符合中小企业对网站设计、功能常规化式的企业展示型网站建设
本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...
商城网站建设因基本功能的需求不同费用上面也有很大的差别...
手机微信网站开发、微信官网、微信商城网站...
这篇文章主要为大家展示了Spring boot基于ScheduledFuture如何实现定时任务,内容简而易懂,希望大家可以学习一下,学习完之后肯定会有收获的,下面让小编带大家一起来看看吧。
创新互联是网站建设专家,致力于互联网品牌建设与网络营销,专业领域包括成都网站制作、网站建设、电商网站制作开发、小程序开发、微信营销、系统平台开发,与其他网站设计及系统开发公司不同,我们的整合解决方案结合了恒基网络品牌建设经验和互联网整合营销的理念,并将策略和执行紧密结合,且不断评估并优化我们的方案,为客户提供全方位的互联网品牌整合方案!
一、 背景
接上一篇,完成存储过程的动态生成后,需要构建定时任务执行存储过程
二、 环境
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);
// 省略之前的... }
2) 编写实现类
@Service public class TestServiceImpl implements TestService { @Autowired private MonitorWarnItemRepository monitorWarnItemRepository @Autowired private ThreadPoolTaskScheduler threadPoolTaskScheduler; @Bean public ThreadPoolTaskScheduler threadPoolTaskScheduler() { return new ThreadPoolTaskScheduler(); } List
3) 构建任务处理线程类
public class QuartzTaskService implements Runnable { private JdbcTemplate jdbcTemplate; private String proName; private Listmaplist; private MonitorWarnItem item; public QuartzTaskService(String proName,List 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{ private Integer result; private String msg; private T rows; private int total; //省略其他处理 }
以上就是关于Spring boot基于ScheduledFuture如何实现定时任务的内容,如果你们有学习到知识或者技能,可以把它分享出去让更多的人看到。