使用redis锁解决集群时定时任务重复执行的问题

背景：
最近项目写了一个定时任务，因为该项目是集群的原因，会产生多台服务器同时执行，因为该定时任务有个发送邮件的动作，一开始使用的方法是properties配置文件中配置邮件发送人【执行的服务器对应的properties就设置发件人，不执行的服务器就设置为空，再在定时任务中获取配置文件的发件人，当发件人为空时就不执行定时任务了】但是以后若有新的定时任务还是会出现重复执行的问题，为了解决这个问题使用了redis锁

Redis更多用法请参考：https://blog.csdn.net/Abysscarry/article/details/80557347

以下内容只是方便我的使用而写的

1. 添加redis依赖 ：

    org.springframework.boot
    spring-boot-starter-data-redis

2.配置redis：

spring:
  redis:
    database: 0
    host: 140.143.23.94
    password: 123
    port: 6379
    timeout: 3000       # 连接超时时间 单位 ms（毫秒）
#    cluster:
#      nodes: 10.3.1.4:7000,10.3.1.4:7001,...,10.3.1.4:7008
    pool:
      max-idle: 8       # 连接池中的最大空闲连接，默认值也是8
      min-idle: 0       # 连接池中的最小空闲连接，默认值也是0
      max-active: 8     # 如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
      max-wait: -1      # 等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出

选择Redis合适的API：
如果k-v都是String类型，我们可以直接用 StringRedisTemplate，这个是官方建议的，也是最方便的，直接导入即用，无需多余配置！
如果k-v是Object类型，则需要自定义 RedisTemplate

3. 定时任务+ redis锁 （操作redis的更多用法可参考原文）：

package xxx.schedule;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Slf4j
@Service
public class TestScheduler {
    @Autowired
    StringRedisTemplate redisTemplate;

    @Value("${server.port}") //properties文件中定义服务端口
    String port;
    
    @Scheduled(cron = "0 */1 * * * ?") //1分钟执行一次
    public void process() {
        if(exists("testScheduler")){
            log.info("****被端口为：" + get("testScheduler") + "的服务抢先执行了任务........");
            return;
        }
        log.info("*****************执行定时任务********");
        set("testScheduler", port, 7*10L); //设置名为testScheduler参数，值为properties文件中取的端口号，存活70秒
    }


    
    public Object get(final String key){
        Object result = null;
        try {
            ValueOperations operations = redisTemplate.opsForValue();
            result = operations.get(key);
        } catch (Exception e) {
            log.error("读取redis缓存失败！错误信息为：" + e.getMessage());
        }
        return result;
    }

    
    public boolean set(final String key, String value, Long expire){
        boolean result = false;
        try {
            ValueOperations operations = redisTemplate.opsForValue();
            operations.set(key, value);
            redisTemplate.expire(key, expire, TimeUnit.SECONDS);
            result = true;
        } catch (Exception e) {
            log.error("写入redis缓存（设置expire存活时间）失败！错误信息为：" + e.getMessage());
        }
        return result;
    }

    
    public boolean exists(final String key){
        boolean result = false;
        try {
            result = redisTemplate.hasKey(key);
        } catch (Exception e) {
            log.error("判断redis缓存中是否有对应的key失败！错误信息为：" + e.getMessage());
        }
        return result;
    }
}