| | |
|---|
| | | import java.util.concurrent.atomic.AtomicInteger; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * XxlJob开发示例（Bean模式） |
|---|
| | | * <p> |
|---|
| | | * 开发步骤： |
|---|
| | | * 1、在Spring Bean实例中，开发Job方法，方式格式要求为 "public ReturnT<String> execute(String param)" |
|---|
| | | * 2、为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。 |
|---|
| | | * 3、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志； |
|---|
| | | * |
|---|
| | | * @author xuxueli |
|---|
| | | * @PROJECT_NAME: skjcmanager |
|---|
| | | * @DESCRIPTION: 执行器相关 |
|---|
| | | * @USER: aix |
|---|
| | | * @DATE: 2023/5/13 14:53 |
|---|
| | | */ |
|---|
| | | @Component |
|---|
| | | public class SampleXxlJob { |
|---|
| | |
|---|
| | | return ReturnT.SUCCESS; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 给巡查责任人定时创建任务执行器 |
|---|
| | | * @param param |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | @XxlJob("createTaskJobHandler") |
|---|
| | | public ReturnT<String> createTaskJobHandler(String param) throws Exception { |
|---|
| | | XxlJobLogger.log("开始自动创建任务..."); |
|---|
