开源中国

我们不支持 IE 10 及以下版本浏览器

It appears you’re using an unsupported browser

为了获得更好的浏览体验,我们强烈建议您使用较新版本的 Chrome、 Firefox、 Safari 等,或者升级到最新版本的IE浏览器。 如果您使用的是 IE 11 或以上版本,请关闭“兼容性视图”。
YurunLock首页、文档和下载 - PHP阻塞锁和非阻塞锁机制 - 开源中国社区
全部项目分类
我要评价
MIT
PHP
跨平台
宇润
分享
收藏
6 人收藏
收录时间:2017-08-08
YurunLock 详细介绍

YurunLock

PHP阻塞锁和非阻塞锁机制,内置解决并发锁重复执行的方案。目前支持文件、Redis、Memcache、Memcached。

composer安装

在你项目中的 composer.json 文件中加入下面的内容

{
    "require": {
        "yurunsoft/yurun-lock": "dev-master"
    }
}

中国用户如果使用composer很卡,请查看:https://pkg.phpcomposer.com/

代码用法

文件锁

<?php
$lock = new \Yurun\Until\Lock\File('我是锁名称');

$lock->lock(); // 阻塞锁
// TODO:在这里做你的一些事情
$lock->unlock(); // 解锁

// 带回调的阻塞锁,防止并发锁处理重复执行
result = $lock->lock(
    function(){
        // TODO:在这里做你的加锁后处理的任务

    },
    function(){
        // 判断是否其它并发已经处理过任务
        return false;
    }
);
switch($result)
{
    case LockConst::LOCK_RESULT_CONCURRENT_COMPLETE:
        // 其它请求已处理
        break;
    case LockConst::LOCK_RESULT_CONCURRENT_UNTREATED:
        // 在当前请求处理
        break;
    case LockConst::LOCK_RESULT_FAIL:
        // 获取锁失败
        break;
}

// 不阻塞锁,获取锁失败就返回false
if($lock->unblockLock())
{
    // TODO:在这里做你的一些事情
}
else
{
    // 获取锁失败
}

redis/memcache/memcached锁

<?php
$lock = new \Yurun\Until\Lock\Redis(    // 可以把Redis替换成Memcache/Memcached,下面代码用法相同
    '我是锁名称',
    array(
        'host'      =>  '127.0.0.1',
        'port'      =>  11211,
        'timeout'   =>  0,
        'pconnect'  =>  false,
    ), // 连接配置,留空则为默认值
    0, // 获得锁等待超时时间,单位:毫秒,0为不限制,留空则为默认值
    1, // 获得锁每次尝试间隔,单位:毫秒,留空则为默认值
    3, // 锁超时时间,单位:秒,留空则为默认值
);

$lock->lock(); // 阻塞锁
// TODO:在这里做你的一些事情
$lock->unlock(); // 解锁

// 带回调的阻塞锁,防止并发锁处理重复执行
result = $lock->lock(
    function(){
        // TODO:在这里做你的加锁后处理的任务

    },
    function(){
        // 判断是否其它并发已经处理过任务
        return false;
    }
);
switch($result)
{
    case LockConst::LOCK_RESULT_CONCURRENT_COMPLETE:
        // 其它请求已处理
        break;
    case LockConst::LOCK_RESULT_CONCURRENT_UNTREATED:
        // 在当前请求处理
        break;
    case LockConst::LOCK_RESULT_FAIL:
        // 获取锁失败
        break;
}

// 不阻塞锁,获取锁失败就返回false
if($lock->unblockLock())
{
    // TODO:在这里做你的一些事情
}
else
{
    // 获取锁失败
}

直接传入操作对象

直接传入操作对象支持文件、redis、memcache、memcached。可以防止重复实例化对象,造成内存和网络负担。

// 文件
$fp = fopen('1.txt', 'w+');
$lock = new \Yurun\Until\Lock\File('我是锁名称', $fp);
$lock->lock();
// 做一些事情
$lock->unlock();
fclose($fp);

// redis、memcache、memcached同理
$redis = new \Redis;
$redis->connect($host, $port, $timeout);
$lock = new \Yurun\Until\Lock\Redis('我是锁名称', $$redis);
$lock->lock();
// 做一些事情
$lock->unlock();
redis->close();
YurunLock

选择将代码托管在码云
你还在等什么

可能是中国最大最好的代码托管平台


大家对 YurunLock 的评论 (全部 0 条评论)
{{repayCom.userName}}
顶部