java中定时器的简单使用

时间:2023-03-08 17:42:27
java中定时器的简单使用

  

1.首先肯定是容器一启动就要启动定时器,所以我们可以选择把定时器写在一个监听器里,容器一启动所以监听器也就跟着启动,然后定时器就可以工作了。

第一步,把自己写的监听器加到web.xml中;

第二步,写一个监听器,实现ServletContextListener接口;

第三步,写一个定时器,继承TimerTask,在复写的run()方法里写具体的业务逻辑。

第四步,在自己的监听器里复写的

public void contextInitialized(ServletContextEvent arg0){

}

这个方法里调用定时器的schedule方法。

具体代码如下:

web.xml添加:

 <!-- 用于补偿认证信息异常的数据,用来启动定时器,20170505 -->
<listener>
<listener-class>com.dcits.app.servlet.MyTimerTaskListener</listener-class>
</listener>

MyTimerTaskListener.java

 package com.dcits.app.servlet;

 import java.util.Calendar;
import java.util.Timer; import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
/**
* @author Weiyongle
* @time 2017-5-5 下午2:05:32
*/
public class MyTimerTaskListener implements ServletContextListener {
private Timer timer = null;
@Override
public void contextDestroyed(ServletContextEvent arg0) {
timer.cancel();
} @Override
public void contextInitialized(ServletContextEvent arg0) {
System.out.println("-----开始启动定时器------");
Calendar twentyOne = Calendar.getInstance();
twentyOne.set(Calendar.HOUR_OF_DAY, 23);
twentyOne.set(Calendar.MINUTE, 0);
twentyOne.set(Calendar.SECOND, 0);
timer = new Timer(true);
//第一次是晚上23点执行,间隔24小时执行一次
timer.schedule(new MyTimerTask(), twentyOne.getTime(), 1000*60*60*24); /*System.out.println("-----开始启动定时器------");
Calendar twentyOne = Calendar.getInstance();
twentyOne.set(Calendar.HOUR_OF_DAY, 14);
twentyOne.set(Calendar.MINUTE, 47);
twentyOne.set(Calendar.SECOND, 0);
timer = new Timer(true);
timer.schedule(new MyTimerTask(), twentyOne.getTime(), 1000*10);*/
} }

MyTimerTask.java

 package com.dcits.app.servlet;

 import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.TimerTask; import org.codehaus.jackson.JsonGenerationException;
import org.codehaus.jackson.map.JsonMappingException;
/**
* 定时器,用于补偿认证的时候没有获取到正常返回的那些数据
* @author Weiyongle
* @time 2017-5-5 下午2:20:12
*/
public class MyTimerTask extends TimerTask{
private static StringBuffer url = new StringBuffer();
@Override
public void run() {
//生产环境
// url.append("https://我是具体的ip地址/nmsypt/servlet/webServlet");//生产环境
url.append("http://localhost:8080/adp/servlet/webServlet");//本地环境
Map<String,Object> reqMap = new HashMap<String,Object>();
//这里的map从数据库里获取对应的数据不写死就行了,先获取map,在写个for循环进行循环就行了
reqMap.put("QYMC","丹同学的公司");
reqMap.put("NSRSBH","158028307441234");
reqMap.put("SJHM_FR","15802830744");
reqMap.put("YZM","123456");
reqMap.put("CWFZR","");//
reqMap.put("ZJLX_DM_CW","");//
reqMap.put("ZJHM_CW","");//
reqMap.put("ZGRS","1234");
reqMap.put("SQYY","");//
reqMap.put("JRCPBM","00002");
reqMap.put("XYDM","1");
reqMap.put("XZQHDM","");
reqMap.put("QYBM","QY17900000647001");
try {
CompensateData.CompensateDatas(url.toString(), reqMap);
System.out.println("-----成功补偿了一条认证信息------");
} catch (JsonGenerationException e) {
e.printStackTrace();
} catch (JsonMappingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
} }