Java實現(xiàn)定時任務最簡單的3種方法
一、Timer
Timer是JAVA自帶的定時任務類，實現(xiàn)如下：
public class MyTimerTask {
public static void main(String[] args) {
// 定義一個任務
TimerTask timerTask = new TimerTask() {
@Override
public void run() {
System.out.println("打印當前時間：" + new Date());
}
};
// 計時器
Timer timer = new Timer();
// 開始執(zhí)行任務 (延遲1000毫秒執(zhí)行，每3000毫秒執(zhí)行一次)
timer.schedule(timerTask, 1000, 3000);
}
}Timer 優(yōu)缺點分析
優(yōu)點是使用簡單，缺點是當添加并執(zhí)行多個任務時，前面任務的執(zhí)行用時和異常將影響到后面任務，這邊深海建議謹慎使用。
二、ScheduledExecutorService
ScheduledExecutorService 也是Java自帶的類，
它可以實現(xiàn)Timer具備的所有功能，并解決了 Timer類存在的問題。
實現(xiàn)如下：
public class MyScheduledExecutorService {
public static void main(String[] args) {
// 創(chuàng)建任務隊列 10 為線程數量
ScheduledExecutorService scheduledExecutorService =
Executors.newScheduledThreadPool(10);
// 執(zhí)行任務
scheduledExecutorService.scheduleAtFixedRate(() -> {
System.out.println("打印當前時間：" + new Date());
}, 1, 3, TimeUnit.SECONDS); // 1s 后開始執(zhí)行，每 3s 執(zhí)行一次
}
}ScheduledExecutorService 優(yōu)缺點分析
優(yōu)點是，該類是JDK1.5自帶的類，使用簡單，缺點是該方案僅適用于單機環(huán)境。
三、Spring Task
Spring系列框架中Spring Framework自帶的定時任務，
使用上面兩種方式，很難實現(xiàn)某些特定需求，比如每周一執(zhí)行某任務，但SpringTask可輕松實現(xiàn)。
以SpringBoot為例來實現(xiàn)：
1、開啟定時任務
在SpringBoot的啟動類上聲明 @EnableScheduling：
@SpringBootApplication
@EnableScheduling //開啟定時任務
public class DemoApplication {
// -- --
}2、添加定時任務
只需使用@Scheduled注解標注即可，
如果有多個定時任務，可以創(chuàng)建多個@Scheduled標注的方法，示例如下：
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component // 把此類托管給 Spring，不能省略
public class TaskUtils {
// 添加定時任務
@Scheduled(cron = "30 40 23 0 0 5") // cron表達式：每周一 23:40:30 執(zhí)行
public void doTask(){
System.out.println("我是定時任務~");
}
}Spring Boot 啟動后會自動加載并執(zhí)行定時任務，無需手動操作。
Cron 表達式
Spring Task 的實現(xiàn)需要使用 cron 表達式來聲明執(zhí)行的頻率和規(guī)則，cron 表達式是由 6 位或者 7 位組成的(最后一位可以省略)，每位之間以空格分隔，每位從左到右代表的含義如下：
其中 * 和 ? 號都表示匹配所有的時間。
cron 表達式在線生成地址：https://cron.qqe2.com/
知識擴展：分布式定時任務
上面的方法都是關于單機定時任務的實現(xiàn)，如果是分布式環(huán)境可以使用 Redis 來實現(xiàn)定時任務。
使用 Redis 實現(xiàn)延遲任務的方法大體可分為兩類：通過 ZSet 的方式和鍵空間通知的方式。
1、ZSet 實現(xiàn)方式
通過 ZSet 實現(xiàn)定時任務的思路是，將定時任務存放到 ZSet 集合中，并且將過期時間存儲到 ZSet 的 Score 字段中，然后通過一個無線循環(huán)來判斷當前時間內是否有需要執(zhí)行的定時任務，如果有則進行執(zhí)行，具體實現(xiàn)代碼如下：
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 后執(zhí)行
long delayTime = Instant.now().plusSeconds(30).getEpochSecond();
jedis.zadd(_KEY, delayTime, "order_1");
// 繼續(xù)添加測試數據
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);
}
// 刪除已經執(zhí)行的任務
jedis.zremrangeByScore(_KEY, lastSecond, nowSecond);
Thread.sleep(1000); // 每秒查詢一次
}
}
}2、鍵空間通知
我們可以通過 Redis 的鍵空間通知來實現(xiàn)定時任務，它的實現(xiàn)思路是給所有的定時任務設置一個過期時間，等到了過期之后，我們通過訂閱過期消息就能感知到定時任務需要被執(zhí)行了，此時我們執(zhí)行定時任務即可。
默認情況下 Redis 是不開啟鍵空間通知的，需要我們通過 config set notify-keyspace-events Ex 的命令手動開啟，開啟之后定時任務的代碼如下：
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;
import utils.JedisUtils;
public class TaskExample {
public static final String _TOPIC = "__keyevent@0__:expired"; // 訂閱頻道名稱
public static void main(String[] args) {
Jedis jedis = JedisUtils.getJedis();
// 執(zhí)行定時任務
doTask(jedis);
}
/**
* 訂閱過期消息，執(zhí)行定時任務
* @param jedis Redis 客戶端
*/
public static void doTask(Jedis jedis) {
// 訂閱過期消息
jedis.psubscribe(new JedisPubSub() {
@Override
public void onPMessage(String pattern, String channel, String message) {
// 接收到消息，執(zhí)行定時任務
System.out.println("收到消息：" + message);
}
}, _TOPIC);
}
}總結
到此這篇關于Java實現(xiàn)定時任務最簡單的3種方法的文章就介紹到這了,更多相關Java定時任務實現(xiàn)內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹了SpringBoot文件上傳大小設置方式(yml中配置)，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
這篇文章主要介紹了SpringBoot Admin使用及心跳檢測原理分析，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
這篇文章主要介紹了java遞歸法求字符串逆序,涉及java遞歸調用的相關操作技巧,需要的朋友可以參考下2015-05-05
springboot 中整合mybatis多數據源不使用JPA
這篇文章主要介紹了springboot 中整合mybatis多數據源不使用JPA，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-08-08
這篇文章主要介紹了MyBatis中如何查詢某個時間段內的數據，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-08-08
這篇文章主要介紹了lombok插件無法使用的原因及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-08-08
spring-boot整合dubbo:Spring-boot-dubbo-starter
這篇文章主要介紹了spring-boot整合dubbo:Spring-boot-dubbo-starter的相關資料,非常不錯，具有參考借鑒價值，需要的朋友可以參考下2017-05-05
這篇文章主要介紹了Java的Lock接口與讀寫鎖詳解,鎖是用來控制多個線程訪問共享資源的方式,一般來說,一個鎖能夠防止多個線程同時訪問共享資源,但是有些鎖可以允許多個線程并發(fā)的訪問共享資源,比如讀寫鎖,需要的朋友可以參考下2023-12-12
這篇文章主要為大家介紹了kafka分布式消息系統(tǒng)基本架構及功能詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-03-03
文件處理是任何應用程序的重要部分,Java 提供了許多用于創(chuàng)建、讀取、更新和刪除文件的方法,這篇文章主要給大家介紹了關于認識文件與Java中操作文件的相關資料,需要的朋友可以參考下2024-05-05