超简单使用redisson延迟队列做定时任务
前言:啰嗦的就不写了,就是传一个多久之后执行,然后到点就执行的任务调度,我之前写过一次基于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了再选中奖用户吧,哈哈
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
win10 风格的 OA 管理系统 skyeye 更新,新增笔记模块
OA管理系统新增笔记模块,以及其他内容的修复和新增 笔记模块 模拟有道笔记添加的的一款笔记功能,可能没有有道那么全,但是会慢慢加上的 功能 可以创建简单文本笔记和MD文本笔记 支持笔记分享 支持最近笔记的查看 提供笔记操作的两种视图 其他内容 售后模块:新增我填报的工单查询(新增),工单填报时省去市级别的必填限制(修复),手机端权限控制完善(修复) 手机端模块:售后工单手机端新增工单管理、申领单管理、客户管理、配件管理等(新增) 架构升级:获取token方式修改,添加接口请求区别(区分手机端和PC端) 手机端地址: https://gitee.com/doc_wei01/cloud-after-sale 效果图 效果图 效果图
- 下一篇
类 UNIX 操作系统 NetBSD 9.0 发布,第 17 个主要版本
NetBSD 9.0 发布了,这是第 17 个主要版本。此版本在硬件支持、质量保证、安全性上进行了重大改进,并且带来了一些新特性、修复了数百个 bug。 NetBSD 是一个免费的、安全的及高度可移植的类 UNIX 操作系统,它适合于很多种平台,从 64 位的 AlphaServers 及桌面系统到手持及嵌入式系统。它在设计上非常整洁,并拥有先进的特性,这使得它在业界和学术界都有口皆碑。用户可通过完整的源代码来获得支持。很多应用程序都可容易地从 NetBSD Packages Collection 获得。 关注一下新特性: NPF 的许多改进,包括新功能、bug 修复、更好的文档,以及通过新的查找算法 thmap 提高性能。现在默认情况下启用 NPF。 更新 ZFS。这是可将 ZFS 用于日常使用的第一个版本,但尚不支持从 ZFS 引导或将 ZFS 用作根文件系统。 新的驱动程序,例如适用于 Broadcom Full-MAC 无线设备的 bwfm,适用于 Amazon Elastic Network Adapter 的 ena和 mcx Mellanox ConnectX-4 Lx ...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- CentOS7安装Docker,走上虚拟化容器引擎之路
- CentOS8安装Docker,最新的服务器搭配容器使用
- CentOS6,7,8上安装Nginx,支持https2.0的开启
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- SpringBoot2全家桶,快速入门学习开发网站教程
- Docker安装Oracle12C,快速搭建Oracle学习环境
- CentOS8编译安装MySQL8.0.19
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- CentOS7设置SWAP分区,小内存服务器的救世主