Spring Boot 2.x基礎教程：使用Redis的發佈訂閱功能

經過前面一篇集中式緩存的使用教程，咱們已經瞭解了Redis的核心功能：做爲K、V存儲的高性能緩存。

接下來咱們會分幾篇來繼續講講Redis的一些其餘強大用法！若是你對此感興趣，必定要關注收藏我哦！

發佈訂閱模式

若是你看過以前我寫的關於MQ的相關文章，那麼對於發佈訂閱功能應該不會陌生。若是沒看過，那也沒關係，這裏先作一個簡單介紹，已經瞭解的能夠跳過直接看下一節內容。

什麼是發佈訂閱模式？

在發佈訂閱模式中有個重要的角色，一個是發佈者Publisher，另外一個訂閱者Subscriber。本質上來講，發佈訂閱模式就是一種生產者消費者模式，Publisher負責生產消息，而Subscriber則負責消費它所訂閱的消息。這種模式被普遍的應用於軟硬件的系統設計中。好比：配置中心的一個配置修改以後，就是經過發佈訂閱的方式傳遞給訂閱這個配置的訂閱者來實現自動刷新的。

不就是觀察者模式嗎？

看到這裏，學過設計模式的同窗可能很容易將它與設計模式中的觀察者模式聯繫起來，你會以爲發佈訂閱模式中的兩個概念與觀察者模式中的兩個概念彷佛乾的是同樣的事情？因此：Publisher就是觀察者模式中的Subject？Subscriber就是觀察者模式中的Observer？

重要區別在哪裏？

從這兩種模式的角色任務來講確實是很是類似的，但從實現架構上來講有一個核心不一樣點！

咱們經過下面的圖示來理解，就很清晰了：

能夠看到這裏有一個很是大的區別就是：發佈訂閱模式在兩個角色中間是一箇中間角色來過渡的，發佈者並不直接與訂閱者產生交互。

回想一下生產者消費者模式，這個中間過渡區域對應的就是是緩衝區。由於這個緩衝區的存在，發佈者與訂閱者的工做就能夠實現更大程度的解耦。發佈者不會由於訂閱者處理速度慢，而影響本身的發佈任務，它只須要快速生產便可。而訂閱者也不用太擔憂一時來不及處理，由於有緩衝區在，能夠一點點排隊來完成（也就是咱們常說的「削峯填谷」效果）。

而咱們所熟知的RabbitMQ、Kafka、RocketMQ這些中間件的本質其實就是實現發佈訂閱模式中的這個中間緩衝區。而Redis也提供了簡單的發佈訂閱實現，當咱們有一些簡單需求的時候，也是能夠一用的！若是你已經理解了這個概念，那麼就進入下一節，一塊兒來作個例子吧！

動手試一試

下面的動手任務，咱們將在Spring Boot應用中，經過接口的方式實現一個消息發佈者的角色，而後再寫一個Service來實現消息的訂閱（把接口傳過來的消息內容打印處理）。

第一步：建立一個基礎的Spring Boot應用，若是還不會點這裏

第二步：pom.xml中加入必須的幾個依賴：

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

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

<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
</dependency>

第三步：建立一個接口，用來發送消息。

@SpringBootApplication
public class Chapter55Application {

    private static String CHANNEL = "didispace";

    public static void main(String[] args) {
        SpringApplication.run(Chapter55Application.class, args);
    }

    @RestController
    static class RedisController {

        private RedisTemplate<String, String> redisTemplate;

        public RedisController(RedisTemplate<String, String> redisTemplate) {
            this.redisTemplate = redisTemplate;
        }

        @GetMapping("/publish")
        public void publish(@RequestParam String message) {
            // 發送消息
            redisTemplate.convertAndSend(CHANNEL, message);
        }

    }

}

這裏爲了簡單實現，公用CHANNEL名稱字段，我都寫在了應用主類裏。

第四步：繼續應用主類裏實現消息訂閱，打接收到的消息打印處理

@Slf4j
    @Service
    static class MessageSubscriber {

        public MessageSubscriber(RedisTemplate redisTemplate) {
            RedisConnection redisConnection = redisTemplate.getConnectionFactory().getConnection();
            redisConnection.subscribe(new MessageListener() {
                @Override
                public void onMessage(Message message, byte[] bytes) {
                    // 收到消息的處理邏輯
                    log.info("Receive message : " + message);
                }
            }, CHANNEL.getBytes(StandardCharsets.UTF_8));

        }

    }

第六步：驗證結果

1. 啓動應用Spring Boot主類
2. 經過curl或其餘工具調用接口curl localhost:8080/publish?message=hello
3. 觀察控制檯，能夠看到打印了收到的message參數

2021-06-19 16:22:30.935  INFO 34351 --- [ioEventLoop-4-2] .c.Chapter55Application$MessageSubscribe : Receive message : hello

好了，今天的內容到這裏結束了。若是你對本系列教程《Spring Boot 2.x基礎教程》感興趣，能夠點擊直達！。學習過程當中如遇困難，建議加入Spring技術交流羣，參與交流與討論，更好的學習與進步！

代碼示例

本文的完整工程能夠查看下面倉庫中的chapter5-5目錄：

• Github：https://github.com/dyc87112/SpringBoot-Learning/
• Gitee：https://gitee.com/didispace/SpringBoot-Learning/

若是您以爲本文不錯，歡迎Star支持，您的關注是我堅持的動力！更多本系列免費教程連載「點擊進入彙總目錄」

歡迎關注個人公衆號：程序猿DD，分享其餘地方看不到的知識與思考