目录

消息通知 任务队列模式 VS 发布订阅模式

优先级队列

  • 当一个队列中有许多任务仍然没有来得及被消费者及时消费时，如果出现紧急的消息，则不得不等待队列中的任务被一一取出，因此，需要实现一个优先级队列，当优先级队列不为空时，消费者优先取出优先级队列中的任务去执行。

  • BLPOP命令可以同时接收多个键BLPOP key [key ...] timeout，当所有键（列表类型）都为空时，则阻塞，当其中一个有元素则会从该键返回。==如果多个键都有元素则按照从左到右的顺序取第一个键中的一个元素，因此可以借此特性实现优先级队列

127.0.0.1:6379> LPUSH queue1 first 
(integer) 1
127.0.0.1:6379> LPUSH queue2 second
(integer) 1

//当两个键都有元素时，按照从左到右的顺序取第一个键中的一个元素
127.0.0.1:6379> BRPOP queue1 queue2 0
1) "queue1"
2) "first"
127.0.0.1:6379> BRPOP queue1 queue2 0
1) "queue2"
2) "second"

发布/订阅者模式

  • 发布/订阅（publish/subscribe）模式同样可以实现进程间通信，==订阅者可以订阅一个或多个频道（channel），而发布者可以向指定的频道发送消息，所有订阅次频道的订阅者都会收到消息。

  • PUBLISH channel msg 将信息 message 发送到指定的频道 channel。返回收到消息的客户端数量。

  • SUBSCRIBE订阅给指定频道的信息。一旦客户端进入订阅状态，客户端就只可接受订阅相关的命令SUBSCRIBE、PSUBSCRIBE、UNSUBSCRIBE和PUNSUBSCRIBE除了这些命令，其他命令一律失效。

  • UNSUBSCRIBE 取消订阅指定的频道，如果不指定，则取消订阅所有的频道。

127.0.0.1:6379> PUBLISH channel1.1 test
(integer) 0 //有0个客户端收到消息

127.0.0.1:6379> SUBSCRIBE channel1.1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"  //"subscribe"表示订阅成功的信息
2) "channel1.1" //表示订阅成功的频道
3) (integer) 1  //表示当前订阅客户端的数量
//当发布者发布消息时，订阅者会收到如下消息
1) "message"    //表示接收到消息
2) "channel1.1" //表示产生消息的频道
3) "test"       //表示消息的内容
//当订阅者取消订阅时会显示如下：
127.0.0.1:6379> UNSUBSCRIBE channel1.1
1) "unsubscribe"    //表示成功取消订阅
2) "channel1.1" //表示取消订阅的频道
3) (integer) 0  //表示当前订阅客户端的数量

//注：在redis-cli中无法测试UNSUBSCRIBE命令