Redis实践操作之—— keyspace notification(键空间通知)

源码地址:https://github.com/Tinywan/PHP_Experience


 

一、需求分析:

  1. 设置了生存时间的Key,在过期时能不能有所提示?
  2. 如果能对过期Key有个监听,如何对过期Key进行一个回调处理?
  3. 如何使用 Redis 来实现定时任务?

二、序言:

       本文所说的定时任务或者说计划任务并不是很多人想象中的那样,比如说每天凌晨三点自动运行起来跑一个脚本。这种都已经烂大街了,随便一个 Crontab 就能搞定了。

       这里所说的定时任务可以说是计时器任务,比如说用户触发了某个动作,那么从这个点开始过二十四小时我们要对这个动作做点什么。那么如果有 1000 个用户触发了这个动作,就会有 1000 个定时任务。于是这就不是 Cron 范畴里面的内容了。

       举个最简单的例子,一个用户推荐了另一个用户,我们定一个二十四小时之后的任务,看看被推荐的用户有没有来注册,如果没注册就给他搞一条短信过去。

三、Redis介绍

       在 Redis 的 2.8.0 版本之后,其推出了一个新的特性——键空间消息(Redis Keyspace Notifications),它配合 2.0.0 版本之后的 SUBSCRIBE 就能完成这个定时任务

的操作了,不过定时的单位是秒。

(1)Publish / Subscribe 

     Redis 在 2.0.0 之后推出了 Pub / Sub 的指令,大致就是说一边给 Redis 的特定频道发送消息,另一边从 Redis 的特定频道取值——形成了一个简易的消息队列。

(2)Redis Keyspace Notifications

      在 Redis 里面有一些事件,比如键到期、键被删除等。然后我们可以通过配置一些东西来让 Redis 一旦触发这些事件的时候就往特定的 Channel 推一条消息。

     大致的流程就是我们给 Redis 的某一个 db 设置过期事件,使其键一旦过期就会往特定频道推消息,我在自己的客户端这边就一直消费这个频道就好了。

     以后一来一条定时任务,我们就把这个任务状态压缩成一个键,并且过期时间为距这个任务执行的时间差。那么当键一旦到期,就到了任务该执行的时间,Redis 自然会把过期消息推去,我们的客户端就能接收到了。这样一来就起到了定时任务的作用。

 四、Key过期事件的Redis配置

      这里需要配置 notify-keyspace-events 的参数为 “Ex”。x 代表了过期事件。notify-keyspace-events "Ex" 保存配置后,重启Redis服务,使配置生效。
重启Reids服务器:

root@iZ23s8agtagZ:/etc/redis# service redis-server restart redis.conf
Stopping redis-server: redis-server.
Starting redis-server: redis-server.

添加过期事件订阅 开启一个终端,redis-cli 进入 redis 。开始订阅所有操作,等待接收消息。

tinywan@iZ23a7607jaZ:~$ redis-cli -h 127.0.01.4 -p 63789
127.0.0.1:63789> psubscribe __keyevent@0__:expired
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "__keyevent@0__:expired"
3) (integer) 1

再开启一个终端,redis-cli 进入 redis,新增一个 20秒过期的键:

1270.01.1.1:63789> SETEX coolName 123 20
OK
121.41.188.109:63789> get coolName
"20"
121.41.188.109:63789> ttl coolName
(integer) 104

另外一边执行了阻塞订阅操作后的终端,20秒过期后有如下信息输出:

121.141.188.209:63789> psubscribe __keyevent@0__:expired
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "__keyevent@0__:expired"
3) (integer) 1
1) "pmessage"
2) "__keyevent@0__:expired"
3) "__keyevent@0__:expired"
4) "coolName"

说明:说明对过期Key信息的订阅是成功的。

 五、PHPREDIS实现订阅Keyspace notification

 Redis实例化类:(RedisInstance.class.php)

<?php

class RedisInstance
{
    private $redis;

    public function __construct($host = '121.41.88.209', $port = 63789)
    {
        $this->redis = new Redis();
        $this->redis->connect($host, $port);
    }

    public function expire($key = null, $time = 0)
    {
        return $this->redis->expire($key, $time);
    }

    public function psubscribe($patterns = array(), $callback)
    {
        $this->redis->psubscribe($patterns, $callback);
    }

    public function setOption()
    {
        $this->redis->setOption(\Redis::OPT_READ_TIMEOUT,-1);
    }

}

过期事件的订阅:(psubscribe.php)

<?php
require_once './RedisInstance.class.php';
$redis = new \RedisInstance();// 解决Redis客户端订阅时候超时情况
$redis->setOption();
$redis->psubscribe(array('__keyevent@0__:expired'), 'psCallback');
// 回调函数,这里写处理逻辑
function psCallback($redis, $pattern, $chan, $msg)
{
    echo "Pattern: $pattern\n";
    echo "Channel: $chan\n";
    echo "Payload: $msg\n\n";
}

说明:psCallback 函数为订阅事件后的回调函数。$redis, $pattern, $chan, $msg 四个参数为回调时返回的参数。 详细说明见下面 Redis 官方文档对 psubscribe 的说明。

因为订阅事件启动后是阻塞执行的,所以我们尝试在终端执行 psubscribe.php 这个脚本。

D:\wamp\www\redistest>php psubscribe.php

设置一个过期事件:

121.41.188.109:63789> SETEX username123 20

20秒过期时间到时,另外一边执行了脚本被阻塞的终端,有如下信息输出订阅结果:

D:\wamp\www\redistest>php psubscribe.php
Pattern: __keyevent@0__:expired
Channel: __keyevent@0__:expired
Payload: username123

以上PHP操作Reids是成功的

 六、使监听后台始终运行(订阅)

     有个问题 做到这一步,利用 phpredis 扩展,成功在代码里实现对过期 Key 的监听,并在 psCallback()里进行回调处理。 开头提出的两个需求已经实现。 可是这里有个问题:redis 在执行完订阅操作后,终端进入阻塞状态,需要一直挂在那。且此订阅脚本需要人为在命令行执行,不符合实际需求。

    实际上,我们对过期监听回调的需求,是希望它像守护进程一样,在后台运行,当有过期事件的消息时,触发回调函数。 使监听后台始终运行 希望像守护进程一样在后台一样,

我是这样实现的。

    Linux中有一个nohup命令。功能就是不挂断地运行命令。 同时nohup把脚本程序的所有输出,都放到当前目录的nohup.out文件中,如果文件不可写,则放到<用户主目录>/nohup.out 文件中。那么有了这个命令以后,不管我们终端窗口是否关闭,都能够让我们的php脚本一直运行。

编写PHP脚本文件:

<?php
#! /usr/local/php/bin/php
require_once './redis.class.php';
$redis = new MyRedis();
$redis->setOption();
$redis->psubscribe(array('__keyevent@0__:expired'), 'psCallback');
// 回调函数,这里写处理逻辑
function psCallback($redis, $pattern, $chan, $msg)
{
    echo "Pattern: $pattern\n";
    echo "Channel: $chan\n";
    echo "Payload: $msg\n\n";
}

注意:不过我们在开头,需要申明 php 编译器的路径:#! /usr/local/php/bin/php 。 这是执行 php 脚本所必须的。

然后,nohup 不挂起执行 nohupRedisNotify.php,注意 末尾的 &

[root@chokingwin HiGirl]# nohup ./nohupRedisNotify.php & [1] 4456 nohup: ignoring input and appending output to `nohup.out'

确认一下脚本是否已在后台运行。查看进程结果如下: 

[root@chokingwin HiGirl]# ps PID TTY TIME CMD 3943 pts/2 00:00:00 bash 4456 pts/2 00:00:00 nohupRedisNotif 4480 pts/2 00:00:00 

说明:脚本确实已经在 4456 号进程上跑起来。 

最后在查看下nohup.out cat 一下 nohuo.out,看下是否有过期输出:

[root@chokingwin HiGirl]# cat nohup.out [root@chokingwin HiGirl]#

并没有。我们还是老样子,新增一个10秒过期的的键 name。10秒后,我们再 cat 一次。 

[root@chokingwin HiGirl]# cat nohup.out Pattern: __keyevent@0__:expired Channel: __keyevent@0__:expired Payload: name

说明监听过期事件并回调成功。

nohup命令:记录详情:

nohup没有输出的情况:

sudo nohup nohupRedisNotify.php > /dev/null 2>&1 &

查看jobs进程ID:[ jobs -l ]命令

www@iZ232eoxo41Z:~/tinywan $ jobs -l
[1]-  1365 Stopped (tty output)    sudo nohup nohupRedisNotify.php > /dev/null 2>&1
[2]+  1370 Stopped (tty output)    sudo nohup nohupRedisNotify.php > /dev/null 2>&1

linux kill进程杀不掉(解决办法):

kill -9 PID
www@iZ232eoxo41Z:~/tinywan $ sudo kill -9 1370
[2]+  Killed                  sudo nohup nohupRedisNotify.php > /dev/null 2>&1

 如果是以后运行的后台程序的,命令【jobs -l】是没办法察觉任务以及PID的,这时候可以借助:ps aux | grep nohup 筛选哦,在使用 kill PID 铲除即可

在这里是www用户已root运行的任务,用jobs -l

jobs -l

www@iZ232eoxo41Z:~ $ jobs -l
www@iZ232eoxo41Z:~ $ 

ps aux | grep nohup 

www@iZ232eoxo41Z:~ $ ps aux | grep nohup
root     18448  0.0  0.2  65160  2088 ?        S    14:44   0:00 sudo nohup php ./nohupRedisNotify.php
root     18449  0.0  1.5 283368 15956 ?        S    14:44   0:00 php ./nohupRedisNotify.php
www      18605  0.0  0.0  11740   928 pts/1    S+   14:50   0:00 grep --color=auto nohup

 经验分享环节:

1、今天在Linux服务器执行一个php脚本nohup.php 挂起一个Redis订阅事件的时候,发现每次都不会调用API接口传递参数。但是直接执行的话(php nohup.php)的时候是 可以调用接口的,经过检查发现是权限的问题:

分析:当前登录用户为www用户:但是启动脚本的时候确实这样的(Root身份执行):(可以在命令行直接执行,打印过期的事件key,并且输出可以作为调试哦!)

sudo nohup php nohupRedisNotify.php > /dev/null 2>&1 &

修改后的:

nohup php nohupRedisNotify.php > /dev/null 2>&1 &

这样的话就直接可以回调自己写的API接口啦!

 

时间: 2024-08-04 10:56:57

Redis实践操作之—— keyspace notification(键空间通知)的相关文章

直播兴起的军功章上也有你的一半——Redis实践及在直播行业的应用

以下为直播整理内容. 云数据库Redis是一种稳定可靠.性能卓越.可弹性伸缩的数据库服务:它基于飞天分布式系统和全SSD盘高性能存储,支持主备版和集群版两套高可用架构:并提供了全套的容灾切换.故障迁移.在线扩容.性能优化的数据库解决方案. Redis介绍 Redis的全称是Remote Dictionary Server,它是由Salvatore Sanfilippo写的Key-Value存储系统.但它提供了比Key-Value更为丰富的数据结构,包括Lists.Sets.Ordered Set

搜索引擎的投票原理与实践操作

投票原理在搜索引擎优化中是我们经常提及的词,锚文本外链对关键词的投票,优质内容对网站信用度的投票,友情链接互相网站的投票等等,这些都是我们经常看到的投票,我们知道好的投票对我们网站的关键词排名是有帮助的,我们要首先研究清楚搜索引擎投票规则的基本原理是什么,知道了原理以后我们可以根据原理相对的进行实际的操作,包括内链.外链的操作等等,今天给大家分享几点关于搜索引擎投票原理的内容. 一.投票的基本原理 投票在我们日常生活中是经常碰到的,大大小小的选举.选最优者等等,票数最多的那一个就是最后胜出的,而

【区块链】Truffle 部署 编译 测试 智能合约 的 完整实践操作

Truffle 部署 编译 测试 智能合约 的 完整实践操作 目标 搭建开发环境 创建一个Truffle项目 编写智能合约 编译转移智能合约 测试智能合约 创建用户界面连接智能合约 在浏览器中访问Dapp 搭建开发环境 Node.js v6+ LTS and npm (comes with Node) Git 这里配置脚本略过.... xiaoyu@LIXIAOYUdeMacBook-Pro.com node -v v8.5.0 xiaoyu@LIXIAOYUdeMacBook-Pro.com

mvc怎么操作全是外键的数据库表

问题描述 mvc怎么操作全是外键的数据库表由于mvc不会自动生成全是外键的表的实体类,那运用mvc的linq查询怎么操作呢? 解决方案 解决方案二:mvc怎么会有linq查询??解决方案三:运用linq查询语句解决方案四:引用2楼u014479626的回复: 运用linq查询语句 使用join语句管理主表与外键表通过select语句来获取要显示的主表值或者外键表值.参见:解决方案五:linq现在最常用的操作是查询内存集合,还是很方便的,要是用于linqtosql或者linqtoef之类的,原理就

redis-stachExchange.Redis如何操作泛型数据

问题描述 stachExchange.Redis如何操作泛型数据 stachExchange.Redis 在插入数据的时候一定要指定好hashFields么 如何直接把泛型数据插入和读取出来

数据-spring data redis RedisTemplate 操作

问题描述 spring data redis RedisTemplate 操作 工程结构:springmvc + mybatis: 现在集成redis做基础数据的缓存,如何实现通过PO类的属性查找一个List(类似Java), 如果没有直接的实现办法,请大家给一个思路: 谢谢!

Win7系统的低磁盘空间通知怎么关闭

  使用过Win7系统的朋友都知道,当系统中每个磁盘的空间不够200M的时候,Win7系统就会在桌面的任务栏弹出提示说系统的磁盘空间不够了,一直老弹出的提示让人都非常的烦扰,那有没有办法让磁盘空间不足的通知彻底关闭不在提示呢?下面就跟着小编去看看Win7系统的低磁盘空间通知怎么关闭的. 步骤一:在win7 64位旗舰版桌面点击"开始"菜单选择"运行"选项,然后在"运行"的窗口中中输入regedit命令,回车打开注册表编辑器; 步骤二:然后在注册表

Android 中Notification弹出通知实现代码

NotificationManager 是状态栏通知的管理类,负责发通知.清除通知等操作. NotificationManager 是一个系统Service,可通过getSystemService(NOTIFICATION_SERVICE)方法来获取 接下来我想说的是android5.0 后的弹出通知, 网上的方法是: //第一步:实例化通知栏构造器Notification.Builder: Notification.Builder builder =new Notification.Build

Redis的缓存策略和主键失效机制

作为缓存系统都要定期清理无效数据,就需要一个主键失效和淘汰策略. >>EXPIRE主键失效机制 在Redis当中,有生存期的key被称为volatile, 在创建缓存时,要为给定的key设置生存期,当key过期的时候(生存期为0),它可能会被删除. (1)影响生存时间的一些操作 生存时间可以通过使用 DEL 命令来删除整个 key 来移除,或者被 SET 和 GETSET 命令覆盖原来的数据, 也就是说,修改key对应的value和使用另外相同的key和value来覆盖以后,当前数据的生存时间