通过redis实现一些常用功能
composer require lit/redis-ext
也可以使项目中已初始化好的redisHandler
//连接redis
$redisHandler = new \Redis();
$redisHandler->connect("192.168.1.163");
某些情况下, 我们需要知道周期内某些行为执行了多少次, 但是又不需要把它长久保存下来.
例如:
1. 欢迎您: 2021年1月1日第 x 位访问者.
2. 判断周期内执行过多少次,下一周期自动重置.
3. 整点限流器.
//初始化计数器
Lit\RedisExt\LoopCounter::init($redisHandler);
/**
* 分钟计数器: 实现每分钟5次限流器
* 参数1 计数器redis key 可以根据使用维度自行设置
* 参数2 计数器生命周期, 单位: 分钟
* 参数3 是否完整分钟, true:完整的 x 分钟, false:从第一次计数开始 x 分钟)
* 参数4 每次增加数量
* */
if( Lit\RedisExt\LoopCounter::everyMinutes("test1", 1, false, 1) > 5 ) {
//超限流
}else{
//未超限流
}
/**
* 小时计数器: 实现记录2小时之内第几次访问
* 参数1 计数器redis key 可以根据使用维度自行设置
* 参数2 计数器生命周期, 单位: 小时
* 参数3 是否完整分钟, true:完整的 x 小时 false:从第一次计数开始 x 小时)
* 参数4 每次增加数量
* */
var_dump(Lit\RedisExt\LoopCounter::everyHours("test2", 2, true, 1));
//日期计数器 从当前开始3天
var_dump(Lit\RedisExt\LoopCounter::everyDays("test3", 3, false, 1));
//指定时间计数器 指定某时间过期
var_dump(Lit\RedisExt\LoopCounter::nextRoundAt("test4", time() + 3600 * 7));
//销毁一个计数器
var_dump(Lit\RedisExt\LoopCounter::destroy("test3"));
//获取一个计数器数值
var_dump(Lit\RedisExt\LoopCounter::get("test4"));
某些情况下, 我们需要记录固定条数的数据
例如:
1. 最后充值的 x 位用户.
2. 最后 x 位访客.
3. 最新 x 条动态.
//初始化固定集合
Lit\RedisExt\CappedCollections::init($redisHandler);
/**
* 参数1 固定集合的key
* 参数2 要记录的数据
* 参数3 固定集合限制条数
* */
var_dump(Lit\RedisExt\CappedCollections::set("cappedKey", uniqid(), 20));
/**
* 参数1 固定集合的key
* */
var_dump(Lit\RedisExt\CappedCollections::size("cappedKey"));
注意: 此方法在并发量大的时候,会造成翻页获取数据不准确.
/**
* 参数1 固定集合的key
* 参数2 偏移量
* 参数3 获取数据条数限制
* */
var_dump(Lit\RedisExt\CappedCollections::get("cappedKey", 15, 5));
/**
* 参数1 固定集合的key
* */
var_dump(Lit\RedisExt\CappedCollections::destroy("cappedKey"));
此类使用 lua 脚本, 可能存在不兼容
假设我们某个程序需要限流 '相对周期内' 只能访问5次.
也就是说:
1) 第 1,2,3,4,5 次没有限制.
2) 第6次与第1次的间隔要大于等于1分种.
3) 第7次与第2次的间隔要大于等于1分种.
4) 如果周期内不访问, 过期的 3,4,5 将不会限制 8,9,10 的访问. 依次类推
循环限流器可以保证, 第一次访问和下一次解除限制之间的时间是完整的相对周期.
举个例子:
运输公司的卡车数量不限, 但是只有5个集装箱, 每个集装箱的单次使用周期是1天, 到期后准时归还.
假设所有卡车都遵循此规则, 集装箱的流转过程就是循环限流器要实现的场景.
卡车能拿到集装箱, 说明不限流, 拿不到说明限流. 我们要做的只是调整集装箱的数量.
//初始化限流器
Lit\RedisExt\LoopThrottle::init($redisHandler);
/**
* 参数1 限流器key
* 参数2 限流次数
* 参数2 限流周期
* 返回 true: 可以访问, false: 被限流
* */
var_dump(Lit\RedisExt\LoopThrottle::attempt("tKey1", 2, 10));
/**
* 参数1 限流器key
* 参数2 限流周期
* 返回 周期内有效访问次数
* */
var_dump(Lit\RedisExt\LoopThrottle::count("tKey1", 300));
/**
* 参数1 限流器key
* */
var_dump(Lit\RedisExt\LoopThrottle::destroy("tKey1"));
接口要执行很长一段时间的逻辑, 由于很轻量化, 不想再使用消息队列.可以试一下异步调用方法.
此方法需要启动一个定时任务或者守护进程.
/**
* 参数1: $redisHandler redis链接句柄
* 参数2: int $collectionsLength 内置固定集合长度, 用于保存执行历史
*/
\Lit\RedisExt\AsyncMethod::init($redisHandler, 50);
/**
* 参数1: 固定的RedisKey
* 参数2: 被实例化的对象
* 参数3: 要执行的方法名称
* 参数4: 调用的所有参数 (注意,此参数会在执行是增加一个 _uniqId 下标的唯一ID,供使用者对进程进行监控, 详见demo)
* 返回值: string 唯一的进程ID _uniqId
*/
\Lit\RedisExt\AsyncMethod::add("testKey", new \Demo\DemoClass(), 'staticClass', ["a" => 1, "b" => 3]);
/**
* 参数1: 固定的RedisKey
* 返回值: array
* callable: 函数调用信息
* return: 异步方法返回值
*/
\Lit\RedisExt\AsyncMethod::run("testKey");
/**
* 参数1: add 方法返回的唯一进程ID
* 返回值: int|false
* int 进程状态码
* false 未找到记录
* 附进程状态码:
* -1 失败
* 0 等待中
* 1 运行中
* 2 成功
*/
var_dump(\Lit\RedisExt\AsyncMethod::getStatus("t-632ad7f381214"));
/**
* 参数1: 指定一个RedisKey, 同 add 方法一致
* 参数2: 列表分页 索引
* 参数3: 列表分页 显示条数
* 返回值: array 列表数据
* data: 数据
* nextIndex: 下一页索引开始
* count: 总条数
*/
var_dump(\Lit\RedisExt\AsyncMethod::getList("testKey",0 , 10));
\Lit\RedisExt\XLocks::init($redisHandler);
/**
* 参数1: 锁的RedisKey
* 参数2: 自动解锁时间(秒). 0为不自动解锁
* 参数3: 使用完成后自动解锁(忽略自动解锁时间)
* 返回值: bool true拿到锁, false未拿到锁
*/
var_dump(\Lit\RedisExt\XLocks::lock("testa", 20, true));
/**
* 参数1: 锁的RedisKey
* 返回值: bool true已解锁, false解锁失败或未上锁
*/
var_dump(\Lit\RedisExt\XLocks::unLock("testa"));
/**
* 参数1: 锁的RedisKey
* 返回值: int 锁的生命周期
*/
var_dump(\Lit\RedisExt\XLocks::ttl("testa"));
\Lit\RedisExt\CacheSup::init($redisHandler);
$version = "1.0.0";
var_dump(\Lit\RedisExt\CacheSup::get("tmpKey:0", $version));
//NULL
// 或者
//array(2) {
// [0]=>
// string(19) "tmp:1:64586e4405fa5"
// [1]=>
// string(19) "tmp:2:64586e4406026"
//}
$version = "1.0.0";
var_dump(\Lit\RedisExt\CacheSup::set("tmpKey:0", ["tmp:1:" . uniqid(), "tmp:2:" . uniqid()], $version, 30));
//bool(true)
$version = "1.0.0";
$keyObject = new CacheStringKey("tmpKey:0:0", [1, 1]);
$data = \Lit\RedisExt\CacheSup::getOrSet($keyObject, function ($id1, $id2) {
return $id1 . ":" . $id2 . ":" . uniqid();
}, $version, 30);
$version = "1.0.0";
var_dump(\Lit\RedisExt\CacheSup::mGet(["tmpKey:1", "tmpKey:2", "tmpKey:3"], $version));
//array(3) {
// ["tmpKey:1"]=>
// NULL
// ["tmpKey:2"]=>
// NULL
// ["tmpKey:3"]=>
// NULL
//}
//或者
//array(3) {
// ["tmpKey:1"]=>
// string(19) "tmp:1:64586e4407117"
// ["tmpKey:2"]=>
// string(19) "tmp:2:64586e4407140"
// ["tmpKey:3"]=>
// string(19) "tmp:3:64586e4407145"
//}
$version = "1.0.0";
$cacheData = ["tmpKey:1" => "tmp:1:" . uniqid(), "tmpKey:2" => "tmp:2:" . uniqid(), "tmpKey:3" => "tmp:3:" . uniqid()];
var_dump(\Lit\RedisExt\CacheSup::mSet($cacheData, $version, 30));
//bool(true)
$version = "1.0.0";
$keyObjects = [
new CacheStringKey("tmpKey:1:1", [1, 1]),
new CacheStringKey("tmpKey:2:2", [2, 2]),
new CacheStringKey("tmpKey:3:3", [3, 3])
];
$data = \Lit\RedisExt\CacheSup::mGetOrSet($keyObjects, function ($id1, $id2) {
return $id1 . ":" . $id2 . ":" . uniqid();
}, $version, 30);
var_dump($data);
//array(3) {
// ["tmpKey:1:1"]=>
// string(17) "1:1:64586db82eded"
// ["tmpKey:2:2"]=>
// string(17) "2:2:64586db82ee35"
// ["tmpKey:3:3"]=>
// string(17) "3:3:64586db82ee3a"
//}
见 示例