怎麼用redis發布訂閱方式實現簡易的訊息系統

I. 基本上使用

1. 配置

我們使用SpringBoot 2.2.1.RELEASE來建立專案環境，直接在pom.xml中新增redis 依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

如果我們的redis 是預設配置，則可以不額外新增任何配置；也可以直接在application.yml配置中，如下

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password:

2. 使用姿勢

redis 的發布/訂閱，主要就是利用兩個指令publish/subscribe; 在SpringBoot 中使用發布訂閱模式比較簡單，借助RedisTemplate 可以很方便的實作

a. 訊息發布

@Service
public class PubSubBean {
    @Autowired
    private StringRedisTemplate redisTemplate;

    public void publish(String key, String value) {
        redisTemplate.execute(new RedisCallback<Object>() {
            @Override
            public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
                redisConnection.publish(key.getBytes(), value.getBytes());
                return null;
            }
        });
    }
}

b. 訂閱訊息

訊息訂閱這裡，需要注意我們藉助org.springframework.data.redis.connection. MessageListener來實作消費邏輯

public void subscribe(MessageListener messageListener, String key) {
    redisTemplate.execute(new RedisCallback<Object>() {
        @Override
        public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
            redisConnection.subscribe(messageListener, key.getBytes());
            return null;
        }
    });
}

c. 測試case

#寫一個簡單的測試case，來驗證上面的發布訂閱，順帶理解這個MessageListener的使用姿勢；我們創建一個簡單的WEB 工程，提供兩個rest 介面

@RestController
@RequestMapping(path = "rest")
public class DemoRest {
    @Autowired
    private PubSubBean pubSubBean;

    // 发布消息
    @GetMapping(path = "pub")
    public String pubTest(String key, String value) {
        pubSubBean.publish(key, value);
        return "over";
    }

    // 新增消费者
    @GetMapping(path = "sub")
    public String subscribe(String key, String uuid) {
        pubSubBean.subscribe(new MessageListener() {
            @Override
            public void onMessage(Message message, byte[] bytes) {
                System.out.println(uuid + " ==> msg:" + message);
            }
        }, key);
        return "over";
    }
}

我們先創建了兩個消費者，然後發送訊息時，兩個都收到；再新增一個消費者，發送訊息時，三個都能收到

3. 使用說明與應用程式場景

redis 的發布訂閱，只適用於比較簡單的場景，從上面的使用說明也能看出，它就是一個簡單的發布訂閱模型，支援1 對N，而且發送的訊息，只有在線的消費者才能get 到（至於不在線的，那就只能說遺憾了）而且對於redis 而言，消息推出去之後就完事了，至於消費者能不能正常消費，那就不care 了

劃重點：

• 只有在線的消費者能接收到訊息

• 對於消費者一個訊息只能拿到一次

#接下來的問題就來了，什麼​​樣的場景下可以使用redis 的發布訂閱呢？

基於記憶體的快取失效

利用reids 記憶體做二級緩存，可以說是比較常見的方式了，借助基於記憶體的緩存，可以有效的提高系統的負載，但是問題也很明顯，記憶體中快取資料失效是個問題，特別是當一個應用程式部署多台伺服器時，如果我希望同時失效所有伺服器的某個記憶體緩存，使用redis 的發布/訂閱就是一個比較好的選擇

SpringCloud Config 配置刷新

使用SpringCloud Config 做配置中心的小夥伴可能會經常遇到這個問題，配置修改之後的動態刷新是個問題（當然官方是支援透過mq 走bus 總線來同步，也可以透過spring boot admin 來強刷）

借助redis 發布/訂閱，實現配置動態刷新也是一個不錯的備選方案（後面給出一個具體的實作demo，如有興趣請持續關註一灰灰Blog）

redis key 失效訂閱

我們在使用redis 做快取時，通常會設定一個過期時間，redis 提供了一個過期的事件，當然預設是不開啟的；我們也是可以透過subscribe 來訂閱快取失效的事件

修改配置，開啟key 失效事件

notify-keyspace-events Ex

重啟redis 之後，訂閱失效事件即可

subscribe __keyevent@0__:expired

以上是怎麼用redis發布訂閱方式實現簡易的訊息系統的詳細內容。更多資訊請關注PHP中文網其他相關文章！