Spring boot基于ScheduledFuture实现定时任务
程序员文章站
2022-07-06 17:56:06
一、 背景 接,完成存储过程的动态生成后,需要构建定时任务执行存储过程二、 环境 1.此随笔内容基于spring boot项目 2.数据库为mysql 5.7.9版本 3.jdk 版本为1.8...
一、 背景
接,完成存储过程的动态生成后,需要构建定时任务执行存储过程
二、 环境
1.此随笔内容基于spring boot项目
2.数据库为mysql 5.7.9版本
3.jdk 版本为1.8
三、 内容
1、定义接口和接口参数bean;
1)在上一篇博客bean 的基础上把接口配置参数bean修改一下,添加一个配置参数值和排序字段;在添加一个监测项的bean,想查看其他的bean信息,请移
@entity @table(name="monitor_warn_item") public class monitorwarnitem { @id private string id; private string proname;//名称 private string rule; private string send_content; private string recommend_value;// 建议值 private string standard_value; // 标准值 private integer fre_num; private string frequency; private string status; private string warntype; private string warn_date_num;// 监测频次 //此处省略get、set… } @entity @table(name="qt_interface_parameter") public class qtinterfaceparameter { @id private string id; @column(name="inter_id") private string interid; private string name; //参数名称 private string explain_info; //参数描述 private string type;// 输入输出类型 private string paratype; // 参数类型 private integer paralen; private integer paravalue; // 参数值 private integer order_num; // 排序字段 //此处省略get、set… }
2、定义scheduledfuture定时任务
1) 添加接口
public interface testservice { resultinfo initmonitor(string id);<br> // 省略之前的... }
2) 编写实现类
@service public class testserviceimpl implements testservice { @autowired private monitorwarnitemrepository monitorwarnitemrepository @autowired private threadpooltaskscheduler threadpooltaskscheduler; @bean public threadpooltaskscheduler threadpooltaskscheduler() { return new threadpooltaskscheduler(); } list<map<string, object>> maplist = new arraylist<map<string, object>>(); // 新建任务信息集合 /** * 初始化监测项 * * @param id * @return */ @override @transactional public resultinfo initmonitor(string id) { resultinfo info = new resultinfo(); string msg = ""; monitorwarnitem item = monitorwarnitemrepository.findid(id); msg =buildtask(item); info.setresult(1); info.setmsg("初始化成功,初始化返回信息:" + msg); system.out.println(msg);// 日志打印 return info; } /** * 配置任务信息 * * @param qt * @return */ private string buildtask(monitorwarnitem qt) { string msg = ""; if (isfure(qt.getid())) { list<qtinterface> interlist = qtinterfacerepository.queryinterfacebyitemid(qt.getid()); if (interlist.size() > 0) { map<string, object> map_future = new hashmap<>(); scheduledfuture<?> future;// 监测任务 list<qtinterfaceparameter> para = qtinterfaceparameterrepository.queryinfobyinterid(interlist.get(0).getid()); // 查找参数信息 list<string> map = new arraylist<>(para.size()); if (para.size() > 0) { // 参数集合 for (qtinterfaceparameter pa : para) { for (int item = 1; item <= para.size(); item++) { if (item == pa.getorder_num()) { // 根据字段排序来设置参数值的顺序 map.add(pa.getpara_value()); // 设置值 item++; } } } } quartztaskservice service = new quartztaskservice(interlist.get(0).getname(), map, jdbctemplate, qt); if (!"".equals(qt.getwarn_date_num()) && qt.getwarn_date_num() != null) { future = threadpooltaskscheduler.schedule(service, new crontrigger(qt.getwarn_date_num()));// 初始化任务,第二个参数是cron表达式 if (future != null) { map_future.put("future", future); map_future.put("id", interlist.get(0).getitemid()); map_future.put("status", "0"); maplist.add(map_future); } } else { msg += " 监测项:" + qt.getproname() + " 监测频次字段为空,不能执行计划!"; } } else { msg += " 监测项:" + qt.getproname() + " 没有查找到接口配置信息"; } } else { msg += " 监测项:" + qt.getproname() + " 已经启动,请不要重复启动。"; } return msg; } }
3) 构建任务处理线程类
public class quartztaskservice implements runnable { private jdbctemplate jdbctemplate; private string proname; private list<string> maplist; private monitorwarnitem item; public quartztaskservice(string proname,list<string> maplist,jdbctemplate jdbctemplate ,monitorwarnitem item){ this.proname=proname; this.maplist=maplist; this.jdbctemplate=jdbctemplate; this.item=item; } protected void executeinternal() throws jobexecutionexception { simpledateformat sdf=new simpledateformat("yyyy-mm-dd hh:mm:ss"); stringbuffer bf=new stringbuffer(); bf.append("call "); bf.append(proname); bf.append("("); int i=1; for(string map:maplist){ if(i==maplist.size()){ // 最后一位 bf.append("'"+map+"')"); }else { bf.append("'" + map + "',"); } i++; } jdbctemplate.batchupdate(bf.tostring()); system.out.println("执行了过程:" +proname+"当前参数顺序:"+bf.tostring()+ " 当前时间 "+ sdf.format(new date())); } @override public void run() { try { executeinternal(); // 调用执行 } catch (jobexecutionexception e) { e.printstacktrace(); } }
4) 此处是用的list保存的任务信息,在项目重启之后这个东西就没了,也就是说定时任务就全丢了,so,这里考虑使用数据库来持久化保存调度任务信息, 或者在项目启动的时候写一个配置来调用启动定时任务
@component @order(1) public class starttask implements commandlinerunner { @autowired private testservice testservice; public string settask(){ calendar cale = null; cale = calendar.getinstance(); int year = cale.get(calendar.year); monitorwarnitem itemlist=testservice.querybystatus ("1");// 根据状态查询需要启动的监测项 if(itemlist.size()>0){ // 存在需要启动的检测项 for(monitorwarnitem qt: itemlist) testservice.initmonitor(qt);// 启动任务列表和消息 } return ""; } @override public void run(string... args) throws exception { settask (); } }
5)最后附上一个我使用的返回处理类
public class resultinfo<t> { private integer result; private string msg; private t rows; private int total; //省略其他处理 }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: 经典学校搞笑顺口溜
推荐阅读
-
spring定时任务(scheduler)的串行、并行执行实现解析
-
基于Flyway实现简化Spring Boot项目部署
-
Spring Boot @Scheduled定时任务代码实例解析
-
.net core 基于 IHostedService 实现定时任务
-
SpringBoot系列:Spring Boot集成定时任务Quartz
-
控制台基于Quartz.Net组件实现定时任务调度(一)
-
基于netty实现rpc框架-spring boot客户端
-
.net core 基于Hangfire+Mysql持久化实现定时任务配置方法
-
Spring Boot+Quartz实现一个实时管理的定时任务
-
Spring Boot实现简单的定时任务