Redis 過期監聽場景
業務中有類似等待一定時間之后執行某種行為的需求 , 比如 30 分鐘之后關閉訂單 . 網上有很多使用 Redis 過期監聽的 Demo
redis配置
把notify-keyspace-events Ex 這一行的注釋打開
項目demo工程
項目結構如下圖
maven依賴
?xml version="1.0" encoding="UTF-8"?>
project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
parent>
artifactId>kim-redis/artifactId>
groupId>com.kim/groupId>
version>1.0.0/version>
/parent>
modelVersion>4.0.0/modelVersion>
artifactId>kim-redis-expiration-notice/artifactId>
dependencies>
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.projectlombok/groupId>
artifactId>lombok/artifactId>
/dependency>
dependency>
groupId>org.apache.commons/groupId>
artifactId>commons-pool2/artifactId>
/dependency>
/dependencies>
/project>
配置文件
server:
port: 20103
spring:
redis:
#數據庫索引
database: 0
host: 127.0.0.1
port: 6379
password: 123456
lettuce:
pool:
#最大連接數
max-active: 8
#最大阻塞等待時間(負數表示沒限制)
max-wait: -1
#最大空閑
max-idle: 8
#最小空閑
min-idle: 0
#連接超時時間
timeout: 10000
啟動類
/**
* @Project: kim-redis
* @PackageName: com.kim.redis.expiration.notice
* @FileName: NoticeApplication.java
* @Description: The NoticeApplication is...
* @Author: kimwu
* @Time: 2020-12-19 14:01:56
*/
@SpringBootApplication
public class NoticeApplication {
public static void main(String[] args) {
SpringApplication.run(NoticeApplication.class, args);
}
}
配置類
@Configuration
public class RedisTimeoutConfiguration {
@Autowired
private RedisConnectionFactory redisConnectionFactory;
@Bean
public RedisMessageListenerContainer redisMessageListenerContainer() {
RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
return redisMessageListenerContainer;
}
@Bean
public KeyExpiredListener keyExpiredListener() {
return new KeyExpiredListener(this.redisMessageListenerContainer());
}
}
監聽類
@Slf4j
public class KeyExpiredListener extends KeyExpirationEventMessageListener {
public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}
@Override
public void onMessage(Message message, byte[] pattern) {
String channel = new String(message.getChannel(), StandardCharsets.UTF_8);
//過期的key
String key = new String(message.getBody(), StandardCharsets.UTF_8);
log.info("redis key 過期：pattern={},channel={},key={}", new String(pattern), channel, key);
}
}
異常情況測試
當key過期時，項目宕機了
①寫入redis的key
②手動關停服務，等待redis的key過期
③確認redis的key過期后，重啟服務。服務不會收到通知
當key過期時，redis服務宕機了
①寫入redis的key
②關停redis服務，等待redis的key過期
③啟動redis服務，發現redis的過期key已經不存在了，服務沒有收到通知
結論
redis的鍵過期本身不可靠，并不像rabbitmq一樣保證了可靠性。
當服務本身宕機或者redis宕機時，將無法保證過期的key能夠被消費。
當使用場景對數據完整性不那么精確時，可以使用redis的鍵過期策略。否則不太建議使用redis的鍵過期策略。
到此這篇關于使用redis實現延遲通知功能(Redis過期鍵通知)的文章就介紹到這了,更多相關Redis過期鍵通知內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- redis學習之RDB、AOF與復制時對過期鍵的處理教程
- 大家都應該知道的Redis過期鍵與過期策略
- Redis 2.8-4.0過期鍵優化過程全紀錄
- redis鍵空間通知使用實現
- Redis開啟鍵空間通知實現超時通知的步驟詳解
