實(shí)際在我們開(kāi)發(fā)過(guò)程中，有一些業(yè)務(wù)場(chǎng)景需要能夠在一段時(shí)間之后能自動(dòng)變更數(shù)據(jù)狀態(tài)，如優(yōu)惠券，特價(jià)商品，購(gòu)物車(chē)等，這個(gè)時(shí)候如果實(shí)現(xiàn)基于redis，就可以使用下面的方案。

一，在系統(tǒng)添加配置類(lèi)

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 RedisExpirationConfig {@BeanRedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);return container;} }

二，添加對(duì)應(yīng)的業(yè)務(wù)實(shí)現(xiàn)監(jiān)聽(tīng)器

import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.connection.Message; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.listener.KeyExpirationEventMessageListener; import org.springframework.data.redis.listener.RedisMessageListenerContainer; import org.springframework.stereotype.Component;import java.io.File;/*** redis 消息過(guò)期異步通知監(jiān)聽(tīng)器** */ @Component public class RedisMessageListener extends KeyExpirationEventMessageListener {private static Logger logger = LoggerFactory.getLogger(RedisMessageListener.class);@Autowiredprivate RedisTemplate<String, String> redisTemplate;public RedisMessageListener(RedisMessageListenerContainer listenerContainer) {super(listenerContainer);}@Overridepublic void onMessage(Message message, byte[] pattern) {logger.info("收到 redis 過(guò)期異步通知：{}", message.toString());String redisKey = (String) redisTemplate.getValueSerializer().deserialize(message.getBody());logger.info("redisKey : {}", redisKey);//針對(duì)特定的key進(jìn)行處理if (redisKey.startsWith("rediskey")){try { //TODO}catch (Exception exp){logger.info("業(yè)務(wù)處理失敗：" + exp.getMessage());}}} }

三，針對(duì)業(yè)務(wù)實(shí)現(xiàn)對(duì)應(yīng)過(guò)期消息的處理

在TODO的標(biāo)識(shí)上面，針對(duì)不同業(yè)務(wù)設(shè)置的redis key，分成多個(gè)業(yè)務(wù)處理。建議key的設(shè)置使用 XXX:XXX:XXX 這種模式 eg：saas:file:key:業(yè)務(wù)參數(shù)，效果如圖所示：

采用上述構(gòu)建key的工具效果圖

上述方法若有錯(cuò)誤問(wèn)題，請(qǐng)給我留言一下。

總結(jié)

以上是生活随笔為你收集整理的redistemplate hash 过期时间_Redis开发 —— 过期消息通知实现（Springboot）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。