一.设计模式-发布订阅模式
发布订阅模式,又叫观察者模式,属于四人帮的二十三个设计模式中的行为模式。”定义对象间一种一对多的依赖关系,使得每当一个对象改变状态,则所有依赖于他的对象都会得到通知并被自动更新“,模式UML如下图。
通俗一点可以理解为,Subject中保存了Observer的引用组成的列表。Subject状态变化时,遍历列表调用所有Observer的notify成员方法。
发布订阅模式应用场景很多,相当于在系统中构建一个简单的事件处理系统,部分编程语言(如java提供被观察者类java.util.Observable和观察者接口java.util.Observer)原生库中已包含观察者模式的简单实现。
二.Redis-PubSub介绍
Redis中的PubSub实现较上面复杂,但设计思想和上面一致。
客户端A发出一个订阅的频道名称(可以理解为attach A 到Subject)
subscribe temperature rainfall
其他客户端B发布消息(可以理解为B更新Subjec的状态)
publish rainfall 350cc
A客户端将收到降雨量350cc这条message
客户端A也可以取消订阅频道(可以理解为A从Subjec中detach)
unsubscribe rainfall
在提供订阅频道外,Redis还提供了psubscribe/punsubscribe来订阅/取消订阅一个或多个模式。如果模式照通配符(glob)来匹配某个/ 某些频道,当有信息发送给这个/这些频道的时候, 客户端也会收到这个/这些频道的信息。
二.Redis-PubSub订阅频道
Redis中PubSub实现也比较简单,订阅频道的功能主要保存在字典中,其中key为频道,而value是redisClient组成的列表。
下图为订阅频道的redisServer的pubsub_channels字典示例,ClientA订阅 temperature和rainfall,ClientC订阅temperature
当客户端ClientD订阅已经存在的频道时,将ClientD加到该频道对应的链表的尾巴,如订阅rainfall频道。
当客户端ClientD订阅不存在的频道时,新建新频道的key及对应的链表,将ClientD加到新创建的链表中,下图为ClientD执行 subscribe snow后的字典示例。
当客户端ClientA取消订阅频道时,将客户端ClientA从对应的频道的链表中删除,如果删除后对应的频道无客户订阅,则将对应的频道的key从字典中删除。
如ClientA执行subscribe(无参数的subscribe 命令订阅的所有频道都会被退订)后字典的示例。
以上的所有操作在更新redisServer的pubsub_channels字典的同时也会更新redisClient中的pubsub_channels字典,redisClient的pubsub_channels保存着对应客户端订阅的频道。
四.Redis-PubSub订阅模式
订阅模式的功能保存在redisServer的pubsub_patterns链表中,链表的元素结构如下:
typedef struct pubsubPattern {
/*客户端信息,唯一确认一个客户连接*/
redisClient *client;
/*模式信息的字符串对象,如"*no*"*/
robj *pattern;
} pubsubPattern;
下图示例客户端ClientA 订阅“*it*”、"*eye*",客户端ClientB订阅"*eye*"的链表。
增加时遍历redisClient的pubsub_patterns链表,如果不存在,将新的模式增加到redisServer的pubsub_patterns链表的尾部。
删除时需要遍历redisClient的整个pubsub_patterns,如果存在,在定位redisServer的pubsub_patterns链表进行删除操作。
与订阅频道同样,在更新redisServer的pubsub_patterns链表的同时,也更新redisClient的pubsub_patterns链表,redisClient的pubsub_channels保存着对应客户端订阅的模式。
五.消息发送publish
当发送消息时,先从redisServer找到对应的频道的key所拥有的链表,遍历链表发送消息;然后遍历redisServer的pubsub_patterns链表,对频道和pattern进行匹配(stringmatch),如果适配将信息增加到客户端的返回中。
发送消息的伪代码如下:
/*
* 发送消息
* channel 频道
* message 消息主体
* */
function pubsubPublishMessage(channel,message){
/*需要channel被某些客户端订阅,如果不存在pubsub_channels中,就没有订阅此频道的客户*/
if (isset(server.pubsub_channels[channel])){
/*
* 遍历pubsub_channels中对应频道的订阅者的链表
* 给每个频道订阅者发布消息
* */
foreach (server.pubsub_channels[channel] as receiver){
sendMessage(receiver, message);
}
}
/*遍历模式订阅的链表*/
foreach (server . pubsub_patterns as pubsubPattern){
/*如果模式与频道适配,发送消息给此客户端*/
if (stringmatch(pubsubPattern.pattern, channel)) {
sendMessage(pubsubPattern.client, message);
}
}
}
从上面代码中可以Redis发布的消息“即发即失”,redis不会持久保存发布的消息, 一旦client端断开链接,将会失去部分消息。
如果需要client非常关注的消息(如用户支付订单成功,client发货),建议不要用Redis的PubSub功能,可以用其他专门的消息队列系统,也可用Redis的链表,然后客户端进行轮询。
- 大小: 28.3 KB
- 大小: 28.3 KB
- 大小: 10.3 KB
- 大小: 15.9 KB
- 大小: 13.5 KB
- 大小: 8.4 KB
- 大小: 26.5 KB
分享到:
相关推荐
redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-...
NRP(节点Redis Pubsub) 该库现在主要由@...安装并测试$ npm install node-redis-pubsub # Install locally$ npm install -g node-redis-pubsub # Install globally$$ make test # test (devDependencies need to
redis-5.0.14-1.el7.remi.x86_64.rpm安装包(含有部署手册) redis-5.0.14-1.el7.remi.x86_64.rpm安装包(含有部署手册) redis-5.0.14-1.el7.remi.x86_64.rpm安装包(含有部署手册) redis-5.0.14-1.el7.remi.x86_64.rpm...
1、基于spring-boot-starter-data-redis实现发布订阅功能 2、依赖的 spring-boot-starter-parent 的版本是 2.5.3 3、如果用IDEA打开后,@Slf4j报错的话,请下载插件 Lombok 详细的功能介绍可以参考这篇博客 ...
redis-pubsub为 Redis 服务器上的单个发布/订阅通道提供了一个简单的接口。 var pubsub = require('redis-pubsub');// Subscribe to channel 'foobar' on a local server.var channel = pubsub.createChannel(6379, ...
redis-5.0.14/src/redis-cli --cluster create 192.168.129.98:7000 192.168.129.99:7003 192.168.129.99:7002 192.168.129.126:7005 192.168.129.126:7004 192.168.129.98:7001 --cluster-replicas
tomcat-redis-session-manager-1.2-tomcat-7-java-7tomcat-redis-session-manager-1.2-tomcat-7-java-7tomcat-redis-session-manager-1.2-tomcat-7-java-7tomcat-redis-session-manager-1.2-tomcat-7-java-7tomcat-...
tomcat-redis-session-manager-2.0.0.jar jedis-2.5.2.jar commons-pool2-2.2.jar 2.修改 conf 目录下的 context.xml 文件 host="localhost" port="6379" database="0" maxInactiveInterval="60" /> ...
Redis在CentOS系统中创建集群可能会用到的安装包, 其中redis-3.0.0.tar是Redis服务, redis-3.0.0.gem是Redis通过ruby创建集群要用到的包
redis-stack-server-7.2.0-v9.arm64.snap redis-stack-server-7.2.0-v9.bionic.arm64.tar.gz redis-stack-server-7.2.0-v9.bionic.x86_64.tar.gz redis-stack-server-7.2.0-v9.bullseye.x86_64.tar.gz redis-stack-...
redis++使用说明,windows下编译redis-plus-plus
redis校验工具redis-full-check,配合redis-shake使用!!!
1: 下载redis-5.0.4.tar.gz 2: 解压源码并进入目录 tar zxvf redis-5.0.4.tar.gz cd redis-5.0.4 3: 不用configure 4: 直接make (如果是32位机器 make 32bit) 查看linux机器是32位还是64位的方法:file /bin/...
文件夹内包括有Redis-x64-3.0.504.zip、Redis-x64-3.2.100.msi。可供大家下载安装。
Redis-x64-5.0.10.msi
压缩文件包括tomcat-redis-session-manager-master-2.0.0.jar、jedis-2.7.3.jar、commons-pool2-2.3.jar三个jar包使用方法请参照https://github.com/jcoleman/tomcat-redis-session-manager。apache-tomcat-8.5.33....
tomcat-redis-session-manager-2.0.0.jar
Redis稳定版 Redis-x64-5.0.14.1.zip
资源在github上下载下来,包含Redis-x64-3.2.100.zip和Redis-x64-3.2.100.msi两个文件
jizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-redis-mqjizq-...