您现在的位置是:首页 > 文章详情

超简单使用redisson延迟队列做定时任务

日期:2020-02-17点击:550

前言:啰嗦的就不写了,就是传一个多久之后执行,然后到点就执行的任务调度,我之前写过一次基于quartz的定时任务,前端和分布式还需要完善 https://my.oschina.net/wangnian/blog/758054 ,这个直接是基于时间的,其实多久之后和啥时候执行都一会事。

今天是我疫情复工的第一天上班,有很多小伙伴都已经复工了,戴了半天的口罩,很难受,准备下班之后把耳戴式改造成头戴式。

这个没有啥理论知识,就是对于redisson的delayedQueue延迟队列的封装,接下来直接粘贴代码,有需要的直接粘贴过去去,没需要的可以看看我的代码指指毛病

1.导入redisson包

注意,如果是Springboot的项目强制使用,别单独引入,再自己配置config

<dependency>  <groupId>org.redisson</groupId>  <artifactId>redisson-spring-boot-starter</artifactId>  <version>3.10.5</version> </dependency>

2.配置SpringBootRedis标准配置

spring.redis.host=192.168.1.100 spring.redis.port=6379

3.唯一一个封装的工具类

package com.test.redis.demo; import org.redisson.api.RBlockingQueue; import org.redisson.api.RDelayedQueue; import org.redisson.api.RedissonClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.concurrent.TimeUnit; @Service public class RedisDelayedQueue { /** * 任务回调监听 * * @param <T> */ public abstract static class TaskEventListener<T> { /** * 执行方法 * * @param t */ public abstract void invoke(T t); } @Autowired RedissonClient redissonClient; /** * 添加队列 * * @param t DTO传输类 * @param delay 时间数量 * @param timeUnit 时间单位 * @param <T> 泛型 */ public <T> void addQueue(T t, long delay, TimeUnit timeUnit) { RBlockingQueue<T> blockingFairQueue = redissonClient.getBlockingQueue(t.getClass().getName()); RDelayedQueue<T> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue); delayedQueue.offer(t, delay, timeUnit); delayedQueue.destroy(); } /** * 获取队列 * * @param zClass DTO泛型 * @param taskEventListener 任务回调监听 * @param <T> 泛型 * @return */ public <T> void getQueue(Class zClass, TaskEventListener taskEventListener) { RBlockingQueue<T> blockingFairQueue = redissonClient.getBlockingQueue(zClass.getName()); //由于此线程需要常驻,可以新建线程,不用交给线程池管理 ((Runnable) () -> { while (true) { try { T t = blockingFairQueue.take(); taskEventListener.invoke(t); } catch (InterruptedException e) { e.printStackTrace(); } } }).run(); } }

4.运行并测试

 @Override public void run(String... args) throws Exception { //添加需要延迟的DTO TaskBodyDTO taskBody = new TaskBodyDTO(); taskBody.setBody("测试DTO实体类的BODY,3秒之后执行"); taskBody.setName("测试DTO实体类的姓名,3秒之后执行"); //添加队列3秒之后执行 redisDelayedQueue.addQueue(taskBody, 3, TimeUnit.SECONDS); taskBody.setBody("测试DTO实体类的BODY,10秒之后执行"); taskBody.setName("测试DTO实体类的姓名,10秒之后执行"); //添加队列10秒之后执行 redisDelayedQueue.addQueue(taskBody, 10, TimeUnit.SECONDS); taskBody.setBody("测试DTO实体类的BODY,20秒之后执行"); taskBody.setName("测试DTO实体类的姓名,20秒之后执行"); //添加队列20秒之后执行 redisDelayedQueue.addQueue(taskBody, 20, TimeUnit.SECONDS); //监听延迟队列 RedisDelayedQueue.TaskEventListener<TaskBodyDTO> taskEventListener = new RedisDelayedQueue.TaskEventListener<TaskBodyDTO>() { @Override public void invoke(TaskBodyDTO taskBodyDTO) { //这里调用你延迟之后的代码 logger.info("执行...." + taskBodyDTO.getBody() + "===" + taskBodyDTO.getName()); } }; redisDelayedQueue.getQueue(TaskBodyDTO.class, taskEventListener); }

打印的值

2020-02-17 13:45:08.371  INFO 14700 --- [           main] com.test.redis.demo.DemoApplication      : 执行....测试DTO实体类的BODY,3秒之后执行===测试DTO实体类的姓名,3秒之后执行 2020-02-17 13:45:15.467  INFO 14700 --- [           main] com.test.redis.demo.DemoApplication      : 执行....测试DTO实体类的BODY,10秒之后执行===测试DTO实体类的姓名,10秒之后执行 2020-02-17 13:45:25.463  INFO 14700 --- [           main] com.test.redis.demo.DemoApplication      : 执行....测试DTO实体类的BODY,20秒之后执行===测试DTO实体类的姓名,20秒之后执行

 

结束:

使用是不是很简单,我这里是通过DTO的名字来区分队列名的,所以每一个定时任务的DTO都不要相同。

 

大家对于定时任务有其他好用的方式,或者开源的好项目,欢迎下方留言评论,我将在评论区选出100位中奖用户送出iPhone5.

哎呀,不对 我没有粉丝,等我粉丝到10000了再选中奖用户吧,哈哈

 

原文链接:https://my.oschina.net/wangnian/blog/3167316
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章