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));

        }

    }

第六步：驗證結果

啟動應用Spring Boot主類
通過curl或其他工具呼叫介面curl localhost:8080/publish?message=hello
觀察控制臺，可以看到列印了收到的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，分享外面看不到的干貨與思考！

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/288598.html

標籤：Java

上一篇：一個高性能、小而美的序列化工具！

下一篇：合肥某小公司面試題：Spring基礎