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

這篇文章主要講解了“怎么用redis發布訂閱方式實現簡易的消息系統”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“怎么用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發布訂閱方式實現簡易的消息系統”的內容了，經過本文的學習后，相信大家對怎么用redis發布訂閱方式實現簡易的消息系統這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！