Redis定时任务，

迈不过友情╰ 2022-12-23 09:40 98阅读 0赞

**动态定时任务**  
一种是用DelayQueue,一种是用消息队列。

**一个重写了 Redis 的 Key 失效监听器：**

/** * 当redis 中的key过期时，触发一个事件。 * 我们可以算好需要执行的时间间隔作为key失效时间，这样就可以保证到点执行逻辑了。 */
    public class RedisEventMessageListener extends KeyExpirationEventMessageListener { 
    
        /** * Instantiates a new Redis event message listener. * * @param listenerContainer the listener container */
        public RedisEventMessageListener(RedisMessageListenerContainer listenerContainer) { 
            super(listenerContainer);
        }
    
    
        @Override
        protected void doHandleMessage(Message message) { 
            String key = message.toString();
            // 这个就是过期的key ，过期后，也就是事件触发后对应的value是拿不到的。
            // 这里实现业务逻辑，如果是服务器集群的话需要使用分布式锁进行抢占执行。
            System.out.println("key = " + key);
            System.out.println("end = " + LocalDateTime.now());
        }
    }

一个监听器的配置：

/** * Redis 消息监听器容器. * * @param redisConnectionFactory the redis connection factory * @return the redis message listener container */
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory redisConnectionFactory) { 
        RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
        redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
        return redisMessageListenerContainer;
    }
    
    
    /** * Redis Key失效监听器注册为Bean. * * @param redisMessageListenerContainer the redis message listener container * @return the redis event message listener */
    @Bean
    public RedisEventMessageListener redisEventMessageListener(RedisMessageListenerContainer redisMessageListenerContainer){ 
        return new RedisEventMessageListener(redisMessageListenerContainer);
    }

**一个执行测试：**

@Test
    public void redisJobTest() { 
        // 调用 redisTemplate 对象设置一个10s 后过期的键，不出意外 10s 后键过期后会触发事件打印结果
        redisTemplate.boundValueOps("job").set("10s",10, TimeUnit.SECONDS);
        System.out.println("begin = " + LocalDateTime.now());
        try { 
            // 测试需要休眠才能看到结果
            Thread.sleep(20000);
        } catch (InterruptedException e) { 
            e.printStackTrace();
        }
        // ---------测试结果---------
        // begin = 2020-11-18T00:19:09.272
        // key = job
        // end = 2020-11-18T00:19:19.369
    }

参考链接 ：  
Redis也能搞定时任务，  
https://mp.weixin.qq.com/s/fzxwQ3fZH1JdQl1Vx9O4tA