Redis 发布-订阅

环境说明

基于Window的Redis.3.2.100

Redis的发布与订阅

Redis 提供了基于“发布/订阅”模式的消息机制，发送者（publish）发布消息，订阅者（subscribe）接收消息，两者之间不需要进行直接通信，他们之间通过频道进行消息传递。发布者向指定的频道（channel）发布消息，订阅了该频道的订阅者都可以接收到该消息。

Redis 中发布订阅相关的命令如下：

PSUBSCRIBE pattern [pattern …]：订阅一个或多个符合给定模式的频道。
PUBSUB subcommand [argument [argument …]]：查看订阅与发布系统状态。
PUBLISH channel message ：将信息发送到指定的频道。
PUNSUBSCRIBE [pattern [pattern …]]：退订所有给定模式的频道。
SUBSCRIBE channel [channel …]：订阅给定的一个或多个频道的信息。
UNSUBSCRIBE [channel [channel …]]：退订给定的频道。

命令演示
开启 4 个客户端，1 个消息发布者，3 个消息订阅者。

1、2、3 为消息订阅者，4 为消息发布者。
在 1 、2、3 消息订阅者分别执行：subscribe channel1，订阅 channel 频道：
```
127.0.0.1:6379> subscribe channel1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1
```
在窗口4 消息发布者执行：publish channel1 “Hello World”，向频道 channel1 发布消息：

返回值为 3 ，表示有 3 个订阅者。同时，3 个订阅者应该都接收到了消息。
message：返回值类型，message 表示消息
channel1：消息的频道名称

Hello World：消息的内容

程序演示

引入Jedis客户端依赖

<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.3.0</version>
</dependency>

通过一个简单的程序来演示 Redis 的发布/订阅模式。
首先是发布者：

public class Publisher{
  public static void main(String[] args) {
      Jedis jedis = new Jedis("127.0.0.1",6379);
      System.out.println("我是发布者....");
      jedis.publish("channel2","hello,girls.....");
      System.out.println("消息发布完毕....");
  }
}

然后是订阅者：

public class Subscriber extends JedisPubSub{
  @Override
  public void onMessage(String channel, String message) {
      System.out.println("订阅渠道:["+ channel + "],收到的消息："+ message);
  }
  public static void main(String[] args) {
      Jedis jedis = new Jedis("127.0.0.1",6379);
      Subscriber subscriber = new Subscriber();
      // 从Redis订阅
      System.out.println("我是订阅者.....");
      jedis.subscribe(subscriber, "channel2");
  }
}

JedisPubSub 类是 Jedis 的一个抽象类，此类定义了 publish/subscribe 的回调方法，通过继承 JedisPubSub 类，重写回调方法就可以实现 Redis 的发布订阅

onMessage()：发布者发布消息时，会执行订阅者的回调方法 onMessage(),接收发布的消息。

先运行订阅者，然后运行发布者，就可以得到想要的效果，如下：

发布订阅是一种应用程序之间通信和传递数据的通信手段，这种模式在实际应用中得到广泛的使用，比如网络聊天、实时广播、提醒、微信公众号等等，它实现了应用之间的解耦。

SQL

Redis-实现[发布-订阅]

环境说明

Redis的发布与订阅

命令演示

程序演示