1、redis配置文件redis.windows.conf設(shè)置
找到notify-keyspace-events配置，初始化為""，改為Ex凹蜈。這樣可以監(jiān)聽(tīng)key值過(guò)期的事件。
2忍啸、spring boot配置文件
redis配置
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.jedis.pool.max-active= 100
spring.redis.jedis.pool.max-idle=10
spring.redis.jedis.pool.min-idle=10
spring.redis.jedis.pool.max-wait=100
spring.redis.timeout=500
spring.redis.database=0
spring.redis.topic=keyevent@0:expired
3仰坦、代碼配置
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
/**
* 生成key的策略
* @return
*/
@Bean
public KeyGenerator keyGenerator() {
return new KeyGenerator() {
@Override
public Object generate(Object target, Method method, Object... params) {
StringBuilder sb = new StringBuilder();
sb.append(target.getClass().getName());
sb.append(method.getName());
for (Object obj : params) {
sb.append(obj.toString());
}
return sb.toString();
}
};
}
/**
* 采用RedisCacheManager作為緩存管理器
* @param connectionFactory
*/
@Bean
public CacheManager cacheManager(RedisConnectionFactory connectionFactory) {
RedisCacheManager redisCacheManager = RedisCacheManager.create(connectionFactory);
return redisCacheManager;
}
/**
* RedisTemplate配置
*/
@Bean
public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
StringRedisTemplate template = new StringRedisTemplate(factory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
template.setValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
//==================================================監(jiān)聽(tīng)事件配置======================================================//
/**
* redis消息監(jiān)聽(tīng)器容器
* 可以添加多個(gè)監(jiān)聽(tīng)不同話題的redis監(jiān)聽(tīng)器，只需要把消息監(jiān)聽(tīng)器和相應(yīng)的消息訂閱處理器綁定计雌，該消息監(jiān)聽(tīng)器
* 通過(guò)反射技術(shù)調(diào)用消息訂閱處理器的相關(guān)方法進(jìn)行一些業(yè)務(wù)處理
* @param connectionFactory
* @param listenerAdapter
* @return
*/
@Bean //相當(dāng)于xml中的bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter1,MessageListenerAdapter listenerAdapter2) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
//訂閱了一個(gè)叫chat 的通道
container.addMessageListener(listenerAdapter1, new PatternTopic("chat"));
//監(jiān)聽(tīng)key值失效的狀態(tài)
container.addMessageListener(listenerAdapter2, new PatternTopic("__keyevent@0__:expired"));
//這個(gè)container 可以添加多個(gè) messageListener
return container;
}
/**
* 消息監(jiān)聽(tīng)器適配器悄晃，綁定消息處理器，利用反射技術(shù)調(diào)用消息處理器的業(yè)務(wù)方法
* @param receiver
* @return
*/
@Bean
MessageListenerAdapter listenerAdapter1(MessageReceiver receiver) {
//這個(gè)地方 是給messageListenerAdapter 傳入一個(gè)消息接受的處理器凿滤，利用反射的方法調(diào)用“receiveMessage”
//也有好幾個(gè)重載方法妈橄，這邊默認(rèn)調(diào)用處理器的方法 叫handleMessage 可以自己到源碼里面看
return new MessageListenerAdapter(receiver, "receiveMessage");
}
@Bean
MessageListenerAdapter listenerAdapter2(MessageReceiver receiver) {
return new MessageListenerAdapter(receiver, "receiveMessage2");
}
/**redis 讀取內(nèi)容的template */
/**
* StringRedisTemplate繼承了RedisTemplate方法，只能配置一個(gè)翁脆，我目前留下的是RedisTemplate
*/
// @Bean
// StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
// return new StringRedisTemplate(connectionFactory);
// }
}
4眷蚓、消息處理方法
@Component
public class MessageReceiver {
/*接收定時(shí)器消息的方法/
public void receiveMessage(String message){
System.out.println("收到一條消息1："+message);
}
/**接收key值監(jiān)聽(tīng)消息的方法*/
public void receiveMessage2(String message){
System.out.println("收到一條消息2："+message);
}
}
5、定時(shí)任務(wù)反番，發(fā)送消息
@Component
public class TestTimer {
@Autowired
StringRedisTemplate stringRedisTemplate;
/**
* 定時(shí)任務(wù)測(cè)試
*/
//@Scheduled(cron = "0/1 * * * * ?")
private void test() {
System.out.println("執(zhí)行定時(shí)任務(wù)的時(shí)間是："+new Date());
}
/**
* 監(jiān)聽(tīng)事件定時(shí)任務(wù)
*/
@Scheduled(cron = "0/5 * * * * ?")
private void sendMessage() {
System.out.println("執(zhí)行定時(shí)任務(wù)的時(shí)間是："+new Date());
Date d = new Date();
stringRedisTemplate.convertAndSend("chat", d.toString());
}
}
6沙热、自行設(shè)置一個(gè)key值叉钥，就可以看到key失效時(shí)出發(fā)的處理方法了。key值監(jiān)聽(tīng)可以用來(lái)作為訂單過(guò)期的處理方法篙贸，避免了定時(shí)任務(wù)投队，提高準(zhǔn)確性。
