springboot實現(xiàn)多實例crontab搶占定時任務代碼分享

這篇文章主要介紹“springboot實現(xiàn)多實例crontab搶占定時任務代碼分享”，在日常操作中，相信很多人在springboot實現(xiàn)多實例crontab搶占定時任務代碼分享問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”springboot實現(xiàn)多實例crontab搶占定時任務代碼分享”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

利用redisson實現(xiàn)多實例搶占定時任務

pom.xml
<dependency>   <groupId>org.redisson</groupId>   <artifactId>redisson</artifactId>   <version>3.12.0</version></dependency>
Kernel.java - 重寫多線程調度
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;@Configurationpublic class Kernel implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {  //設定一個長度10的定時任務線程池  taskRegistrar.setScheduler(Executors.newScheduledThreadPool(4)); }}
RedissonManager.java - 分布式鎖的實現(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@Slf4jpublic 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@Slf4jpublic class CronSynData { @Autowired RedissonManager redissonManager; @Autowired RedisUtil redisUtil; @Autowired DateFormatV1 dateFormatV1; private String lokFlag = ".handleKernel"; private Redisson redisson = null; /* * java定時腳本掛靠實例 * 多實例會有重復調用問題 + 使用Redisson實現(xiàn)分布式鎖 * 業(yè)務邏輯必須加鎖 + 且需要保證 tryLock 等待時間小于cron的最小間隔執(zhí)行時間 * */ @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個實例

到此，關于“springboot實現(xiàn)多實例crontab搶占定時任務代碼分享”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關知識，請繼續(xù)關注億速云網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>