SpringBoot使用SchedulingConfigurer實現(xiàn)多個定時任務(wù)多機器部署問題(推薦)
更新時間：2023年01月05日 11:34:50 作者：小志的博客
這篇文章主要介紹了SpringBoot使用SchedulingConfigurer實現(xiàn)多個定時任務(wù)多機器部署問題,定時任務(wù)多機器部署解決方案，方式一拆分，單獨拆分出來，單獨跑一個應(yīng)用，方式二是基于aop攔截處理（搶占執(zhí)行），只要有一個執(zhí)行，其它都不執(zhí)行，需要的朋友可以參考下
一、使用SchedulingConfigurer實現(xiàn)多個定時任務(wù)
二、定時任務(wù)多機器部署解決方案
- 方式一：拆分，單獨拆分出來，單獨跑一個應(yīng)用
- 方式二：基于aop攔截處理（搶占執(zhí)行），只要有一個執(zhí)行，其它都不執(zhí)行（前提：服務(wù)器時間一致）
三、基于redis實現(xiàn)的代碼示例
3.1、基于redis實現(xiàn)的概述
定時任務(wù)Aop一樣可以處理的，多臺同個任務(wù)類似搶占，先搶到的則打標(biāo)識記錄在Redis中,根據(jù)有無標(biāo)識去執(zhí)行任務(wù)
3.2、基于redis實現(xiàn)的代碼
在使用SchedulingConfigurer實現(xiàn)多個定時任務(wù)的示例基礎(chǔ)上（即此博文鏈接的基礎(chǔ)上）進(jìn)行新增代碼
3.2.1、代碼目錄結(jié)構(gòu)
目錄結(jié)構(gòu)如下圖：
3.2.2、引入依賴包
pom文件引入依賴包
<!-- Redis 配置 排除默認(rèn)啟動-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<exclusions>
<exclusion>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</exclusion>
</exclusions>
</dependency>
<!--redis連接池-->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
<version>2.9.0</version>
</dependency>
<!--jedis-->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
<!--aspectj-->
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.9.7</version>
</dependency>3.2.3、配置文件新增redis連接配置
application.yml配置文件配置
upload:
#每天幾點幾分執(zhí)行
taskOnecron: 0 25 22 ? * *
#每2分鐘執(zhí)行一次
taskTwocron: 0 0/2 * * * ?
spring:
redis:
#數(shù)據(jù)庫索引
database: 0
host: 127.0.0.1
port: 6379
password:
jedis:
pool:
#最大連接數(shù)
max-active: 8
#最大阻塞等待時間(負(fù)數(shù)表示沒限制)
max-wait: -1
#最大空閑
max-idle: 8
#最小空閑
min-idle: 0
#連接超時時間
timeout: 100003.2.4、自定義redis鎖注解類
自定義redis鎖注解
package com.xz.jdk11.schedule.aop;
import java.lang.annotation.*;
import java.util.concurrent.TimeUnit;
/**
* @author xz
* @description 自定義redis鎖注解
*/
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
@Documented
public @interface RedisLock {
//鎖前綴
String lockPrefix() default "SCHEDULE_REDISLOCK:";
//鍵
String lockKey() default "";
//默認(rèn)超時時間（秒）
long TimeOut() default 60;
//默認(rèn)超時時間單位 （秒）
TimeUnit timeUtil() default TimeUnit.SECONDS;
}3.2.5、自定義redis切面類（即aop類）
redis切面類
package com.xz.jdk11.schedule.aop;
import cn.hutool.core.util.StrUtil;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.lang.reflect.Method;
import java.util.HashMap;
import java.util.Map;
/**
* @author xz
* @description redis鎖切面
*/
@Aspect
@Component
public class RedisLockAspect {
private static final Logger log = LoggerFactory.getLogger(RedisLock.class);
//最大重試次數(shù)
private static final Integer MAX_RETRY_COUNT=3;
//鎖前綴
private static final String LOCK_PRE_FIX="lockPreFix";
//鍵
private static final String LOCK_KEY="lockKey";
//超時時間
private static final String TIME_OUT="timeOut";
//保護時間 2*2^11 =4096
private static final int PROTECT_TIME= 2 << 11;
@Autowired
private CommonRedisHelper commonRedisHelper;
//切點
@Pointcut("@annotation(com.xz.jdk11.schedule.aop.RedisLock)")
public void RedisLockAspect(){
}
//通知
@Around(value="RedisLockAspect()")
public void lockRoundAction(ProceedingJoinPoint proceeding){
//獲取redis鎖
boolean flag = this.getLock(proceeding, 0, System.currentTimeMillis());
if(flag){
try {
proceeding.proceed();
Thread.sleep(PROTECT_TIME);
} catch (Throwable e) {
throw new RuntimeException("定時任務(wù)======>>>redis分布式鎖執(zhí)行發(fā)生異常："+e.getMessage(),e);
}finally {
//刪除鎖
this.delLock(proceeding);
}
}else{
log.info("定時任務(wù)======>>>其他服務(wù)器正在執(zhí)行此定時任務(wù)");
}
}
/**
* 獲取鎖
*/
private boolean getLock(ProceedingJoinPoint proceeding,int count,long currentTime){
//獲取鎖參數(shù)
Map<String, Object> annotationArgs = this.getAnnotationArgs(proceeding);
String lockPreFix = (String) annotationArgs.get(LOCK_PRE_FIX);
String lockKey = (String) annotationArgs.get(LOCK_KEY);
long timeOut = (Long) annotationArgs.get(TIME_OUT);
if(StrUtil.isEmpty(lockPreFix) || StrUtil.isEmpty(lockKey)){
throw new RuntimeException("定時任務(wù)======>>>RedisLock 鎖前綴（LOCK_PRE_FIX）或者鎖名（LOCK_KEY）未設(shè)置");
}
if(commonRedisHelper.setNx(lockPreFix,lockKey,timeOut)){
log.info("定時任務(wù)======>>>RedisLock:{}線程，已獲取到鎖",Thread.currentThread().getName());
return true;
}else{
//如果當(dāng)前時間與鎖的時間差，大于保護時間，則強制刪除鎖（防止死鎖）
long creatTime = commonRedisHelper.getLockValue(lockPreFix, lockKey);
if((currentTime - creatTime) >timeOut * 1000 + PROTECT_TIME){
count ++;
if(count > MAX_RETRY_COUNT){
return false;
}
commonRedisHelper.delete(lockPreFix,lockKey);
getLock(proceeding,count,currentTime);
}
log.info("定時任務(wù)======>>>正在執(zhí)行定時任務(wù)key：{}",lockKey);
log.info("定時任務(wù)======>>>RedisLock===={}線程，獲取鎖失敗",Thread.currentThread().getName());
return false;
}
}
/**
* 刪除鎖
*/
private void delLock(ProceedingJoinPoint proceedingJoinPoint){
//獲取鎖參數(shù)
Map<String, Object> annotationArgs = this.getAnnotationArgs(proceedingJoinPoint);
String lockPreFix = (String) annotationArgs.get(LOCK_PRE_FIX);
String lockKey = (String) annotationArgs.get(LOCK_KEY);
//刪除鎖
commonRedisHelper.delete(lockPreFix,lockKey);
}
/**
* 獲取鎖參數(shù)
* @param proceeding
* */
public Map<String,Object> getAnnotationArgs(ProceedingJoinPoint proceeding){
Class<?> target = proceeding.getTarget().getClass();
//獲取所有方法
Method[] methods = target.getMethods();
//獲取方法名稱
String methodName = proceeding.getSignature().getName();
for(Method method:methods){
if(method.getName().equals(methodName)){
HashMap<String, Object> hashMap = new HashMap<>();
RedisLock redisLock = method.getAnnotation(RedisLock.class);
hashMap.put(LOCK_PRE_FIX,redisLock.lockPrefix());
hashMap.put(LOCK_KEY,redisLock.lockKey());
hashMap.put(TIME_OUT,redisLock.timeUtil().toSeconds(redisLock.TimeOut()));
return hashMap;
}
}
return new HashMap<>();
}
}
3.2.6、自定義redis命令操作類
redis命令操作類
package com.xz.jdk11.schedule.aop;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
/**
* @author xz
* @description redis命令操作類
*/
@Component
public class CommonRedisHelper {
@Autowired
RedisTemplate<Object,Object> redisTemplate;
/**
* 添加分布式鎖
* */
public boolean setNx(String track,String sector,long timeout){
boolean flag =false;
ValueOperations<Object, Object> valueOperations = redisTemplate.opsForValue();
flag=valueOperations.setIfAbsent(track+sector,System.currentTimeMillis());
if(flag){
valueOperations.set(track+sector,getLockValue(track,sector),timeout, TimeUnit.SECONDS);
}
return flag;
}
/**
* 刪除鎖
* @param lockPreFix 前綴
* @param key 鍵
* */
public void delete(String lockPreFix,String key){
redisTemplate.delete(lockPreFix+key);
}
/**
* 查詢鎖
* @return 寫鎖時間
* */
public long getLockValue(String track,String sector){
return (long) redisTemplate.opsForValue().get(track+sector);
}
}
3.2.7、在定時任務(wù)一中添加自定義注解
定時任務(wù)一中添加自定義注解，如下圖：
完整代碼如下：
package com.xz.jdk11.schedule;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.util.Calendar;
/**
* @author xz
* @description 定時任務(wù)一（每天幾點幾分執(zhí)行）
*/
@Slf4j
@Component
public class TaskOne implements BaskTask{
@Value("${upload.taskOnecron}")
private String taskOnecron;
@Override
public String getCron() {
return taskOnecron;
}
@Override
public void execute() {
log.info("定時任務(wù)一（每天幾點幾分執(zhí)行一次）,執(zhí)行開始時間：{}",Calendar.getInstance().getTime());
}
@Override
@RedisLock(lockKey = "run",TimeOut = 60)
public void run() {
execute();
}
}
3.2.8、在定時任務(wù)二中添加自定義注解
定時任務(wù)二中添加自定義注解，如下圖：
完整代碼如下：
package com.xz.jdk11.schedule;
import com.xz.jdk11.schedule.aop.RedisLock;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.util.Calendar;
/**
* @author xz
* @description 定時任務(wù)一（每幾分鐘執(zhí)行一次，共執(zhí)行幾次）
*/
@Slf4j
@Component
public class TaskTwo implements BaskTask{
@Value("${upload.taskTwocron}")
private String taskTwocron;
@Override
public String getCron() {
return taskTwocron;
}
@Override
public void execute() {
log.info("定時任務(wù)二：每幾分鐘執(zhí)行一次,執(zhí)行開始時間：{}", Calendar.getInstance().getTime());
}
@Override
@RedisLock(lockKey = "run",TimeOut = 60)
public void run() {
execute();
}
}3.3、本地嘗試運行springboot項目查看輸出結(jié)果
輸出結(jié)果如下所示：
到此這篇關(guān)于SpringBoot使用SchedulingConfigurer實現(xiàn)多個定時任務(wù)多機器部署問題的文章就介紹到這了,更多相關(guān)SpringBoot多個定時任務(wù)多機器部署內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
mybatis整合spring實現(xiàn)開啟mapper.xml映射文件掃描
這篇文章主要介紹了mybatis整合spring實現(xiàn)開啟mapper.xml映射文件掃描，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-10-10
如何通過java實現(xiàn)highcharts導(dǎo)出圖片至excel
這篇文章主要介紹了如何通過java實現(xiàn)highcharts導(dǎo)出圖片至excel。文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，下面我們就來一起學(xué)習(xí)一下吧2019-06-06
Java實現(xiàn)實時視頻轉(zhuǎn)播的代碼示例
這篇文章主要給大家詳細(xì)介紹了Java如何實現(xiàn)實時視頻轉(zhuǎn)播,文中通過代碼實例介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴可以自己動手試一試2023-09-09
Mybatis的Mapper代理對象生成及調(diào)用過程示例詳解
這篇文章主要為大家介紹了Mybatis的Mapper代理對象生成及調(diào)用過程示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-09-09
這篇文章主要為大家詳細(xì)介紹了java實現(xiàn)IP地址轉(zhuǎn)換，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-11-11
這篇文章主要介紹了springBoot使用JdbcTemplate代碼實例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-09-09
Spring Boot中數(shù)據(jù)庫操作Druid和HikariDataSource的詳細(xì)過程
這篇文章主要介紹了Spring Boot中數(shù)據(jù)庫操作Druid和HikariDataSource的詳細(xì)過程,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-06-06
在SpringBoot項目當(dāng)中，我們要想配置一個屬性，可以通過這三種方式當(dāng)中的任意一種來配置都可以，那么優(yōu)先級怎么算，本文主要介紹了一問詳解SpringBoot配置文件優(yōu)先級，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
SpringSecurity整合jwt權(quán)限認(rèn)證的全流程講解
這篇文章主要介紹了SpringSecurity整合jwt權(quán)限認(rèn)證的全流程講解，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-06-06
本篇文章主要介紹了spring與disruptor集成的簡單示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-02-02