SchedulerLock分布式定时任务锁
1.pom中引入依赖,这里使用redis作为锁
(图片来源网络,侵删)
net.javacrumbs.shedlock shedlock-spring 4.12.0 net.javacrumbs.shedlock shedlock-provider-redis-spring 4.12.0
2.yml配置redis连接
spring: redis: host: localhost port: 6379 database: 0 taskrelease: taskrelease
3.配置redis序列化
@Configuration public class RedisConfig { @Bean public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate redisTemplate = new RedisTemplate(); redisTemplate.setConnectionFactory(redisConnectionFactory); // 使用Jackson2JsonRedisSerialize 替换默认序列化 Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper objectMapper = new ObjectMapper(); objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); jackson2JsonRedisSerializer.setObjectMapper(objectMapper); // 设置value的序列化规则和 key的序列化规则 redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.afterPropertiesSet(); return redisTemplate; } }
4.线程池和分布式锁配置
import lombok.extern.slf4j.Slf4j; import net.javacrumbs.shedlock.core.LockProvider; import net.javacrumbs.shedlock.provider.redis.spring.RedisLockProvider; import net.javacrumbs.shedlock.spring.annotation.EnableSchedulerLock; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; import org.springframework.scheduling.config.ScheduledTaskRegistrar; import javax.annotation.Resource; import java.util.concurrent.ExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor; @EnableSchedulerLock(defaultLockAtMostFor = "PT30M") @Slf4j @Configuration public class ScheduleConfig implements SchedulingConfigurer { @Resource ExecutorService scheduledThreadPoolExecutor; /** * */ @Bean public ThreadPoolTaskExecutor threadPoolTaskExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); //最大线程数 executor.setMaxPoolSize(8); //核心线程数 executor.setCorePoolSize(8); //任务队列的大小 executor.setQueueCapacity(100); //线程前缀名 executor.setThreadNamePrefix("common-"); //线程存活时间 executor.setKeepAliveSeconds(30); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy()); //线程初始化 executor.initialize(); return executor; } /** * 动态调度任务线程池 */ @Bean public ThreadPoolTaskScheduler threadPoolTaskScheduler() { ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); // 线程池大学 threadPoolTaskScheduler.setPoolSize(15); // 线程名称 threadPoolTaskScheduler.setThreadNamePrefix("taskScheduler-"); // 等待时长 threadPoolTaskScheduler.setAwaitTerminationSeconds(60); // 调度器shutdown被调用时等待当前被调度的任务完成 threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true); return threadPoolTaskScheduler; } /** * Schedule定时任务指定线程池 * Spring注解 */ @Bean(name = "scheduledThreadPoolExecutor") public ScheduledThreadPoolExecutor scheduledThreadPoolExecutor() { return new ScheduledThreadPoolExecutor(15); } @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { //显式为Scheduler指定线程池 taskRegistrar.setScheduler(scheduledThreadPoolExecutor); } /** * 分布式锁 * Schedule定时任务, Spring注解 */ @Bean public LockProvider lockProvider(RedisConnectionFactory connectionFactory) { return new RedisLockProvider(connectionFactory, System.getProperty("spring.profiles.active")); } }
5.执行任务方法
@Scheduled(cron = "0 0 23 * * ?") @SchedulerLock(name = "synchronizeAddDept", lockAtLeastFor = "PT15S") public void synchronizeAddDept() { StopWatch watch = new StopWatch(); watch.start(); log.info("====================> 同步部门数据开始, {}", LocalDateTime.now()); watch.stop(); log.info("====================> 同步部门数据结束, {}, 用时 {}", LocalDateTime.now(), watch.getTotalTimeSeconds()); }
文章版权声明:除非注明,否则均为主机测评原创文章,转载或复制请以超链接形式并注明出处。