最通俗易懂的Redis釋出訂閱及程式碼實戰
阿新 • • 發佈：2020-04-26
### 釋出訂閱簡介
除了使用List實現簡單的訊息佇列功能以外，Redis還提供了釋出訂閱的訊息機制。在這種機制下，訊息釋出者向指定頻道（channel）釋出訊息，訊息訂閱者可以收到指定頻道的訊息，同一個頻道可以有多個訊息訂閱者，如下圖：
Redis也提供了一些命令支援這個機制，接下來我們詳細介紹一下這些命令。
歡迎關注微信公眾號：萬貓學社，每週一分享Java技術乾貨。
### 釋出訂閱相關命令
在Redis中，釋出訂閱相關命令有：
1. 釋出訊息
2. 訂閱頻道
3. 取消訂閱
4. 按照模式訂閱
5. 按照模式取消訂閱
6. 查詢訂閱資訊
#### 釋出訊息
釋出訊息的命令是`publish`，語法是：
```
publish 頻道名稱 訊息
```
比如，要向channel:one-more-study:demo頻道釋出一條訊息“I am One More Study.”，命令如下：
```
> publish channel:one-more-study:demo "I am One More Study."
(integer) 0
```
返回的結果是訂閱者的個數，上例中沒有訂閱者，所以返回結果為0。
#### 訂閱訊息
訂閱訊息的命令是`subscribe`，訂閱者可以訂閱一個或者多個頻道，語法是：
```
subscribe 頻道名稱 [頻道名稱 ...]
```
比如，訂閱一個channel:one-more-study:demo頻道，命令如下：
```
> nodes = new HashSet<>();
String[] hosts = hostAndPorts.split(";");
for (String hostport : hosts) {
String[] ipport = hostport.split(":");
String ip = ipport[0];
int port = Integer.parseInt(ipport[1]);
nodes.add(new HostAndPort(ip, port));
}
jedisCluster = new JedisCluster(nodes, 1000, poolConfig);
}
public JedisCluster getJedisCluster() {
return jedisCluster;
}
}
```
歡迎關注微信公眾號：萬貓學社，每週一分享Java技術乾貨。
#### 釋出者示例
```java
package onemore.study;
import redis.clients.jedis.JedisCluster;
/**
* 釋出者
*
* @author 萬貓學社
*/
public class Publisher implements Runnable {
private final String CHANNEL_NAME = "channel:one-more-study:demo";
private final String QUIT_COMMAND = "quit";
@Override
public void run() {
JedisCluster jedisCluster = Cluster.INSTANCE.getJedisCluster();
for (int i = 1; i <= 3; i++) {
String message = "第" + i + "訊息";
System.out.println(Thread.currentThread().getName() + " 釋出：" + message);
jedisCluster.publish(CHANNEL_NAME, message);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("------------------");
}
jedisCluster.publish(CHANNEL_NAME, QUIT_COMMAND);
}
}
```
#### 訂閱者示例
```java
package onemore.study;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPubSub;
/**
* 訂閱者
*
* @author 萬貓學社
*/
public class Subscriber implements Runnable {
private final String CHANNEL_NAME = "channel:one-more-study:demo";
private final String QUIT_COMMAND = "quit";
private final JedisPubSub jedisPubSub = new JedisPubSub() {
@Override
public void onMessage(String channel, String message) {
System.out.println(Thread.currentThread().getName() + " 接收：" + message);
if (QUIT_COMMAND.equals(message)) {
unsubscribe(CHANNEL_NAME);
}
}
};
@Override
public void run() {
JedisCluster jedisCluster = Cluster.INSTANCE.getJedisCluster();
jedisCluster.subscribe(jedisPubSub, CHANNEL_NAME);
}
}
```
歡迎關注微信公眾號：萬貓學社，每週一分享Java技術乾貨。
#### 綜合示例
```java
package onemore.study;
public class App {
public static void main(String[] args) throws InterruptedException {
//建立3個訂閱者
new Thread(new Subscriber()).start();
new Thread(new Subscriber()).start();
new Thread(new Subscriber()).start();
Thread.sleep(1000);
//建立釋出者
new Thread(new Publisher()).start();
}
}
```
執行結果如下：
```
Thread-6 釋出：第1訊息
Thread-0 接收：第1訊息
Thread-1 接收：第1訊息
Thread-2 接收：第1訊息
------------------
Thread-6 釋出：第2訊息
Thread-0 接收：第2訊息
Thread-1 接收：第2訊息
Thread-2 接收：第2訊息
------------------
Thread-6 釋出：第3訊息
Thread-0 接收：第3訊息
Thread-2 接收：第3訊息
Thread-1 接收：第3訊息
------------------
Thread-0 接收：quit
Thread-1 接收：quit
Thread-2 接收：quit
```
微信公眾號：萬貓學社
微信掃描二維碼
獲得更多Java技術乾貨