1、设置分布式锁

/**     * 设置redis 分布式锁     * @param lockName     * @param acquireTimeout     * @param lockTimeout     * @return     */    public String acquireDistributedLockWithTimeout(String lockName, long acquireTimeout, int lockTimeout) {        String lockValue = UUID.randomUUID().toString();        String lockKey = "lock:" + lockName;        long acquireTime = System.currentTimeMillis() + acquireTimeout;        ValueOperations ops = this.redisTemplate.opsForValue();        while(acquireTime > System.currentTimeMillis()) {            boolean locked = ops.setIfAbsent(lockKey, lockValue);            if (locked) {                this.redisTemplate.expire(lockKey, (long)lockTimeout, TimeUnit.SECONDS);                return lockValue;            }            try {                TimeUnit.MILLISECONDS.sleep(1L);            } catch (InterruptedException var12) {                Thread.currentThread().interrupt();            }        }        return null;    }

2、释放redis分布式锁

/**     * 释放redis锁     * @param lockName     * @param lockValue     * @return     */    public boolean releaseDistributedLock(String lockName, String lockValue) {        String lockKey = "lock:" + lockName;        List

3、定时逻辑

　　　　 //集群环境 定时任务加锁，保证执行一次 异常情况6个小时 释放锁        String lock = redisService.acquireDistributedLockWithTimeout("incomeStatistics", 10, 60*60*6);        //判断是否获得锁        if(StringUtils.isNotBlank(lock)){            logger.info("定时任务 开始执行");            try{                //业务逻辑                                            }catch (Exception e){               //异常处理            }            finally {                //释放锁                redisService.releaseDistributedLock("incomeStatistics",lock);            }        }