YuruLock
PHP阻塞锁和非阻塞锁机制，内置解决并发锁重复执行的方案。目前支持文件、Redis、Memcache、Memcached。
composer安装在你项目中的 composer.jso 文件中加入下面的内容
{ "require": { "yurusoft/yuru-lock": "dev-master" }}中国用户如果使用composer很卡，请查看：https://pkg.phpcomposer.com/
代码用法文件锁<?php$lock = ew \Yuru\Util\Lock\File('我是锁名称');$lock->lock(); // 阻塞锁// TODO:在这里做你的一些事情$lock->ulock(); // 解锁// 带回调的阻塞锁，防止并发锁处理重复执行result = $lock->lock( fuctio(){ // TODO:在这里做你的加锁后处理的任务 }, fuctio(){ // 判断是否其它并发已经处理过任务 retur false; });switch($result){ case LockCost::LOCK_RESULT_CONCURRENT_COMPLETE: // 其它请求已处理 break; case LockCost::LOCK_RESULT_CONCURRENT_UNTREATED: // 在当前请求处理 break; case LockCost::LOCK_RESULT_FAIL: // 获取锁失败 break;}// 不阻塞锁，获取锁失败就返回falseif($lock->ublockLock()){ // TODO:在这里做你的一些事情}else{ // 获取锁失败}redis/memcache/memcached锁<?php$lock = ew \Yuru\Util\Lock\Redis( // 可以把Redis替换成Memcache/Memcached，下面代码用法相同 '我是锁名称', array( 'host' => '127.0.0.1', 'port' => 11211, 'timeout' => 0, 'pcoect' => false, ), // 连接配置，留空则为默认值 0, // 获得锁等待超时时间，单位：毫秒，0为不限制，留空则为默认值 1, // 获得锁每次尝试间隔，单位：毫秒，留空则为默认值 3, // 锁超时时间，单位：秒，留空则为默认值);$lock->lock(); // 阻塞锁// TODO:在这里做你的一些事情$lock->ulock(); // 解锁// 带回调的阻塞锁，防止并发锁处理重复执行result = $lock->lock( fuctio(){ // TODO:在这里做你的加锁后处理的任务 }, fuctio(){ // 判断是否其它并发已经处理过任务 retur false; });switch($result){ case LockCost::LOCK_RESULT_CONCURRENT_COMPLETE: // 其它请求已处理 break; case LockCost::LOCK_RESULT_CONCURRENT_UNTREATED: // 在当前请求处理 break; case LockCost::LOCK_RESULT_FAIL: // 获取锁失败 break;}// 不阻塞锁，获取锁失败就返回falseif($lock->ublockLock()){ // TODO:在这里做你的一些事情}else{ // 获取锁失败}直接传入操作对象直接传入操作对象支持文件、redis、memcache、memcached。可以防止重复实例化对象，造成内存和网络负担。
// 文件$fp = fope('1.txt', 'w+');$lock = ew \Yuru\Util\Lock\File('我是锁名称', $fp);$lock->lock();// 做一些事情$lock->ulock();fclose($fp);// redis、memcache、memcached同理$redis = ew \Redis;$redis->coect($host, $port, $timeout);$lock = ew \Yuru\Util\Lock\Redis('我是锁名称', $$redis);$lock->lock();// 做一些事情$lock->ulock();redis->close();
评论