ShedLock的使用

通常，我们在公司里的部分对外服务都是多集群多节点部署的。同时我们可能一些拆分的不是很细的服务，里面混杂着一些定时任务。

而定时任务中，有些业务为了防止同一时间并发操作，我们就用到了“分布式锁”。
一般最简单的方法我们就是使用redis加锁机制来实现分布式锁。
这里我我们使用ShedLock来在定时任务中实现分布式锁。

maven

        <dependency><groupId>net.javacrumbs.shedlock</groupId><artifactId>shedlock-spring</artifactId><version>4.3.0</version></dependency><dependency><groupId>net.javacrumbs.shedlock</groupId><artifactId>shedlock-provider-redis-jedis</artifactId><version>4.3.0</version></dependency>

配置LockProvider

单节点测试

    @Beanpublic JedisPool createJedisCluster() {// 因为我是本地测试的代码，所以使用的是jedisPoolJedisCluster jedisCluster = new JedisCluster(hostAndPorts);JedisPool jedisPool = new JedisPool();return jedisPool;}@Beanpublic LockProvider createLockProvider(JedisPool jedisPool) {JedisLockProvider jedisLockProvider = new JedisLockProvider(jedisPool);return jedisLockProvider;}

集群测试

    @Beanpublic JedisCluster createJedisCluster() {HashSet<HostAndPort> hostAndPorts = new HashSet<>();hostAndPorts.add(new HostAndPort("ip", port));JedisCluster jedisCluster = new JedisCluster(hostAndPorts);return jedisCluster;}@Beanpublic LockProvider createLockProvider(JedisCluster jedisCluster) {JedisLockProvider jedisLockProvider = new JedisLockProvider(jedisCluster);return jedisLockProvider;}

开启SchedLock

@SpringBootApplication
@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")
public class Application {public static void main(String[] args) {SpringApplication.run(SpringApplication.class, args);}
}

创建定时任务

@Component
class BaeldungTaskScheduler {@Scheduled(cron = "0 0/15 * * * ?")@SchedulerLock(name = "TaskScheduler_scheduledTask", lockAtLeastForString = "PT5M", lockAtMostForString = "PT14M")public void scheduledTask() {// ...}
}

参数说明

@SchedulerLock注解主要参数：
name：锁的名称，必须保证唯一；
lockAtMostFor：成功执行任务的节点所能拥有的独占锁的最长时间，设置的值要保证比定时任务正常执行完成的时间大一些；
lockAtLeastFor：成功执行任务的节点所能拥有的独占锁的最短时间，其主要目的是任务执行时间可能很短，防止多个节点执行。
@EnableSchedulerLock注解主要参数：
defaultLockAtMostFor：lockAtMostFor的默认时间；
defaultLockAtLeastFor：lockAtLeastFor的默认时间。