快速集成

1. 在 SpringBoot 工程中添加依赖（需要提前将 jar 包打入私服）

<dependency>    <groupId>top.panson</groupId>    <artifactId>argo-core</artifactId>    <version>0.0.1-SNAPSHOT</version></dependency>

2. mysql 中执行 sql

CREATETABLE `argo_task` (`id`bigintNOT NULL AUTO_INCREMENT COMMENT'主键⾃增',`task_id`varchar(500) CHARACTERSET utf8mb4 COLLATE utf8mb4_general_ciNOT NULL COMMENT'⽤户⾃定义的任务名称，如果没有则使⽤⽅法签名',`task_status`intNOT NULL DEFAULT'0' COMMENT'执⾏状态',`execute_times`intNOT NULL COMMENT'执⾏次数',`execute_time`bigintNOT NULL COMMENT'执⾏时间',`parameter_types`varchar(255) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ciNOT NULL COMMENT'参数的类路径名称',`method_name`varchar(100) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ciNOT NULL COMMENT'⽅法名',`method_sign_name`varchar(200) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ciNOT NULL DEFAULT'' COMMENT'⽅法签名',`execute_interval_sec`intNOT NULL DEFAULT'60' COMMENT'执⾏间隔秒',`delay_time`intNOT NULL DEFAULT'60' COMMENT'延迟时间：单位秒',`task_parameter`varchar(200) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ciNOT NULL DEFAULT'' COMMENT'任务参数',`performance_way`intNOT NULL COMMENT'执⾏模式：1、⽴即执⾏ 2、调度执⾏',`thread_way`intNOT NULL COMMENT'线程模型 1、异步 2、同步',`error_msg`varchar(200) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ciNOT NULL DEFAULT'' COMMENT'执⾏的error信息',`alert_expression`varchar(100) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ci DEFAULTNULL COMMENT'告警表达式',`alert_action_bean_name`varchar(255) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ci DEFAULTNULL COMMENT'告警逻辑的的执⾏beanName',`fallback_class_name`varchar(255) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ci DEFAULTNULL COMMENT'降级逻辑的的类路径',`fallback_error_msg`varchar(200) CHARACTERSET utf8mb4 COLLATE            utf8mb4_general_ci DEFAULTNULL COMMENT'降级失败时的错误信息',`shard_key`bigint DEFAULT'0' COMMENT'任务分⽚键',`gmt_create` datetimeNOT NULL COMMENT'创建时间',`gmt_modified` datetimeNOT NULL COMMENT'修改时间',PRIMARY KEY (`id`),        UNIQUE KEY`uk_id_shard_key` (`id`,`shard_key`) USING BTREE) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

3. 在application.properties中添加以下配置

spring:  datasource:    url: jdbc:mysql://localhost:3306/task-engine?characterEncoding=utf8&characterSetResults=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false    username: root    password: your password    driver-class-name: com.mysql.cj.jdbc.Driver    hikari:      connection-timeout: 3000top:  panson:    argo:      parallel:        pool:          thread-max-pool-size: 6          thread-core-pool-size: 6          thread-pool-keep-alive-time: 60          thread-pool-keep-alive-time-unit: SECONDS          thread-pool-queue-size: 200      action:        fail-count-threshold: 0      shard:        task-sharded: false

4. 在启动类中加上EnableTendConsistencyTask 注解

@EnableTendConsistencyTask@EnableScheduling@SpringBootApplicationpublicclassApplication {publicstaticvoidmain(String[]args) {SpringApplication.run(Application.class,args);    }}

5. 在目标方法上(必须是 public 方法)加上@ConsistencyTask 注解

@ConsistencyTask(id ="testAction",executeIntervalSec =2,delayTime =5,performanceWay =PerformanceEnum.EXECUTE_RIGHT_NOW,threadWay =ThreadWayEnum.ASYNC,fallbackClass =SendMessageFallbackHandler.class,alertActionBeanName ="normalAlerter")publicvoidaction(CreateOrderRequestcreateOrderRequest) {}

6. 自定义任务重试查询逻辑

@ComponentpublicclassMyTaskTimeRangeQueryimplementsTaskTimeRangeQuery {/**    * 获取查询任务的初始时间 默认的开始时间为 查询12⼩时内的任务    *    * @return 启始时间    */@OverridepublicDategetStartTime() {returnDateUtils.getDateByDayNum(newDate(),Calendar.HOUR, -12);    }/**    * 获取查询任务的结束时间    *    * @return 结束时间    */@OverridepublicDategetEndTime() {returnnewDate();    }/**    * 每次最多查询出多少个未完成的任务出来    *    * @return 未完成的任务数量    */@OverridepublicLonglimitTaskCount() {return200L;    }}

top:panson:argo:parallel:pool:task-schedule-time-range-class-name:top.panson.argo.example.range.MyTaskTimeRangeQuery