您好,登錄后才能下訂單哦!
這篇文章主要講解了“怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡易的消息系統(tǒng)”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡易的消息系統(tǒng)”吧!
我們使用 SpringBoot 2.2.1.RELEASE
來搭建項(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:
redis 的發(fā)布/訂閱,主要就是利用兩個(gè)命令publish/subscribe
; 在 SpringBoot 中使用發(fā)布訂閱模式比較簡單,借助 RedisTemplate 可以很方便的實(shí)現(xiàn)
@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; } }); } }
消息訂閱這里,需要注意我們借助org.springframework.data.redis.connection.MessageListener
來實(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; } }); }
寫一個(gè)簡單的測試 case,來驗(yàn)證一下上面的發(fā)布訂閱,順帶理解一下這個(gè)MessageListener
的使用姿勢;我們創(chuàng)建一個(gè)簡單的 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è)都能收到
redis 的發(fā)布訂閱,只適用于比較簡單的場景,從上面的使用說明也能看出,它就是一個(gè)簡單的發(fā)布訂閱模型,支持 1 對 N,而且發(fā)送的消息,只有在線的消費(fèi)者才能 get 到(至于不在線的,那就只能說遺憾了)而且對于 redis 而言,消息推出去之后就完事了,至于消費(fèi)者能不能正常消費(fèi),那就不 care 了
劃重點(diǎn):
只有在線的消費(fèi)者能接收到消息
對于消費(fèi)者一個(gè)消息只能拿到一次
接下來的問題就來了,什么樣的場景下可以使用 redis 的發(fā)布訂閱呢?
基于內(nèi)存的緩存失效
利用 reids + 內(nèi)存做二級緩存,可以說是比較常見的方式了,借助基于內(nèi)存的緩存,可以有效的提高系統(tǒng)的負(fù)載,但是問題也很明顯,內(nèi)存中緩存數(shù)據(jù)失效是個(gè)問題,特別是當(dāng)一個(gè)應(yīng)用部署多臺服務(wù)器時(shí),如果我希望同時(shí)失效所有服務(wù)器的某個(gè)內(nèi)存緩存,使用 redis 的發(fā)布/訂閱就是一個(gè)比較好的選擇
SpringCloud Config 配置刷新
使用 SpringCloud Config 做配置中心的小伙伴可能會經(jīng)常遇到這個(gè)問題,配置修改之后的動(dòng)態(tài)刷新是個(gè)問題(當(dāng)然官方是支持通過 mq 走 bus 總線來同步,也可以通過 spring boot admin 來強(qiáng)刷)
借助 redis 發(fā)布/訂閱,實(shí)現(xiàn)配置動(dòng)態(tài)刷新也是一個(gè)不錯(cuò)的備選方案(后面給出一個(gè)具體的實(shí)現(xiàn) demo,如有興趣請持續(xù)關(guān)注一灰灰 Blog)
redis key 失效訂閱
我們在使用 redis 做緩存時(shí),通常會設(shè)置一個(gè)過期時(shí)間,redis 提供了一個(gè)過期的事件,當(dāng)然默認(rèn)是不開啟的;我們也是可以通過 subscribe 來訂閱緩存失效的事件
修改配置,開啟 key 失效事件
notify-keyspace-events Ex
重啟 redis 之后,訂閱失效事件即可
subscribe __keyevent@0__:expired
感謝各位的閱讀,以上就是“怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡易的消息系統(tǒng)”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對怎么用redis發(fā)布訂閱方式實(shí)現(xiàn)簡易的消息系統(tǒng)這一問題有了更深刻的體會,具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云,小編將為大家推送更多相關(guān)知識點(diǎn)的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。