使用redisson控制多个springboot实例负载同时只有一个实例执行任务

一 redisson依赖

<!--        redisson 依赖-->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson-spring-boot-starter</artifactId>
            <version>3.23.4</version>
        </dependency>

二定时任务代码

package com.hzf.work.task;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

/**
 * @author: hzf
 * @create: 2024-01-25 10:11
 **/
@Component
@Slf4j
@RequiredArgsConstructor
public class TestTask {
    @Value("${server.port}")
    private Integer port;
    private final RedissonClient redissonClient;
//    private final TestService test;

    @Scheduled(fixedRate = 5000) //每5秒执行一次
    public void sayHello() throws InterruptedException {
//        定义分布式锁名称
        String locaName = "hzf";
        LocalDateTime now = LocalDateTime.now();
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        String format = now.format(formatter);
//        获取分布式锁
        RLock lock = redissonClient.getLock(locaName);
        try {
            if (lock.tryLock()) {
                //模拟任务执行时间
                Thread.sleep(4000);
                System.out.println(format + "  port" + port);
            } else {
                //没有获取到锁,说明其他服务正在执行定时任务
                System.out.println("未获取到所,其他服务正在执行定时任务");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (lock.tryLock()) {
                lock.unlock();
            }
        }
    }

}