集群部署项目时，Spring Task的坑大家一定要注意

这篇具有很好参考价值的文章主要介绍了集群部署项目时，Spring Task的坑大家一定要注意。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

一. 通过Spring Task执行定时任务

1.创建定时任务

我们要在下面的代码中，实现每5秒钟执行一个打印信息的任务。

package com.qfedu.day85.task;

import org.redisson.api.RedissonClient;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.Date;

@Component
public class PrintTask {

// 任务默认同步执行的
@Async // 表示异步执行的注解
// 每分钟的第5秒触发定时任务
@Scheduled(cron = "5 * * * * ?")
public void printInfo() {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.SSS");
System.out.println(sdf.format(new Date()) + ": print info test");
}
}

2.启动同一个项目的多个实例

首先我们可以通过“Edit Configurations”，增加一个运行实例的配置。

集群部署项目时，Spring Task的坑大家一定要注意,Java,spring,java,后端

接着启动项目的多个实例即可，如下图所示：

集群部署项目时，Spring Task的坑大家一定要注意,Java,spring,java,后端

3.查看执行结果

然后我们就可以查看上面代码的执行结果了，如下图：

集群部署项目时，Spring Task的坑大家一定要注意,Java,spring,java,后端

通过对比执行结果，我们会发现，有两个实例"同时"执行了任务。实际开发中，我们的项目经常会进行集群部署，但是，如果我们通过Spring Task来执行定时任务，只需要一个实例执行任务即可。

那么，如果我们不想有多个实例同时执行任务，需要怎么办呢？

一般我们可以借助分布式锁对任务进行加锁，防止多个实例同时执行任务。

但这样做，真的可以吗？

二. 定时任务中使用分布式锁

1.通过Redisson对任务加锁

加锁后的代码如下：

package com.qfedu.day85.task;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.TimeUnit;

@Component
public class PrintTask {
// 注入RedissonClient 对象
@Resource
private RedissonClient redissonClient;

@Async
@Scheduled(cron = "0/5 * * * * ?")
public void printInfo2() {
// 获取锁对象，参数表示redis中key值
RLock taskLock = redissonClient.getLock("taskLock");

try {
// 尝试加锁，
// 第一个参数，表示加锁的重试时间，如果锁被占用，在指定时间内尝试加锁
// 第二个参数，表示锁过期时间
// 返回true/false
// 本例中，第一个参数是0，表示如果没有加上锁，直接返回false
if (taskLock.tryLock(0, 10, TimeUnit.SECONDS)) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
System.out.println(sdf.format(new Date()) + ": print info test");
// Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
if (taskLock.isLocked()) {
// 判断是否当前线程拥有该锁
if (taskLock.isHeldByCurrentThread()) {
// 释放锁
taskLock.unlock();
}
}
}
}
}

本例，不讨论Redisson的使用。