雅荷心语博客
雅荷心语
心之所向便是光
  • 首页
  • 前端之旅
  • 后端之路
  • 软件工具
  • 心灵鸡汤
  • 心路历程
  • 视频资料
  • 关于我们
    • 关于我
    • 关于我
  • 微信平台
    • 业务合作
  • 首页
  • 前端之旅
  • 后端之路
  • 软件工具
  • 心灵鸡汤
  • 心路历程
  • 视频资料
  • 关于我们
    • 关于我
    • 关于我
  • 微信平台
    • 业务合作
  • 关注本站
    • 微信
    • 微博
    • 腾讯微博
    • Twitter
    • Facebook
    • RSS订阅
Hi, 请登录     我要注册     找回密码

使用redis的发布订阅机制来做计划任务

2019-09-23 分类:后端之路 阅读(1929) 评论(0)

它主要是用了redis的发布订阅机制,redis的notify-keyspace-events  会自动发布一个频道,频道的名称有固定的格式,这里我们监听键的失效事件,的订阅频道名是  __keyevent@0__:expired,订阅了这个频道,当redis的 第0号数据库中有键名失效时,就会收到一个推送,我们就利用这个特点来完成功能!

我们找到 redis的配置文件, 修改配置!

配置:这果在 redis.conf中 设置监听,键的失效事件    notify-keyspace-events Ex

配置好后,重启redis的服务端

首先, 我们存入一个带过期时间的key;10后过期

1
2
3
4
5
6
7
8
9
10
11
<?php
/**
* Created by PhpStorm.
* User: iyahe@qq.com (天明)
* Date: 2019/9/11 0011
* Time: 下午 17:52
*/
$redis = new \redis();
$redis->connect("127.0.0.1",6379);
$redis->setex("order_420682198105122517",10,"xxx");
print_r($redis->get('order_420682198105122517'));

 

然后, 启动一个监听

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
<?php
/**
* Created by PhpStorm.
* User: iyahe@qq.com (天明)
* Date: 2018/12/17 0017
* Time: 下午 13:39
*/
 
//这一句是说长连接不超时,如果没有的话,这个文件会在运行一段时间后自动停止,一定不能少
ini_set('default_socket_timeout', -1);
$redis = new \Redis();
$redis->connect("127.0.0.1", 6379);
$redis->subscribe(["__keyevent@0__:expired"], function ($redis, $event, $key) {
  var_dump($redis, $event, $key);
});

这里只是大至代码,在 function($redis,$event,$key)的函数体中,就可以写上订单作废的逻辑,还有返还库存的逻辑,$redis,$event,$key是 phpredis自动会给我们加上的参数,

$redis 是一个redis对象,

$event 是事件的名称,也就是  __keyevent@0__:expired,

$key 就是失效的键的名称,们就可以用它来做逻辑操作了

等待 10s 之后,

object(Redis)#1 (0) {}
string(22) “__keyevent@0__:expired”
string(24) “order_420682198105122517”
string(24) “order_420682198105122517”

收到了数据, 这样我们可以用这种方法来处理一些特殊的数据,比如订单超时提醒,等待~~

微信图片_20190827154352

喜欢 (1) 赏 讨厌 (0)
分享到:更多 ()

相关推荐

  • 将docker安装到D盘或者其他目录
  • 使用 python 给音频增加水印,剪辑压缩后不丢失!
  • 如何使用 nodejs 下载一个 wav 音频
  • macOS 对 Demucs 的支持
  • edge-tts 初体验
  • 联盟数据查询示例
  • 科学上网记录
  • 在浏览器内使用obs-websocket-js控制obs录屏
关于我

小天明 北京·朝阳 前端搬砖工程师

碎碎念):(来自公众号)

热门文章

  • 踩坑记录——iphone上safari开启隐身模式时localStorage变为只读-雅荷心语博客踩坑记录——iphone上safari开启隐身模式时localStorage变为只读2017-02-21评论(4)
  • 程序员是怎样一群人-雅荷心语博客程序员是怎样一群人2015-12-08评论(3)
  • 百度你个大毒瘤 - 吐糟博客这几天打不开事情-雅荷心语博客百度你个大毒瘤 – 吐糟博客这几天打不开事情2015-12-28评论(2)
  • PHP 非对称加密 openssl 加密及解密方法-雅荷心语博客PHP 非对称加密 openssl 加密及解密方法2016-05-17评论(2)
  • PHPStorm10 下载安装破解汉化-雅荷心语博客PHPStorm10 下载安装破解汉化2015-12-15评论(2)
2025年7月
一 二 三 四 五 六 日
« 六    
 123456
78910111213
14151617181920
21222324252627
28293031  

最新评论

  • 前端小武 8年前 (2017-04-06)说:
    我看到了layer
  • 丁艳平 8年前 (2017-03-03)说:
  • Dawn 9年前 (2016-09-16)说:
    call_user_func_array最后的例子是错哦,你用bc方法去调用类里 另外一个方法就知道问题所在了。情况1.调用非静态方法 第一个参数应该传[类的实例,调用方法] (既然有类实例了直接-&
  • Dawn 9年前 (2016-06-21)说:
    tp框架设置了全局捕获异常的,这也没什么。坑的是 他捕获了异常。然后全部返回404。。。不知道的 还以为自己网站被删除了
  • Dawn 9年前 (2016-05-17)说:
    构造函数里的判断 用异常机制可能更好一些

其他类型

  • 芊云全景
  • 配音兔AI配音神器

博客类型

  • 芊云全景
  • 配音兔AI配音神器

左邻右舍

  • 易水寒
  • 楼教主
  • 芊云全景
  • 贤心
  • 配音兔AI配音神器

雅荷心语博客 -心之所向便是光

联系我们关于我们

© 2025 雅荷心语博客   网站地图