这篇文章主要介绍了springboot怎么实现多实例crontab抢占定时任务,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。
创新互联于2013年开始,是专业互联网技术服务公司,拥有项目成都网站制作、成都做网站网站策划,项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命,1280元孟村做网站,已为上家服务,为孟村各地企业和个人服务,联系电话:18982081108
利用redisson实现多实例抢占定时任务
pom.xml
org.redisson redisson 3.12.0
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; @Configuration public class Kernel implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { //设定一个长度10的定时任务线程池 taskRegistrar.setScheduler(Executors.newScheduledThreadPool(4)); } }
RedissonManager.java - 分布式锁的实现
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定时脚本挂靠实例 * 多实例会有重复调用问题 + 使用Redisson实现分布式锁 * 业务逻辑必须加锁 + 且需要保证 tryLock 等待时间小于cron的最小间隔执行时间 * */ @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怎么实现多实例crontab抢占定时任务”这篇文章对大家有帮助,同时也希望大家多多支持创新互联,关注创新互联行业资讯频道,更多相关知识等着你来学习!