`
jelly_bitores
  • 浏览: 46336 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

Java定时执行任务

    博客分类:
  • Java
阅读更多

  在做项目时经常用遇到在指定的时间段执行某个操作,比如说项目中要求每天的00:00分计算当天的剩于库存数或要求02:00开始清理某一个表中的数据,如何实现呢?下面我们就分几步来完成这个任务。

 

1. 增加一个ServletContextListener监听器,在服务器启动时执行ServletContextListener。

 具体代码如下:

   a. 实现ServletContextListener接口,实现接口中的方法。

public class TimerTaskListener implements ServletContextListener {
	private static final Logger logger = LogManager.getLogger(TimerTaskListener.class);
	@Override
	public void contextDestroyed(ServletContextEvent arg0) {
		logger.info("TimerTaskListener Destoryed!");
	}

	@Override
	public void contextInitialized(ServletContextEvent arg0) {
		// code written in here ...
	}
}

   b. 在web.xml中配置listener,这样在服务器启动时就可以调用TimerTaskListener监听类了。

 

<listener> 
        <listener-class>com.jelly.commons.listener.TimerTaskListener</listener-class> 
</listener>

 2. 设计系统任务表,用于存放要执行的任务。

 表结构如下: 

TASK_ID FIRST_TIME PERIOD TASK_CLASS SERVICE_NAME
10001 2011-11-04 00:00:00 200000 com.jelly.service.task.TimerTaskServices1 任务1
10002 2011-11-03 02:00:00 500000 com.jelly.service.task.TimerTaskServices2 任务2

 

 TASK_ID(任务ID)

 FIRST_TIME(首次执行时间)

 PERIOD(执行频率,单位毫秒,1天=24*60*60*1000)

 TASK_CLASS(任务的所在的类)

 SERVICE_NAME(任务名称)

 

3. 新建一个TimerTask抽象类,该类主要是为了让用户继承使用(TASK_CLASS所指的父类),代码如下:

 

public abstract class TimerTask {
	private static final Logger logger = LogManager.getLogger(TimerTaskListener.class);
	public abstract void execute(SystemTask task);
	public void start(final SystemTask task){
		// code written in here...
	}
}

 4. 编写TimerTaskListener类中需要书写的代码。

 

public void contextInitialized(ServletContextEvent arg0) {
		new Thread(new Runnable() {
			@Override
			public void run() {
				DBHelper dbHelper = null;
				List<SystemTask> tasks = FastList.newInstance();
				try {
					Thread.sleep(30000);
					// query tasks
					dbHelper = DBHelper.getInstance();
					StringBuffer sql = new StringBuffer();
					sql.append("SELECT * FROM SYSTEM_TASK");
					tasks = dbHelper.select(sql.toString(), new BeanListHandler<SystemTask>(SystemTask.class));
					dbHelper.close();
				} catch (InterruptedException e) {
					logger.error(e.getMessage(), e);
				} catch (SQLException e) {
					logger.error(e.getMessage(), e);
				} finally {
					if(dbHelper != null){
						dbHelper.freeConnection();
					}
				}
				// execute task
				for (SystemTask task : tasks) {
					String className = task.getTaskClass();
					try {
						Class<?> clzz = Class.forName(className);
						TimerTask service = (TimerTask)clzz.newInstance();
						service.start(task);
					} catch (ClassNotFoundException e) {
						logger.error(e.getMessage(), e);
					} catch (InstantiationException e) {
						logger.error(e.getMessage(), e);
					} catch (IllegalAccessException e) {
						logger.error(e.getMessage(), e);
					} catch (Exception e) {
						logger.error(e.getMessage(), e);
					}
				}
			}
		}).start();
	}

 5. TimerTask类中的主要代码。

 

public void start(final SystemTask task){
		final String taskId = task.getId();
		final long period = task.getPeriod();
		final Date firstTime = task.getFirstTime();
		Calendar c = Calendar.getInstance();
		c.setTime(firstTime);
		
		long dayMillisecond = c.getTimeInMillis();
		int hour = c.get(Calendar.HOUR_OF_DAY);
		int minute = c.get(Calendar.MINUTE);
		int second = c.get(Calendar.SECOND);
		int millisecond = c.get(Calendar.MILLISECOND);
		
		Calendar runtime = Calendar.getInstance();
		runtime.setTime(new Date());
		runtime.set(Calendar.HOUR_OF_DAY, hour);
		runtime.set(Calendar.MINUTE, minute);
		runtime.set(Calendar.SECOND, second);
		runtime.set(Calendar.MILLISECOND, millisecond);
		
		long nowMillisecond = runtime.getTimeInMillis();
		if(nowMillisecond >= dayMillisecond){
			if(nowMillisecond < new Date().getTime())
				runtime.add(Calendar.DAY_OF_MONTH, 1);
		}else{
			runtime.setTime(firstTime);
		}
		final String assignTime = UtilDateTime.toDateString(firstTime, UtilDateTime.FORMAT_DATE_TIME);
		final String executeTime = UtilDateTime.toDateString(runtime.getTime(), UtilDateTime.FORMAT_DATE_TIME);
		logger.info("task id (" + taskId + ") assign time : " + assignTime);
		logger.info("task id (" + taskId + ") execute time: " + executeTime);
		Timer timer = new Timer();
		timer.scheduleAtFixedRate(new java.util.TimerTask() {
			@Override
			public void run() {
				try {
					execute(task);
				} catch (Throwable e) {
					logger.error(e.getMessage(),e);
				}
			}
		}, runtime.getTime(), period);
	}

 

(未完)

分享到:
评论

相关推荐

    java 定时执行任务

    Java定时执行任务是Java开发中常见的一种需求,用于在特定时间点或按照预设周期执行某段代码。在Java中,有两种主要的方式来实现定时任务:Java.util.Timer类和java.util.concurrent包下的ScheduledExecutorService...

    Java定时执行任务的三种方法

    Java定时执行任务是Java开发中常见的一种需求,用于在特定时间执行特定的代码逻辑,例如数据备份、统计分析等。本文将详细介绍Java中三种常见的定时任务实现方式:`java.util.Timer`、`ServletContextListener`以及...

    java定时任务,每天定时执行任务

    Java 定时任务,每天定时执行任务 Java 定时任务是指在 Java 语言中实现的定时执行任务的机制,通过使用 Timer 和 TimerTask 两个类,可以实现定时执行任务的功能。在这个例子中,我们将实现每天定时执行任务的功能...

    Java定时执行某个任务

    在Java编程中,定时执行某个任务是一项常见的需求,例如定期备份数据、发送邮件或执行维护操作等。要实现这一功能,Java提供了多种解决方案。这里我们将深入探讨两种主要的方法:Java的`java.util.Timer`类和Java 5...

    java 定时执行任务 定时关机 定时重启

    使用Java Swing写的一个小程序,用来定时关机、定时重启、定时执行某一个应用程序。执行时调用cmd命令执行的。其他的,就没什么了,最后用exe4j把jar打包成了exe文件,在本地测能用,不知道其他地方是否能用,内部有...

    java轻松实现—定时任务

    Java中的定时任务是软件开发中一个非常重要的功能,它允许我们按照预定的时间间隔执行特定的任务,比如数据备份、日志清理、系统监控等。在Java中,我们可以利用`java.util.Timer`类和`java.util.TimerTask`类来实现...

    java定时执行sql语句

    通过配置数据库连接信息和要执行的sql语句,可实现定时执行多个sql语句。 所要执行的语句只能是写死的,可支持sqlserver mysql oracle。 配置说明: config/sys.properties 中指定数据库类型及连接信息,执行间隔...

    java定时任务的实现方式

    Java定时任务的实现是软件开发中常见的需求,用于在特定时间执行特定的业务逻辑,例如数据备份、报表生成等。本文将详细介绍两种常用的Java定时任务实现方式:Timer类和Spring框架的Quartz调度器。 首先,第一种...

    java定时任务调度

    Java定时任务调度是Java开发中常见的一种功能,用于在特定时间执行特定的任务,例如数据同步、日志清理、报表生成等。在Java中,有多种实现定时任务调度的方式,包括但不限于Java内置的`java.util.Timer`类、Spring...

    java动态管理定时任务

    在Java开发中,定时任务是不可或缺的一部分,尤其在企业级应用中,用于执行定期的数据处理、报表生成、系统维护等工作。Spring框架与Quartz库的整合提供了强大的动态管理定时任务的能力。下面我们将深入探讨这个主题...

    Quartz--JAVA定时任务\Java应用:Java调度任务和Spring Quartz (1)

    Java定时任务是应用程序中不可或缺的一部分,它允许程序在特定时间执行特定操作,无需用户干预。在JDK 1.3及以后的版本中,`java.util.Timer`类提供了基础的定时任务支持。不过,`Timer`类的功能相对有限,无法精确...

    java quartz 定时任务

    - Quartz 是一个完全由Java编写的开源作业调度框架,它可以在Java应用中用于执行定时任务。Quartz 支持集群环境,可以在多台服务器上分布式运行,以提高系统的可用性和可靠性。 2. **定时任务**: - 定时任务是在...

    java定时任务小例子

    Java定时任务是编程中常见的一种需求,用于在特定时间或间隔执行特定的代码逻辑。在这个“java定时任务小例子”中,我们可以看到两个关键文件:`TimerTest.java`和`DoTask.java`,它们分别代表了定时器的任务调度和...

    JAVA定时任务调度

    Java定时任务调度是Java开发中一个非常重要的技术领域,它允许开发者在特定的时间点或按照预定义的周期执行任务,从而实现自动化的工作流程。在Java中,我们可以使用多种方式来实现定时任务,如Java内置的`java.util...

    java定时执行多任务和quartz定时执行多任务

    Java定时执行多任务是软件开发中的常见需求,用于在特定时间点或按固定频率执行某项操作,例如数据同步、日志清理等。Java提供了一些内置的定时工具,如`java.util.Timer`和`java.util.concurrent....

    java定时任务器(含源码)

    用java写的任务定时器,设置想设的时间,选择可执行文件或者txt,word,时间一到便会自动运行。现在有源码。

    java定时任务开源案例

    Java定时任务是软件开发中一个不可或缺的特性,它允许程序在特定时间执行预定的任务,而无需用户干预。在Java世界里,实现定时任务的方式多种多样,包括但不限于使用Java内置的`java.util.Timer`和`java.util....

    java 定时任务及jar包

    Java定时任务是Java编程中一个重要的特性,它允许开发者安排任务在特定的时间点或周期性地执行。在Java中,我们可以使用内置的`java.util.Timer`类和`java.util.concurrent.ScheduledExecutorService`来实现定时任务...

    java定时任务quartz的基本实现

    Java定时任务在软件开发中扮演着重要角色,它允许开发者安排任务在特定时间执行,而无需持续监控。Quartz是Java领域中一个广泛使用的开源任务调度框架,它提供了丰富的功能来满足各种定时任务的需求。本篇文章将深入...

Global site tag (gtag.js) - Google Analytics