您好,登錄后才能下訂單哦!
這篇文章主要介紹了springboot怎么實(shí)現(xiàn)多實(shí)例crontab搶占定時(shí)任務(wù),具有一定借鑒價(jià)值,感興趣的朋友可以參考下,希望大家閱讀完這篇文章之后大有收獲,下面讓小編帶著大家一起了解一下。
利用redisson實(shí)現(xiàn)多實(shí)例搶占定時(shí)任務(wù)
pom.xml
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.12.0</version> </dependency>
Kernel.java - 重寫多線程調(diào)度
package com.brand.log.scheduler; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.config.ScheduledTaskRegistrar; import java.util.concurrent.Executors; @Configuration public class Kernel implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { //設(shè)定一個(gè)長度10的定時(shí)任務(wù)線程池 taskRegistrar.setScheduler(Executors.newScheduledThreadPool(4)); } }
RedissonManager.java - 分布式鎖的實(shí)現(xiàn)
package com.brand.log.util; import lombok.extern.slf4j.Slf4j; import org.redisson.Redisson; import org.redisson.config.Config; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; @Component @Slf4j public class RedissonManager { @Value("${spring.redis.host}") private String host; @Value("${spring.redis.port}") private int port; private Redisson redisson = null; private Config config = new Config(); @PostConstruct private void init() { try { config.useSingleServer().setAddress("redis://" + host + ":" + port); log.info("redisson address {} {}", host, port); redisson = (Redisson) Redisson.create(config); log.info("Redisson 初始化完成"); } catch (Exception e) { log.error("init Redisson error ", e); } } public Redisson getRedisson() { return redisson; } }
CronSynData.java
package com.brand.log.scheduler; import com.brand.log.util.DateFormatV1; import com.brand.log.util.RedisUtil; import com.brand.log.util.RedissonManager; import lombok.extern.slf4j.Slf4j; import org.redisson.Redisson; import org.redisson.api.RLock; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.util.concurrent.TimeUnit; @Component @Slf4j public class CronSynData { @Autowired RedissonManager redissonManager; @Autowired RedisUtil redisUtil; @Autowired DateFormatV1 dateFormatV1; private String lokFlag = ".handleKernel"; private Redisson redisson = null; /* * java定時(shí)腳本掛靠實(shí)例 * 多實(shí)例會有重復(fù)調(diào)用問題 + 使用Redisson實(shí)現(xiàn)分布式鎖 * 業(yè)務(wù)邏輯必須加鎖 + 且需要保證 tryLock 等待時(shí)間小于cron的最小間隔執(zhí)行時(shí)間 * */ @Scheduled(cron = "*/10 * * * * *") public void handleKernel() { redisson = redissonManager.getRedisson(); if (redisson != null) { RLock lock = redisson.getLock(this.getClass().getName() + lokFlag); Boolean stat = false; try { // 嘗試加鎖,立即返回,最多等待5s自動解鎖 stat = lock.tryLock(0, 5, TimeUnit.SECONDS); if (stat) { log.info("{} 取鎖成功!{}",this.getClass().getName(), Thread.currentThread().getName()); redisUtil.checkCount("log:limit_", dateFormatV1.getDate("HH", "GMT+8"), 60*10, 1000); } else { log.info("{}沒有獲取到鎖:{}", this.getClass().getName(), Thread.currentThread().getName()); } } catch (InterruptedException e) { log.error("Redisson 獲取分布式鎖異常", e); if (!stat){ return; } lock.unlock(); } } } }
kibana - 6個(gè)實(shí)例
感謝你能夠認(rèn)真閱讀完這篇文章,希望小編分享的“springboot怎么實(shí)現(xiàn)多實(shí)例crontab搶占定時(shí)任務(wù)”這篇文章對大家有幫助,同時(shí)也希望大家多多支持億速云,關(guān)注億速云行業(yè)資訊頻道,更多相關(guān)知識等著你來學(xué)習(xí)!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。