java定时任务(java定时任务每小时执行一次)

http://www.itjxue.com  2023-03-05 20:23  来源:未知  点击次数: 

java 定时任务的几种实现方式

JDK 自带的定时器实现

// schedule(TimerTask task, long delay) 延迟 delay 毫秒 执行

// schedule(TimerTask task, Date time) 特定时间执行

public static void main(String[] args) {

for (int i = 0; i 10; ++i) {

new Timer("timer - " + i).schedule(new TimerTask() {

@Override

public void run() {

println(Thread.currentThread().getName() + " run ");

}

}, 1000);

}

}

2. Quartz 定时器实现

//首先我们需要定义一个任务类,比如为MyJob02 ,

//该类需要继承Job类,然后添加execute(JobExecutionContext context)方法,在

//这个方法中就是我们具体的任务执行的地方。

//由希望由调度程序执行的组件实现的接口

public class MyJob02 implements Job {

@Override

public void execute(JobExecutionContext context) throws JobExecutionException {

// TODO Auto-generated method stub

// 执行响应的任务.

System.out.println("HelloJob.execute,"+new Date());

}

}

public class QuartzTest5 {

public static void main(String[] args) throws Exception {

//SchedulerFactory 是一个接口,用于Scheduler的创建和管理

SchedulerFactory factory = new StdSchedulerFactory();

//从工厂里面拿到一个scheduler实例

//计划表(可能翻译的不太贴切),现在我们有了要做的内容,

//与调度程序交互的主要API

/*

* Scheduler的生命期,从SchedulerFactory创建它时开始,

到Scheduler调用shutdown()方法时结束;Scheduler被创建后,

可以增加、删除和列举Job和Trigger,以及执行其它与调度相关的操作

(如暂停Trigger)。但是,Scheduler只有在调用start()方法后,

才会真正地触发trigger(即执行job)

*/

Scheduler scheduler = factory.getScheduler();

//具体任务.

//用于定义作业的实例

//JobBuilder - 用于定义/构建JobDetail实例,用于定义作业的实例。

JobDetail job = JobBuilder.newJob(MyJob.class).withIdentity("job1", "group1").build();

//Trigger(即触发器) - 定义执行给定作业的计划的组件

//TriggerBuilder - 用于定义/构建触发器实例

CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")

.withSchedule(CronScheduleBuilder.cronSchedule("0/1? * * * * ?")).build();

scheduler.scheduleJob(job, trigger);

scheduler.start();

}

3. Spring? boot 任务调度(这个非常容易实现)

/*

*? 开启对定时任务的支持

*? 在相应的方法上添加@Scheduled声明需要执行的定时任务。

*/

@EnableScheduling

//@EnableScheduling注解来开启对计划任务的支持

public class Application {

public static void main(String[] args) {

SpringApplication.run(Application.class, args);

}

}

@Component

public class ScheduledTasks {

private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class);

private??? int???? i=0;

//0 0 0 2 * ?

@Scheduled(cron="*? *? *? 2? *? ?")

//@Scheduled 注解用于标注这个方法是一个定时任务的方法

public void testFixDelay() {

logger.info("执行方法"+i++);

}

java怎么用定时任务实现失效

1、ZSet 实现方式

通过 ZSet 实现定时任务的思路是,将定时任务存放到 ZSet 集合中,并且将过期时间存储到 ZSet 的 Score 字段中,然后通过一个无线循环来判断当前时间内是否有需要执行的定时任务,如果有则进行执行,具体实现代码如下:

import redis.clients.jedis.Jedis;

import utils.JedisUtils;

import java.time.Instant;

import java.util.Set;

public class DelayQueueExample {

private static final String _KEY = "DelayQueueExample";

public static void main(String[] args) throws InterruptedException {

Jedis jedis = JedisUtils.getJedis();

// 30s 后执行

long delayTime = Instant.now().plusSeconds(30).getEpochSecond();

jedis.zadd(_KEY, delayTime, "order_1");

// 继续添加测试数据

jedis.zadd(_KEY, Instant.now().plusSeconds(2).getEpochSecond(), "order_2");

jedis.zadd(_KEY, Instant.now().plusSeconds(2).getEpochSecond(), "order_3");

jedis.zadd(_KEY, Instant.now().plusSeconds(7).getEpochSecond(), "order_4");

jedis.zadd(_KEY, Instant.now().plusSeconds(10).getEpochSecond(), "order_5");

// 开启定时任务队列

doDelayQueue(jedis);

}

/**

* 定时任务队列消费

* @param jedis Redis 客户端

*/

public static void doDelayQueue(Jedis jedis) throws InterruptedException {

while (true) {

// 当前时间

Instant nowInstant = Instant.now();

long lastSecond = nowInstant.plusSeconds(-1).getEpochSecond();

// 上一秒时间

long nowSecond = nowInstant.getEpochSecond();

// 查询当前时间的所有任务

Set data = jedis.zrangeByScore(_KEY, lastSecond, nowSecond);

for (String item : data) {

// 消费任务

System.out.println("消费:" + item);

}

// 删除已经执行的任务

jedis.zremrangeByScore(_KEY, lastSecond, nowSecond);

Thread.sleep(1000); // 每秒查询一次

}

}

}

登录后复制

?

2、键空间通知

我们可以通过 Redis 的键空间通知来实现定时任务,它的实现思路是给所有的定时任务设置一个过期时间,等到了过期之后,我们通过订阅过期消息就能感知到定时任务需要被执行了,此时我们执行定时任务即可。

默认情况下 Redis 是不开启键空间通知的,需要我们通过 config set notify-keyspace-events Ex 的命令手动开启,开启之后定时任务的代码如下

java定时任务没十分钟执行一次,成功就不执行了

题主问的是java定时任务没十分钟执行一次,成功就不执行了是什么原因?是系统故障的问题。

java定时任务没十分钟执行一次,成功就不执行了是系统故障的问题,主要是任务最外面没有用try-catch 捕捉,或者是任务执行时,遇到了Uncaught Exception,导致这个定时任务停止执行了。

java是一种计算机编程语言,拥有跨平台,面向对象,泛型编程的特性,广泛应用于企业级Web应用开发和移动应用开发,任职于太阳微系统的詹姆斯·高斯林等人于1990年代初开发Java语言的雏形,最初被命名为Oak,目标设置在家用电器等小型系统的程序语言。

java定时任务保存首月的车辆分析报告怎么实现

java定时任务保存首月的车辆分析报告在Timer接口中实现。java定时任务保存首月的车辆分析报告实现方法

1、首先,Timer接口中,字段是非常核心重要的。

2、接着,这个TimerThread类其实是Timer的一个内部类,它继承了Thread并重写了其run方法,该线程实例将在构建Timer实例的时候被启动,即可实现java定时任务保存首月的车辆分析报告。

java定时任务没有执行完又到执行时间了

代码错误。多数是代码错误导致java定时任务没有执行完又到执行时间了。

1、首先打开java检查代码是否错误。

2、其次打开网络诊断器进行测试网络连接是否异常。

3、最后点击重新运行java即可。

java 怎么写定时任务

如果要执行一些简单的定时器任务,无须做复杂的控制,也无须保存状态,那么可以考虑使用JDK 入门级的定期器Timer来执行重复任务。

一、原理

JDK中,定时器任务的执行需要两个基本的类:

java.util.Timer;

java.util.TimerTask;

要运行一个定时任务,最基本的步骤如下:

1、建立一个要执行的任务TimerTask。

2、创建一个Timer实例,通过Timer提供的schedule()方法,将 TimerTask加入到定时器Timer中,同时设置执行的规则即可。

当程序执行了Timer初始化代码后,Timer定时任务就会按照设置去执行。

Timer中的schedule()方法是有多种重载格式的,以适应不同的情况。该方法的格式如下:

void schedule(TimerTask task, Date time)

安排在指定的时间执行指定的任务。

void schedule(TimerTask task, Date firstTime, long period)

安排指定的任务在指定的时间开始进行重复的固定延迟执行。

void schedule(TimerTask task, long delay)

安排在指定延迟后执行指定的任务。

void schedule(TimerTask task, long delay, long period)

安排指定的任务从指定的延迟后开始进行重复的固定延迟执行。

Timer是线程安全的,此类可扩展到大量同时安排的任务(存在数千个都没有问题)。其所有构造方法都启动计时器线程。可以调用cancel() 终止此计时器,丢弃所有当前已安排的任务。purge()从此计时器的任务队列中移除所有已取消的任务。此类不提供实时保证:它使用 Object.wait(long) 方法来安排任务。

TimerTask是一个抽象类,由 Timer 安排为一次执行或重复执行的任务。它有一个抽象方法run()----计时器任务要执行的操作。因此,每个具体的任务类都必须继承TimerTask类,并且重写run()方法。另外它还有两个非抽象的方法:

boolean cancel()

取消此计时器任务。

long scheduledExecutionTime()

返回此任务最近实际 执行的安排 执行时间。

二、例子

下面用Timer实现一个简单例子:

package stu.timer;

import java.util.Date;

import java.util.TimerTask;

/**

* 重复执行的任务

*

* @author leizhimin,2008-10-9 9:20:20

*/

public class TestTimerTask extends TimerTask {

/**

* 此计时器任务要执行的操作。

*/

public void run() {

Date executeTime = new Date(this.scheduledExecutionTime());

System.out.println("本次任务执行的时间是" + executeTime);

}

}

package stu.timer;

import java.util.Timer;

import java.util.TimerTask;

/**

* 测试JDK Timer的执行

*

* @author leizhimin,2008-10-9 9:24:35

*/

public class TestTimer {

public static void main(String[] args) {

Timer timer = new Timer();

TimerTask task = new TestTimerTask();

timer.schedule(task, 500L, 1000L);

}

}

运行结果:

本次任务执行的时间是Thu Oct 09 09:47:57 CST 2008

本次任务执行的时间是Thu Oct 09 09:47:58 CST 2008

本次任务执行的时间是Thu Oct 09 09:47:59 CST 2008

本次任务执行的时间是Thu Oct 09 09:48:00 CST 2008

本次任务执行的时间是Thu Oct 09 09:48:01 CST 2008

本次任务执行的时间是Thu Oct 09 09:48:02 CST 2008

本次任务执行的时间是Thu Oct 09 09:48:03 CST 2008

本次任务执行的时间是Thu Oct 09 09:48:04 CST 2008

本次任务执行的时间是Thu Oct 09 09:48:05 CST 2008

......

(责任编辑:IT教学网)

更多

推荐新手入门文章