Redis学习之发布与订阅机制

Posted 2020-10-12 无谓的test

Redis提供了发布订阅功能，可以用于消息的传输，Redis的发布订阅机制包括三个部分，分别是发布者、订阅者、频道(channel)。注意：redis属于即发即弃的机制，信息发送后则会丢失，如果订阅者断网就收不到该信息了。这里的机制是客户端绑定了发布者，和订阅者。channel属于服务端。发布者客户端发送一条消息到channel后，channel会将消息发送至订阅者，同时这条消息它不会存储，也不管订阅者是否能成功接收到消息。使用场景应该属于哪种不重要的消息队列环境。

 

 发布者和订阅者都是Redis客户端，channel则为Redis服务端，发布者将消息发送到某个频道，订阅了这个频道的订阅者就能接收到这条消息。Redis的这种发布订阅机制与基于主题的发布订阅类似，channel相当于主题。

 

(1)发送消息

Redis采用PUBLISH命令发送消息，其返回值为接收该消息的订阅者的数量。

127.0.0.1:6379> PUBLISH redis123 "hello"    //表示有两个订阅者数量

(integer) 2

 

(2)订阅某个频道

Redis采用SUBSCRIBE命令订阅某个频道，其返回值包括客户端订阅的频道，目前已订阅的频道数量，以及接收到的消息，其中subscribe表示已经成功订阅了某个频道

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "redis123"

3) (integer) 1

1) "message"

2) "redis123"

3) "hello"

 

(3)取消订阅

Redis采用UNSUBSCRIBE和PUNSUBSCRIBE命令取消订阅，其返回值与订阅类似。由于Redis的订阅操作是阻塞式的，因此一旦客户端订阅了某个频道或模式，就将会一直处于订阅状态直到退出。在SUBSCRIBE，PSUBSCRIBE，UNSUBSCRIBE和PUNSUBSCRIBE命令中，其返回值都包含了该客户端当前订阅的频道和模式的数量，当这个数量变为0时，该客户端会自动退出订阅状态。

 

Redis发布订阅与ActiveMQ的比较

（1）ActiveMQ支持多种消息协议，包括AMQP，MQTT，Stomp等，并且支持JMS规范，但Redis没有提供对这些协议的支持； 

（2）ActiveMQ提供持久化功能，但Redis无法对消息持久化存储，一旦消息被发送，如果没有订阅者接收，那么消息就会丢失； 

（3）ActiveMQ提供了消息传输保障，当客户端连接超时或事务回滚等情况发生时，消息会被重新发送给客户端，Redis没有提供消息传输保障。 

总之，ActiveMQ所提供的功能远比Redis发布订阅要复杂，毕竟Redis不是专门做发布订阅的，但是如果系统中已经有了Redis，并且需要基本的发布订阅功能，就没有必要再安装ActiveMQ了，因为可能ActiveMQ提供的功能大部分都用不到，而Redis的发布订阅机制就能满足需求。