java_Timer定时器实例_Spring实例.doc

java Timer定时器实例 Spring实例2009-09-11 14:48package com.loong.mail.timer;import java.text.SimpleDateFormat;import java.util.Date;import java.util.Timer;import javax.servlet.ServletContextEvent;import javax.servlet.ServletContextListener;public class TimerListen implements ServletContextListener private Timer timer = null; public void contextDestroyed(ServletContextEvent arg0) timer.cancel(); public void contextInitialized(ServletContextEvent arg0) try SimpleDateFormat fTime = new SimpleDateFormat(yyyy/MM/dd HH:mm:ss); SimpleDateFormat fTime_1=new SimpleDateFormat(yyyy/MM/dd); Date d1 = fTime.parse(fTime_1.format(new Date()+ 14:17:00); timer = new Timer(true); /设置任务计划，启动和间隔时间 / System.out.print(rundate); /timer.scheduleAtFixedRate(new MailTimerTask(arg0.getServletContext().getRealPath(/),rundate,1000*60*60*24); timer.scheduleAtFixedRate(new MailTimerTask(arg0.getServletContext().getRealPath(/),d1, 24*60*60*1000); catch (Exception e) System.out.print(e.getMessage(); package com.loong.mail.timer;import java.util.Date;import java.util.TimerTask;import com.loong.filter.CFile;import com.loong.mail.sendmail.SendMail;import com.loong.user.service.UserService;import java.io.*;import .*;import java.io.InputStream;public class MailTimerTask extends TimerTaskprivate String path;public MailTimerTask(String path) this.path=path; System.out.println(test+new Date(); run();public void run() System.out.println(new Date(); SendMail sm = new SendMail(); sm.SystemMail(, wmq534, ); /UserService us = new UserService(); /us.getUserInfo(userId); /查找数据库中当天消费金额大于20的用户的用户名，email，消费金额、/使用freemarker生成html文件。传递到sendMails，发送到邮箱 / BufferedReader in=null; /StringBuffer sb=new StringBuffer(); /try /URL url=new URL(/html/paihang.jsp); /HttpURLConnection conn = (HttpURLConnection)url.openConnection(); /conn.setRequestProperty(Accept-Language,zh-cn); / conn.setRequestProperty(user-agent,mozilla/4.0 (compatible; msie 6.0; windows 2000); / conn.setRequestMethod(POST); / conn.setUseCaches(false); /conn.connect(); /int code=conn.getResponseCode(); /InputStream l_urlStream=null; /if(code!=404) / l_urlStream =conn.getInputStream(); /else / l_urlStream=conn.getErrorStream(); / /in = new BufferedReader(new InputStreamReader(l_urlStream,UTF-8); /String inputLine=; /while (inputLine = in.readLine() != null) / / sb.append(inputLine); /sb.append(rn); /* HtmlPage html=new HtmlPage(); CFile.writeFile(path+/inc/phb.htm,html.html().toString(), null); */ /conn.disconnect();/ catch(MalformedURLException e)/ CFile.writeFile(path+/inc/phb1.htm,URL连接异常:+e.getMessage(), null);/ System.out.print(e.getMessage();/ catch(IOException e)/ CFile.writeFile(path+/inc/phb1.htm,IO异常:+e.getMessage(), null);/ System.out.print(e.getMessage();/ / finally/ try/ if(in!=null)/ in.close();/ catch(Exception e)/ / System.out.print(e.getMessage();/ / Spring 中的定时任务配置实例 SayHello 0/10 * * * * ? package test;import org.apache.log4j.*;public class TaskJob public static Logger log = Logger .getLogger(TaskJob.class); public void SayHello() / TODO Auto-generated method stub try (处理任务开始.); / 业务逻辑代码调用 System.out.println(时间 + new java.util.Date().toLocaleString() + -大家好啊！); (处理任务结束!); catch (Exception e) log.error(处理任务出现异常, e); java中定时器timer类的实现和源代码2007-11-01 08:59在Windows编程中可以调用SetTimer在指定窗口安装定时器(Timer)，定时器可以在指定的时间间隔周期性回调用户指定的方法，用来执行周期性的任务，如果想取消定时器，可以调用KillTimer取消。但是在java标准包里中并没有这种类。下面介绍的这个类包可以实现上述功能。下面是接口，需要支持定时器功能的类要实现这个接口：TimerClient.java package com.ly.util;/* TimerClient Interface* version 1.0, 8 October 1995*/public interface TimerClient void timerEvent(int id);下面是定时器的实现，包括三个类：TimerCtl,TimerTask,TimerTasks。其中TimerTask用来描述定时器信息。TimerTasks是一个TimerTask的列表，这样我们就可以同时在一个应用中安插多个定时器。TimerCtl是定时器控制类，是个线程，不停地检查TimerTasks中是否有TimerTask到期，要是有TimerTask到达指定的时间，则回调TimerTask指定的TimerClient的timerEvent接口。TimerCtl.java package com.ly.util;import java.util.Vector;import java.util.Enumeration;/import com.borland.jb.util.Diagnostic;/* Timer Component* Note:* - The successful operation of this timer requires clients to execute simple, short* code snippets when called back by the engine. Otherwise the queues delivery* mechanism will be held up* Further work:* - When Thread.Interrupt is implemented we can switch from the busy wait model to* the calculated wait model. Without the interrupt the thread waits for the* calculated interval before waking up. This is a problem if another shorter* request arrives. For now well assume the minimum resolution of the timer is* 100ms.* version 1.0, 2 October 1995*/public class TimerCtl static TimerTasks timerTasks; public TimerCtl() /* * Start a timer running */ public static void startTimer(TimerClient client, int eventId, long delay, boolean repeat) / create the timer if necessary if (timerTasks = null) timerTasks = new TimerTasks(); timerTasks.start(); /Diagnostic.out.println(TIMER: startTimer+eventId); / add the new task to the queue timerTasks.add(client, eventId, delay, repeat); /* * Stop a timer */ public static void stopTimer(TimerClient client, int eventId) /Diagnostic.out.println(TIMER: stopTimer+eventId); if(timerTasks != null) timerTasks.end(client, eventId); class TimerTasks extends Thread Vector tasks = new Vector(); boolean suspended = false; boolean sleeping = false; /* * Thread task runner */ public void run() / Loop forever while (true) long sleepTime = 0; / Ensure that the tasks class is protected synchronized (tasks) /Diagnostic.out.println(TIMER: Tick); / Scan the job list for any jobs which may fire. / Mark one-shot jobs for deletion / Calculate the maximum time we can sleep for sleepTime = scan(); / Delete DeletePending jobs. DeletePending jobs result from one-shots which have / been sent, and repeat jobs which have been cancelled. Jobs may have been / cancelled during the Scan process. purge(); / Suspend timer if necessary if (tasks.size() = 0) /Diagnostic.out.println(TIMER: Suspend); try synchronized(this) suspended = true; wait(); catch (InterruptedException e) else /Diagnostic.out.println(TIMER: Suggested Sleeping for +sleepTime); if (sleepTime = 0) try sleeping = true; sleep(sleepTime); sleeping = false; catch (InterruptedException i) /Diagnostic.out.println(TIMER: Caught me napping); /* * Add a new task */ public void add(TimerClient client, int eventId, long delay, boolean repeat) TimerTask t = new TimerTask(client, eventId, delay, repeat); synchronized (tasks) tasks.addElement(Object)t); / Want instant response - wake the thread if its napping / unfortunately the interrupt() method is not working/ if (sleeping)/ interrupt(); if (suspended) synchronized(this) notify(); /Diagnostic.out.println(TIMER: Resume); suspended = false; /* * Find the job and mark it for deletion */ public void end(TimerClient client, int eventId) synchronized (tasks) for (int i = 0; i tasks.size(); i+) TimerTask t = (TimerTask)tasks.elementAt(i); /if (!t.deletePending & t.client = client & t.eventId = eventId) if (t.deletePending = false & t.client = client & t.eventId = eventId) / JPBS - if we dont reset repeat, deletePending will be set again t.repeat = false; t.deletePending = true; break; /* * Clear out all the dead wood */ void purge() for (int i = 0; i tasks.size(); i+) TimerTask t = (TimerTask)tasks.elementAt(i); if (t.deletePending) /Diagnostic.out.println(TIMER: purged); tasks.removeElementAt(i); i-; long scan() / The value added to the current time determines the MAX time until / the next scan / This is 100 now since errupt() is not implemented long nextTime = System.currentTimeMillis() +