# 業(yè)務(wù)場景
我們以訂單功能為例說明下:生成訂單后一段時間不支付訂單會自動關(guān)閉探膊。最簡單的想法是設(shè)置定時任務(wù)輪詢,但是每個訂單的創(chuàng)建時間不一樣待榔,定時任務(wù)的規(guī)則無法設(shè)定逞壁,如果將定時任務(wù)執(zhí)行的間隔設(shè)置的過短,太影響效率锐锣。還有一種想法腌闯,在用戶進(jìn)入訂單界面的時候,判斷時間執(zhí)行相關(guān)操作雕憔。方式可能有很多姿骏,在這里介紹一種監(jiān)聽 Redis 鍵值對過期時間來實(shí)現(xiàn)訂單自動關(guān)閉。整理了一份Java面試寶典完整版PDF
# 實(shí)現(xiàn)思路
在生成訂單時斤彼,向 Redis 中增加一個 KV 鍵值對分瘦,K 為訂單號蘸泻,保證通過 K 能定位到數(shù)據(jù)庫中的某個訂單即可,V 可為任意值嘲玫。假設(shè)悦施,生成訂單時向 Redis 中存放 K 為訂單號,V 也為訂單號的鍵值對去团,并設(shè)置過期時間為 30 分鐘抡诞,如果該鍵值對在 30 分鐘過期后能夠發(fā)送給程序一個通知,或者執(zhí)行一個方法渗勘,那么即可解決訂單關(guān)閉問題沐绒。實(shí)現(xiàn):通過監(jiān)聽 Redis 提供的過期隊(duì)列來實(shí)現(xiàn),監(jiān)聽過期隊(duì)列后旺坠,如果 Redis 中某一個 KV 鍵值對過期了乔遮,那么將向監(jiān)聽者發(fā)送消息,監(jiān)聽者可以獲取到該鍵值對的 K取刃,注意蹋肮,是獲取不到 V 的,因?yàn)橐呀?jīng)過期了璧疗,這就是上面所提到的坯辩,為什么要保證能通過 K 來定位到訂單,而 V 為任意值即可崩侠。拿到 K 后漆魔,通過 K 定位訂單,并判斷其狀態(tài)却音,如果是未支付改抡,更新為關(guān)閉,或者取消狀態(tài)即可系瓢。
# 開啟 Redis key 過期提醒
修改 redis 相關(guān)事件配置阿纤。找到 redis 配置文件 redis.conf,查看 notify-keyspace-events 配置項(xiàng)夷陋,如果沒有欠拾,添加 notify-keyspace-events Ex,如果有值骗绕,則追加 Ex藐窄,相關(guān)參數(shù)說明如下:
K:keyspace 事件,事件以 keyspace@ 為前綴進(jìn)行發(fā)布
E:keyevent 事件酬土,事件以 keyevent@ 為前綴進(jìn)行發(fā)布
g:一般性的枷邪,非特定類型的命令,比如del,expire东揣,rename等
$:字符串特定命令
l:列表特定命令
s:集合特定命令
h:哈希特定命令
z:有序集合特定命令
x:過期事件践惑,當(dāng)某個鍵過期并刪除時會產(chǎn)生該事件
e:驅(qū)逐事件,當(dāng)某個鍵因 maxmemore 策略而被刪除時嘶卧,產(chǎn)生該事件
A:g$lshzxe的別名尔觉,因此”AKE”意味著所有事件
# 引入依賴
在 pom.xml 中添加 org.springframework.boot:spring-boot-starter-data-redis 依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
# 相關(guān)配置
定義配置 RedisListenerConfig 實(shí)現(xiàn)監(jiān)聽 Redis key 過期時間
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
@Configuration
public class RedisListenerConfig {
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
return container;
}
}
定義監(jiān)聽器 RedisKeyExpirationListener,實(shí)現(xiàn)KeyExpirationEventMessageListener 接口芥吟,查看源碼發(fā)現(xiàn)侦铜,該接口監(jiān)聽所有 db 的過期事件 keyevent@*:expired"整理了一份Java面試寶典完整版PDF
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;
/**
* 監(jiān)聽所有db的過期事件__keyevent@*__:expired"
*/
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}
/**
* 針對 redis 數(shù)據(jù)失效事件,進(jìn)行數(shù)據(jù)處理
* @param message
* @param pattern
*/
@Override
public void onMessage(Message message, byte[] pattern) {
// 獲取到失效的 key钟鸵,進(jìn)行取消訂單業(yè)務(wù)處理
String expiredKey = message.toString();
System.out.println(expiredKey);
}
}