环境要求

1.PHP >= 7
2.composer
3.redis(必须支持lua)
4.predis

composer 安装

redis 安装

predis 安装

composer require predis/predis

lock 安装

composer require nabao/lock

抢占锁

lock(callable $callback, string $lock_val)

$callback 
 回调函数, 可返回值
$lock_val
 锁定值

多参数抢占锁

lock(callable $callback, array $lock_vals)

$callback 
 回调函数, 可返回值
$lock_vals
 锁定值(数组)

队列锁

queueLock($closure, $lock_val, $max_queue_process = 100, $expiration = 60)

$callback 
 回调函数, 可返回值
$lock_val
 锁定值
$max_queue_process 
 队列最大等待进程 
$expiration
 进程最大执行时间 

多参数队列锁

queueLock($closure, $lock_vals, $max_queue_process = 100)

$callback 
 回调函数, 可返回值
$lock_vals
 锁定值(数组)
$max_queue_process 
 队列最大等待进程 

使用

//静态调用
$lock_val = 'user:pay:1';
Lock::lock(function($redis){
 echo 'hello world!';
}, $lock_val);
 
//实例化调用
$lock = new Lock();
$lock_val = 'user:pay:1';
$lock->lock(function($redis){
 echo 'hello world!';
}, $lock_val);
//多参数锁
$lock = new Lock();
$lock_val[] = 'user:pay:1';
$lock_val[] = 'user:pay:2';
$lock->lock(function($redis){
 echo 'hello world!';
}, $lock_val);

限流

isActionAllowed($key, $period, $max_count)

$key 限制key
$period 限制时间(秒)
$max_count 限制时间内最大数量

config配置

目前兼容tp.其它框架请实例化传参

 /*
 |--------------------------------------------------------------------------
 | lock配置文件
 |--------------------------------------------------------------------------
 |
 |drive 锁驱动(默认redis)
 |
 |redis redis驱动配置
 | host 地址
 | port 端口
 |
 |params 参数配置
 | max_queue_process 进程池最大进程
 | expiration 锁值过期时间
 |
 */
 'lock'=>[
 'drive' => 'redis',
 'redis' => [
 'host' => '127.0.0.1',
 'port' => '6379'
 ],
 'params' => [
 'max_queue_process' => 100
 'expiration' => 5
 ]
 ]