这篇文章主要介绍了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抢占定时任务”这篇文章对大家有帮助，同时也希望大家多多支持创新互联，关注创新互联行业资讯频道，更多相关知识等着你来学习!
