怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡(jiǎn)易的消息系統(tǒng)

這篇文章主要講解了“怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡(jiǎn)易的消息系統(tǒng)”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來(lái)研究和學(xué)習(xí)“怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡(jiǎn)易的消息系統(tǒng)”吧！

公司主營(yíng)業(yè)務(wù)：成都做網(wǎng)站、網(wǎng)站建設(shè)、移動(dòng)網(wǎng)站開(kāi)發(fā)等業(yè)務(wù)。幫助企業(yè)客戶真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競(jìng)爭(zhēng)能力。創(chuàng)新互聯(lián)公司是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開(kāi)放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對(duì)我們的高要求，感謝他們從不同領(lǐng)域給我們帶來(lái)的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶帶來(lái)驚喜。創(chuàng)新互聯(lián)公司推出安州免費(fèi)做網(wǎng)站回饋大家。

I. 基本使用

1. 配置

我們使用 SpringBoot 2.2.1.RELEASE來(lái)搭建項(xiàng)目環(huán)境，直接在pom.xml中添加 redis 依賴

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

如果我們的 redis 是默認(rèn)配置，則可以不額外添加任何配置；也可以直接在application.yml配置中，如下

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

2. 使用姿勢(shì)

redis 的發(fā)布/訂閱，主要就是利用兩個(gè)命令publish/subscribe; 在 SpringBoot 中使用發(fā)布訂閱模式比較簡(jiǎn)單，借助 RedisTemplate 可以很方便的實(shí)現(xiàn)

a. 消息發(fā)布

@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來(lái)實(shí)現(xiàn)消費(fèi)邏輯

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. 測(cè)試 case

寫一個(gè)簡(jiǎn)單的測(cè)試 case，來(lái)驗(yàn)證一下上面的發(fā)布訂閱，順帶理解一下這個(gè)MessageListener的使用姿勢(shì)；我們創(chuàng)建一個(gè)簡(jiǎn)單的 WEB 工程，提供兩個(gè) rest 接口

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

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

    // 新增消費(fèi)者
    @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";
    }
}

我們先創(chuàng)建了兩個(gè)消費(fèi)者，然后發(fā)送消息時(shí)，兩個(gè)都收到；再新增一個(gè)消費(fèi)者，發(fā)送消息時(shí)，三個(gè)都能收到

3. 使用說(shuō)明與應(yīng)用場(chǎng)景

redis 的發(fā)布訂閱，只適用于比較簡(jiǎn)單的場(chǎng)景，從上面的使用說(shuō)明也能看出，它就是一個(gè)簡(jiǎn)單的發(fā)布訂閱模型，支持 1 對(duì) N，而且發(fā)送的消息，只有在線的消費(fèi)者才能 get 到（至于不在線的，那就只能說(shuō)遺憾了）而且對(duì)于 redis 而言，消息推出去之后就完事了，至于消費(fèi)者能不能正常消費(fèi)，那就不 care 了

劃重點(diǎn)：

只有在線的消費(fèi)者能接收到消息
對(duì)于消費(fèi)者一個(gè)消息只能拿到一次

接下來(lái)的問(wèn)題就來(lái)了，什么樣的場(chǎng)景下可以使用 redis 的發(fā)布訂閱呢？

基于內(nèi)存的緩存失效

利用 reids + 內(nèi)存做二級(jí)緩存，可以說(shuō)是比較常見(jiàn)的方式了，借助基于內(nèi)存的緩存，可以有效的提高系統(tǒng)的負(fù)載，但是問(wèn)題也很明顯，內(nèi)存中緩存數(shù)據(jù)失效是個(gè)問(wèn)題，特別是當(dāng)一個(gè)應(yīng)用部署多臺(tái)服務(wù)器時(shí)，如果我希望同時(shí)失效所有服務(wù)器的某個(gè)內(nèi)存緩存，使用 redis 的發(fā)布/訂閱就是一個(gè)比較好的選擇

SpringCloud Config 配置刷新

使用 SpringCloud Config 做配置中心的小伙伴可能會(huì)經(jīng)常遇到這個(gè)問(wèn)題，配置修改之后的動(dòng)態(tài)刷新是個(gè)問(wèn)題（當(dāng)然官方是支持通過(guò) mq 走 bus 總線來(lái)同步，也可以通過(guò) spring boot admin 來(lái)強(qiáng)刷）

借助 redis 發(fā)布/訂閱，實(shí)現(xiàn)配置動(dòng)態(tài)刷新也是一個(gè)不錯(cuò)的備選方案（后面給出一個(gè)具體的實(shí)現(xiàn) demo，如有興趣請(qǐng)持續(xù)關(guān)注一灰灰 Blog）

redis key 失效訂閱

我們?cè)谑褂?redis 做緩存時(shí)，通常會(huì)設(shè)置一個(gè)過(guò)期時(shí)間，redis 提供了一個(gè)過(guò)期的事件，當(dāng)然默認(rèn)是不開(kāi)啟的；我們也是可以通過(guò) subscribe 來(lái)訂閱緩存失效的事件

修改配置，開(kāi)啟 key 失效事件

notify-keyspace-events Ex

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

subscribe __keyevent@0__:expired

感謝各位的閱讀，以上就是“怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡(jiǎn)易的消息系統(tǒng)”的內(nèi)容了，經(jīng)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡(jiǎn)易的消息系統(tǒng)這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！

分享標(biāo)題：怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡(jiǎn)易的消息系統(tǒng)
文章分享：http://muchs.cn/article28/jpgjcp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開(kāi)發(fā)、網(wǎng)站策劃、自適應(yīng)網(wǎng)站、企業(yè)建站、標(biāo)簽優(yōu)化、App設(shè)計(jì)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容