Redis大总结之四:任务队列 | 发布/订阅模式
2017-03-31 14:49
561 查看
任务队列
BRPOP命令:Brpop命令和rpop命令相似,唯一的区别是当列表中没有元素时,brpop命令会一直阻塞住连接,直到有新的元素加入。
Brpop命令接收两个参数,第一个是健名,第二个是超时时间,单位是秒,当超过了此时间仍然没有获得新元素的话就会返回nil,第二个参数设置为“0”表示不限制等待时间,即如果没有新元素加入列表就会永远阻塞下去。
A:6379[7]> brpop list 0//list列表中无元素,一直处于阻塞状态 |光标闪动中… B:6379[7]> lpush list zhangsan//另一端,向list列表中添加元素 (integer) 1 A:6379[7]> brpop list 0//时刻捕获元素,有新元素时,立马输出 1) "list" 2) "zhangsan" (33.15s)//等待的秒数 B:6379[7]> lrange list 0 -1//同时发现B端的list中的新元素没有了 (empty list or set) |
优先级任务队列
同样适用BRPOP参数,参数可以有多个参数key,越往前优先级越高,当多个key都有值的时候,执行BRPOP命令,首先操作第一个key,其次第二个…A> lpush p:1 10 (integer) 1 A> lpush p:2 20 (integer) 1 A> lpush p:3 30 B> brpop p:2 p:3 p:1 0//按照优先级,先获取p:2键的值,P:2排在最前边 1) "p:2" 2) "20" B> brpop p:2 p:3 p:1 0 1) "p:3" 2) "30" B> brpop p:2 p:3 p:1 0 1) "p:1" 2) "10" |
发布/订阅模式
发布者: 127.0.0.1:6379[7]> publish pindao1.1 hille (integer) 1 127.0.0.1:6379[7]> publish pindao1.1 nihao (integer) 1 127.0.0.1:6379[7]> publish pindao1.1 "my name is wangzhongwen" (integer) 1 订阅者:执行订阅命令后,便一直处于监听状态,一旦频道有新消息,立即读取 127.0.0.1:6379[7]> subscribe pindao1.1 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "pindao1.1" 3) (integer) 1 1) "message" 2) "pindao1.1" 3) "hille" 1) "message" 2) "pindao1.1" 3) "nihao" 1) "message" 2) "pindao1.1" 3) " my name is wangzhongwen" |
SUBSCRIBE/UNSUBSCRIBE/PSUBSCRIBE/PUNSUBSCRIBE这4个属于“发布/订阅”模式的命令之外的命令,否则会报错。
按照规则订阅
PSUBSCRIBE pindao1.?*
PSUBSCRIBE 同一个客户端可以重复订阅同一个频道
PUNSUBSCRIBE命令可以退订指定的规则
PUNSUBSCRIBEpindao1.?*;如果没有参数则会退订所有规则。
PUNSUBSCRIBE命令只能退订通过PSUBSCRIBE命令订阅的规则;
UNSUBSCRIBE命令也只能退订通过SUBSCRIBE命令订阅的规则。
注意:PUNSUBSCRIBE* 无法退订 pindao.*规则,
必须使用PUNSUBSCRIBE pindao.*规则,才能退订。
更多:
Redis大总结之一:Redis 五大数据类型及操作
Redis大总结之二:Redis 事务,WATCH命令,生存时间
Redis大总结之三:SORT命令(对 列表|集合|有序集合 进行排序)
------------------完----------------
相关文章推荐
- Redis消息通知(任务队列和发布订阅模式)
- Redis学习笔记(十)消息通知(任务队列和发布订阅模式)
- redis 消息队列 发布、订阅模式
- 【转】redis 消息队列发布订阅模式spring boot实现
- Redis学习笔记(十)消息通知(任务队列和发布订阅模式)
- redis 消息队列发布订阅模式spring boot实现
- redis实现消息队列&发布/订阅模式使用
- Redis入门系列之队列和发布订阅模式
- Spring Data Redis实现消息队列——发布/订阅模式
- 使用redis的发布订阅模式实现消息队列
- 消息队列-ActiveMQ学习笔记(三)-发布-订阅消息模式实现
- Redis发布订阅模式
- Redis - 发布/订阅模式
- redis事务及锁应用、发布订阅模式
- 011 redis的“发布/订阅”模式&redis的排队
- Redis发布与订阅模式
- Redis——发布订阅模式&虚拟内存
- Redis订阅和发布模式和Redis事务
- 基于订阅/发布模式的简易聊天室实现(java+redis)
- Redis基础学习--Redis 事务(watch命令)、生存时间、排序、消息通知("发布/订阅"模式)、管道、节省空间