redis發布（pub）、訂閱（sub）模式

前言：redis提供了很多種功能或模式，可以運用在不同的場景下，今天記錄下redis中的發布、訂閱模式的基本使用

　　注redis安裝及主從搭建請參考我其他博文http://www.cnblogs.com/longjee/p/8652374.html，本文不再贅述

• redis中的發布訂閱由三部分組成。發布者（生產者）、通道（類似於topic）、訂閱者（消費者），具體結構如下圖：

               

 

• redis中實現發布訂閱

1. 首先我們打開兩個客戶端 A、B
2. A客戶端使用subscribe 命令訂閱通道test
3. 
4. 然后客戶端B使用publish 命令發送消息
5. 
6. 這個時候客戶端A能自動接收到消息
7. 
8. 至此，使用redis簡單的搭建一個發布訂閱服務就完成了。

• 使用Java基於redis實現發布訂閱

1. 首先我們新建一個maven的項目。然后建立三個屬於該項目的module: redis-pub、redis-sub、redis-common
2. 
3. 在redis-pubsub(下面簡稱父項目)的pom中添加jedis的依賴 ，本人使用2.9.0版本
4. 
5. redis-common是我寫的一個公共組件
6. 下面開始寫sub端（貼出部分為核心代碼）

7. package com.star4j.redissub.client;
   
   import com.star4j.rediscommon.helper.JedisConnectionHelper;
   import redis.clients.jedis.Jedis;
   import redis.clients.jedis.JedisPubSub;
   
   /**
    * @Author: WuYL
    * @Description: 實現訂閱功能
    * @Date: Create in 2018/3/29 15:21
    * @Modified By:
    */
   public abstract class SubClient extends JedisPubSub{
   
       private Jedis jedis = null;
   
       public SubClient(Jedis jedis){
           this.jedis = jedis;
       }
   
       protected SubClient(){
           jedis = JedisConnectionHelper.get();
       }
   
       /**
        * 訂閱一個通道 (必須實現該類才行)
        * @param channal
        */
       public final void sub(String channal){
           jedis.subscribe(this, channal);
       }
   
       /**
        * 有消息被推送過來時調用（子類實現）
        * @param channel
        * @param message
        */
       public abstract void message(String channel, String message);
   
       @Override
       public  void onMessage(String channel, String message) {
           this.message(channel, message);
       }
   
   }

    

8. pub端代碼（部分代碼）

9. package com.star4j.redispub.client;
   
   import com.star4j.rediscommon.helper.JedisConnectionHelper;
   import redis.clients.jedis.Jedis;
   
   /**
    * @Author: WuYL
    * @Description: 發布端實現
    * @Date: Create in 2018/3/29 15:41
    * @Modified By:
    */
   public class PubClient {
   
       /**
        * 發布消息
        * @param channel
        * @param message
        */
       public static void pub(String channel, String message){
           Jedis jedis = JedisConnectionHelper.get();
           jedis.publish(channel, message);
           JedisConnectionHelper.close(jedis);
       }
   }

    

10. 測試：使用postman進行測試。結果如下。
11. 

至此，使用Java搭建一個簡單的發布訂閱模式已經完成!

如有什么不對之處，敬請指教。

上面為關鍵部分代碼,完整代碼請到我的github：https://github.com/wylsource/redis-pubsub