先给redis开启key失效监听模式,在客户端中执行:
config set notify-keyspace-events Ex
配置监听器
@Slf4j
@Service
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
/**
* Creates new {@link MessageListener} for {@code __keyevent@*__:expired} messages.
*
* @param listenerContainer must not be {@literal null}.
*/
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
super(listenerContainer);
}
@Override
public void onMessage(Message message, byte[] pattern) {
if (StringUtils.startsWith(message.toString(), RedisKeyCommon.PLATFORM_ORDER_EXPIRATION)) {
}
super.onMessage(message, pattern);
}
}
将监听器注入到spring容器中
@Configuration
public class RedisListenerConfiguration {
@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory redisConnectionFactory) {
RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();
listenerContainer.setConnectionFactory(redisConnectionFactory);
return listenerContainer;
}
@Bean
public KeyExpirationEventMessageListener keyExpirationEventMessageListener(RedisMessageListenerContainer redisMessageListenerContainer) {
return new RedisKeyExpirationListener(redisMessageListenerContainer);
}
}