limslock/lock

redis lock https://github.com/zhaocong6/lock 根据大佬修车工修改完成

redislock

基于tp5  如果其他框架请修改config.php配置
安装地址
composer require limslock/lock

基于predis类
如需自己安装predis请执行
composer require predis/predis
tp5扩展，如需其他请自行配置Config.php

单队列调用 每次只执行一个消息，多余消息将直接返回队列被抛出异常：单队列已被占用！请稍后

$lock=new Lock();
$lock->queueLock(
    function ($redis){
        echo "hello word!";
        sleep(10);
    },
    "hello",
    50
);

多队列调用 可持续写入消息，当超过最大队列消息，将会抛出异常：队列已被占满，请等待处理完毕后重试

$lock->lock(
    function ($redis){
        echo "hello word!";
        sleep(10);
    },
    "hello",
    50,
    3
);

备注

6-22  2：15 修改命名空间
6-22  2：38 修改readme.me