提出问题的背景:
有一个项目 “xx即时服务平台”,现在出现一个问题,列表展示的任务没有体现即时性,那么于是我就想出了之前做电商平台秒杀时,用到的定时任务;
方案设计:
在ssm配置里引入定时任务, 数据库表里放入定时的时间, 创建任务的时间
让定时任务轮询去判断数据库里的任务是否超时,超时可以改变状态或者删除数据库中的记录
详细设计
创建定时任务,定时任务做的时候出现一点问题,定时任务必须是无返回值,无参数才能创建成功的。 在ssm项目需要手动引入配置,但是在springboot里我们可以通过maven来引入依赖
1,sprinmvc.xml,配置文件添加内容:
xmlns:task="http://www.springframework.org/schema/task"
XSI中添加 :
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-3.2.xsd
2:添加设置定时任务的代码
在springmvc.xml文件中间位置添加如下:
<!-- 设置定时任务 -->
<task:annotation-driven/>
定时任务代码:
package com.ssm.util;
import com.ssm.mapper.TaskMapper;
import com.ssm.po.Task;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Controller;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
@Controller
public class SchedulTask {
@Resource(name="taskMapper")
private TaskMapper taskMapper;
@Scheduled(cron = "* * * * * ?")//每秒刷新一次
public void detect() throws ParseException {
List<Task> list = taskMapper.selectAllTask();
Date db = new Date();
Calendar c = Calendar.getInstance();
SimpleDateFormat std = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String str = std.format(db);//将时间转换为字符串后输出
List<Task> list1 = new ArrayList<>();
for (Task task : list) {
c.setTime(task.getAddtime());
c.add(Calendar.SECOND, task.getLive_time());//
db = std.parse(std.format(c.getTime()));
if (new Date().getTime() > db.getTime() && task.getState() == 0) {
task.setState(1);
task.setEndtime(c.getTime());
taskMapper.updateByPrimaryKey(task);
}
}
}
}
在线corn表达式生成器
这篇文章里介绍了 可以自定义定时任务,可以创建修改和删除 定时任务
|