java 任务系统_Quartz+JAVA+Servlet实现任务调度系统（简洁）

ゞ浴缸里的玫瑰 2022-11-02 06:04 17阅读 0赞

前言

该系统使用场景：

在12306上买了一张火车票，30分钟内需要支付(需要添加一个倒计时)，30分钟还没有支付就请求取消订单的接口(自动根据url请求)，如果支付了收到了支付的回调通知后，就删除计时器上的该任务

1.项目结构图

![139be45d2b441b593a05940d047102a3.png][]

2.引入所需要依赖的jar包

org.quartz-scheduler

quartz

2.2.2

com.fasterxml.jackson.core

jackson-core

2.5.3

com.fasterxml.jackson.core

jackson-databind

2.5.3

commons-beanutils

1.9.2

commons-collections

3.2.2

commons-lang

2.6

commons-logging

1.2

net.sf.ezmorph

ezmorph

1.0.6

net.sf.json-lib

json-lib

2.4

jdk15

3.编写以下类：

3.1Config.java

public class Config \{

public static String token="liujun";

private Config() \{

super();

3.2  JobGroupInfo.java

public class JobGroupInfo \{

private String jobName;//任务名字

private String jobGroupName;//组名字

private Long nextFireTime;//下次执行时间

public String getJobName() \{

return jobName;

public void setJobName(String jobName) \{

this.jobName = jobName;

public String getJobGroupName() \{

return jobGroupName;

public void setJobGroupName(String jobGroupName) \{

this.jobGroupName = jobGroupName;

public Long getNextFireTime() \{

return nextFireTime;

public void setNextFireTime(Long nextFireTime) \{

this.nextFireTime = nextFireTime;

public JobGroupInfo() \{

super();

public JobGroupInfo(String jobName, String jobGroupName, Long nextFireTime) \{

super();

this.jobName = jobName;

this.jobGroupName = jobGroupName;

this.nextFireTime = nextFireTime;

3.3  TaskInfo.java

public class TaskInfo \{

private String backUrl;//任务回调地址

private String jobName;//任务名字

private Integer seconds;//计时时间

private Object context;//其他内容

private Integer errormaxcount;//失败请求的次数

private String jobGorupName;//任务组名字

public String getBackUrl() \{

return backUrl;

public void setBackUrl(String backUrl) \{

this.backUrl = backUrl;

public String getJobName() \{

return jobName;

public void setJobName(String jobName) \{

this.jobName = jobName;

public Integer getSeconds() \{

return seconds;

public void setSeconds(Integer seconds) \{

this.seconds = seconds;

public Object getContext() \{

return context;

public void setContext(Object context) \{

this.context = context;

public Integer getErrormaxcount() \{

return errormaxcount;

public void setErrormaxcount(Integer errormaxcount) \{

this.errormaxcount = errormaxcount;

public String getJobGorupName() \{

return jobGorupName;

public void setJobGorupName(String jobGorupName) \{

this.jobGorupName = jobGorupName;

public TaskInfo() \{

super();

public TaskInfo(String backUrl, String jobName, Integer seconds,

Object context, Integer errormaxcount, String jobGorupName) \{

super();

this.backUrl = backUrl;

this.jobName = jobName;

this.seconds = seconds;

this.context = context;

this.errormaxcount = errormaxcount;

this.jobGorupName = jobGorupName;

@Override

public String toString() \{

return "TaskInfo \[backUrl=" + backUrl + ", jobName=" + jobName

\+ ", seconds=" + seconds + ", context=" + context

\+ ", errormaxcount=" + errormaxcount + ", jobGorupName="

\+ jobGorupName + "\]";

3.4 JobBack.java

public class JobBack implements Job\{

//回调执行方法

public void execute(JobExecutionContext context) throws JobExecutionException \{

//得到添加任务中的参数

TaskInfo task = (TaskInfo) context.getMergedJobDataMap().get("task");

sendBack(task);

private void sendBack(TaskInfo task) \{

task.setErrormaxcount(task.getErrormaxcount() - 1);

// 得到参数请求回调

try \{

//拼装请求地址以及参数

String uri = "jobName=" + task.getJobName() + "&context=" + task.getContext() + "&jobGorupName="

\+ task.getJobGorupName() + "&paramkey=" + Md5Util.GetMD5Code(Config.token);

//请求并得到返回值

String res = HttpUtil.request\_post(task.getBackUrl(), uri);

//如果返回值不是“SUCCESS” 就等待10S进行重复请求(此处避免请求失败就结束请求，参数中传递了一个失败请求次数)

if (!res.trim().equals("SUCCESS")) \{

//如果请求错误次数还大于0

if (task.getErrormaxcount() >= 1) \{

Thread.sleep(10000);

sendBack(task);

\} catch (Exception e) \{

System.out.println(e.getMessage());

if (task.getErrormaxcount() >= 1) \{

try \{

Thread.sleep(10000);

\} catch (InterruptedException e1) \{

e1.printStackTrace();

sendBack(task);

3.5 JobManger.java

public class JobManger \{

private final static String TRIGGER\_GROUP\_NAME = "QUARTZ\_TRIGGERGROUP";//触发器组

private final static SchedulerFactory sf = new StdSchedulerFactory();

/\*\*

\* 添加任务

\* @param jobName 任务名称

\* @param job 任务处理类 需要继承Job

\* @param context 处理任务可以获取的上下文 通过context.getMergedJobDataMap().getString("context"); 获取

\* @param seconds 间隔秒

\* @return

\*/

public static int addJob(String jobName, Class extends Job> job, Object task, int seconds, String jobGorupName)\{

try \{

//判断任务是否存在

Scheduler sche = sf.getScheduler();

JobKey jobKey = JobKey.jobKey(jobName,jobGorupName);

if(sche.checkExists(jobKey))\{

return 1;//任务已经存在

//创建一个JobDetail实例，指定SimpleJob

Map JobDetailmap =new HashMap();

JobDetailmap.put("name", jobName);//设置任务名字

JobDetailmap.put("group", jobGorupName);//设置任务组

JobDetailmap.put("jobClass",job.getCanonicalName());//指定执行类 Task.class.getCanonicalName()

JobDetail jobDetail= JobDetailSupport.newJobDetail(JobDetailmap);

//添加数据内容

jobDetail.getJobDataMap().put("task",task);//传输的上下文

//通过SimpleTrigger定义调度规则：马上启动，每2秒运行一次，共运行100次 等。。。。

SimpleTriggerImpl simpleTrigger = new SimpleTriggerImpl();

simpleTrigger.setName(jobName);

simpleTrigger.setGroup(TRIGGER\_GROUP\_NAME);

//什么时候开始执行

simpleTrigger.setStartTime(new Date(new Date().getTime()+1000\*seconds));

//间隔时间

simpleTrigger.setRepeatInterval(1000\*seconds);

//最多访问次数 默认执行一次

simpleTrigger.setRepeatCount(0);

//通过SchedulerFactory获取一个调度器实例

SchedulerFactory schedulerFactory = new StdSchedulerFactory();

Scheduler scheduler = schedulerFactory.getScheduler();

scheduler.scheduleJob(jobDetail, simpleTrigger);//④ 注册并进行调度

scheduler.start();//⑤调度启动

return 0;//添加成功

\} catch (Exception e) \{

return 2;//操作异常

/\*\*

\* 关闭任务调度

\* @param jobName 任务名称

\* @return 0 关闭成功 1： 关闭失败 2：操作异常

\*/

public static int closeJob(String jobName,String jobGorupName)\{

//关闭任务调度

try \{

Scheduler sche = sf.getScheduler();

JobKey jobKey = JobKey.jobKey(jobName,jobGorupName);

return sche.deleteJob(jobKey)==true?0:1;

\} catch (SchedulerException e) \{

return 2;

private JobManger() \{\}

3.6 AddJob.java

@WebServlet("/addJob.do")

public class AddJob extends HttpServlet\{

private static final long serialVersionUID = 1L;

public AddJob() \{

super();

protected void doGet(HttpServletRequest request, HttpServletResponse response)

throws ServletException, IOException \{

//避免get 请求

response.sendError(403);

// doPost(request, response);

/\*\*

\* 处理添加任务

\*/

protected void doPost(HttpServletRequest request, HttpServletResponse response)

throws ServletException, IOException \{

// 设置编码

request.setCharacterEncoding("utf-8");

response.setCharacterEncoding("utf-8");

response.setContentType("utf-8");

// 得到请求

String jobName = request.getParameter("jobName");// 得到任务名称

// 得到token

//String token = request.getParameter("token");

// 验证签名

/\*if (!MD5Util.GetMD5Code(jobName + Config.token + "zhangke is shabi!").equals(token)) \{

return;

\}\*/

// 得到回调

String backUrl = request.getParameter("backUrl");

// 得到请求定时时间

Integer seconds = Integer.valueOf(request.getParameter("seconds"));

String errMaxCount = request.getParameter("errormaxcount");

Integer errormaxcount = errMaxCount == null ? 1 : Integer.valueOf(errMaxCount);// 回调请求失败的次数

// 默认为一次

// 得到其他参数

String context = request.getParameter("context");

// 得到任务组

String jobGorupName = request.getParameter("jobGorupName");

TaskInfo t = new TaskInfo(backUrl, jobName, seconds, context, errormaxcount, jobGorupName);

// 添加任务

Integer res = JobManger.addJob(jobName, JobBack.class, t, seconds, jobGorupName);

response.getWriter().write(res.toString());

3.7 MonitoringJob.java

@WebServlet("/monitoringJob.do")

public class MonitoringJob extends HttpServlet \{

private static final long serialVersionUID = 1L;

/\*\*

\* @see HttpServlet\#HttpServlet()

\*/

public MonitoringJob() \{

super();

protected void doGet(HttpServletRequest request,

HttpServletResponse response) throws ServletException, IOException \{

doPost(request, response);

protected void doPost(HttpServletRequest request,

HttpServletResponse response) throws ServletException, IOException \{

request.setCharacterEncoding("utf-8");

response.setCharacterEncoding("utf-8");

response.setContentType("text/json;char=utf-8");

// 得到任务组名字

String jobGroupName = request.getParameter("jobGroupName");

// 验证是否为空

//monitoringJob.do

List list=new ArrayList();

try \{

Scheduler scheduler = new StdSchedulerFactory().getScheduler();

for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(jobGroupName==null?"":jobGroupName))) \{

String jobName = jobKey.getName();

String jobGroup = jobKey.getGroup();

// get job's trigger

List triggers = (List) scheduler.getTriggersOfJob(jobKey);

Date nextFireTime = triggers.get(0).getNextFireTime(); // 下一次执行时间、

JobGroupInfo gri=new JobGroupInfo(jobName, jobGroup, nextFireTime.getTime());

list.add(gri);

response.getWriter().write(JSONArray.fromObject(list).toString());

\} catch (SchedulerException e) \{

e.printStackTrace();

3.8 RemoveJob.java

@WebServlet("/removeJob.do")

public class RemoveJob extends HttpServlet \{

private static final long serialVersionUID = 1L;

public RemoveJob() \{

super();

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException \{

response.sendError(403);

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException \{

//得到任务名

String jobName=request.getParameter("jobName");

//得到签名

String token =request.getParameter("token");

//得到任务组

String jobGorupName=request.getParameter("jobGorupName");

//验证签名

/\*if(!MD5Util.GetMD5Code(jobName+Config.token+"zhangke is sb!").equals(token))\{

response.getWriter().write("2");

return;

\}\*/

//执行移除操作

int res= JobManger.closeJob(jobName,jobGorupName);

if(res==0)\{//成功

response.getWriter().write("0");

\}else if(res==1)\{//不存在

response.getWriter().write("1");

\}else\{

//报错啦！

response.getWriter().write("2");

3.9 TestBack.java

@WebServlet("/testback")

public class TestBack extends HttpServlet \{

private static final long serialVersionUID = 1L;

public TestBack() \{

super();

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException \{

System.out.println("get请求");

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException \{

request.setCharacterEncoding("utf-8");

Map map=request.getParameterMap();

Iterator iter = map.keySet().iterator();

while (iter.hasNext()) \{

String key=iter.next();

System.out.println("key："+key+" value:"+map.get(key)\[0\]);

response.getWriter().write("SUCCESS");

3.10 HttpUtil.java

public class HttpUtil \{

public static String request\_get(String httpUrl) \{

BufferedReader reader = null;

String result = null;

StringBuffer sbf = new StringBuffer();

try \{

URL url = new URL(httpUrl);

HttpURLConnection connection = (HttpURLConnection) url

.openConnection();

connection.setRequestMethod("GET");

connection.setRequestProperty("Content-Type","application/x-www-form-urlencoded");

connection.setDoOutput(true);

connection.setDoInput(true);

connection.setConnectTimeout(5000);

connection.setReadTimeout(20000);

connection.connect();

InputStream is = connection.getInputStream();

reader = new BufferedReader(new InputStreamReader(is,"UTF-8"));

String strRead = null;

while ((strRead = reader.readLine()) != null) \{

sbf.append(strRead);

sbf.append("\\r\\n");

reader.close();

result = sbf.toString();

\} catch (Exception e) \{

e.printStackTrace();

return result;

public static String request\_post(String httpUrl, String httpArg) \{

BufferedReader reader = null;

String result = null;

StringBuffer sbf = new StringBuffer();

try \{

URL url = new URL(httpUrl);

HttpURLConnection connection = (HttpURLConnection) url

.openConnection();

connection.setRequestMethod("POST");

connection.setRequestProperty("Content-Type","application/x-www-form-urlencoded");

connection.setDoOutput(true);

connection.setDoInput(true);

connection.setConnectTimeout(5000);

connection.setReadTimeout(20000);

connection.getOutputStream().write(httpArg.getBytes("UTF-8"));

connection.connect();

InputStream is = connection.getInputStream();

reader = new BufferedReader(new InputStreamReader(is,"UTF-8"));

String strRead = null;

while ((strRead = reader.readLine()) != null) \{

sbf.append(strRead);

sbf.append("\\r\\n");

reader.close();

result = sbf.toString();

\} catch (Exception e) \{

e.printStackTrace();

return result;

3.11 Md5Util.java

public class Md5Util \{

private final static String\[\] strDigits = \{ "0", "1", "2", "3", "4", "5",

"6", "7", "8", "9", "a", "b", "c", "d", "e", "f" \};

public Md5Util() \{

private static String byteToArrayString(byte bByte) \{

int iRet = bByte;

if (iRet < 0) \{

iRet += 256;

int iD1 = iRet / 16;

int iD2 = iRet % 16;

return strDigits\[iD1\] + strDigits\[iD2\];

private static String byteToNum(byte bByte) \{

int iRet = bByte;

System.out.println("iRet1=" + iRet);

if (iRet < 0) \{

iRet += 256;

return String.valueOf(iRet);

private static String byteToString(byte\[\] bByte) \{

StringBuffer sBuffer = new StringBuffer();

for (int i = 0; i < bByte.length; i++) \{

sBuffer.append(byteToArrayString(bByte\[i\]));

return sBuffer.toString();

public static String GetMD5Code(String strObj) \{

String resultString = null;

try \{

resultString = new String(strObj);

MessageDigest md = MessageDigest.getInstance("MD5");

resultString = byteToString(md.digest(strObj.getBytes()));

\} catch (NoSuchAlgorithmException ex) \{

ex.printStackTrace();

return resultString;

4.启动maven

https://blog.csdn.net/nandao158/article/details/809021935.测试 postman

![b766d4f80f2b053faa4b9305cda108c1.png][]

5秒后看控制台

![2d76f6572f2c9eefc2b843853ab3d56d.png][]

[139be45d2b441b593a05940d047102a3.png]: /images/20221024/3a36609146174e4ebcc99b53befb4cbd.png
[b766d4f80f2b053faa4b9305cda108c1.png]: /images/20221024/c65ec7dd4c7b43ea9475629a43058b46.png
[2d76f6572f2c9eefc2b843853ab3d56d.png]: /images/20221024/33ae802bbcb54f049eaa13666f677d5c.png