我們使用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:redis 的發布/訂閱，主要就是利用兩個指令publish/subscribe; 在SpringBoot 中使用發布訂閱模式比較簡單，借助RedisTemplate 可以很方便的實作
@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來實作消費邏輯
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;
}
});
}#寫一個簡單的測試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";
}
}我們先創建了兩個消費者，然後發送訊息時，兩個都收到；再新增一個消費者，發送訊息時，三個都能收到
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發布訂閱方式實現簡易的訊息系統的詳細內容。更多資訊請關注PHP中文網其他相關文章！
