• 分布式调度xxl-job实战应用解析

    分布式调度xxl-job实战应用解析今天分享，业务场景经常出现分布式定时任务情况，以前经常采用分布式锁解决，不过随着业务场景的复杂度变大，分布式锁的方案开始满足不了很多业务场景，因此这篇文章，我们重点分析实战使用：

    一、xxl-job 的服务端

    服务端集成mysql数据库，数据库初始化几张表，作用和分布式锁相关，数据库配置等等。

    1、数据库脚本

    1. CREATE database if NOT EXISTS `xxl-job` default character set utf8 collate utf8_general_ci;
    2. use `xxl-job`;
    3.  
    4.  
    5. CREATE TABLE XXL_JOB_QRTZ_JOB_DETAILS
    6.   (
    7.     SCHED_NAME VARCHAR(120) NOT NULL,
    8.     JOB_NAME  VARCHAR(200) NOT NULL,
    9.     JOB_GROUP VARCHAR(200) NOT NULL,
    10.     DESCRIPTION VARCHAR(250) NULL,
    11.     JOB_CLASS_NAME   VARCHAR(250) NOT NULL,
    12.     IS_DURABLE VARCHAR(1) NOT NULL,
    13.     IS_NONCONCURRENT VARCHAR(1) NOT NULL,
    14.     IS_UPDATE_DATA VARCHAR(1) NOT NULL,
    15.     REQUESTS_RECOVERY VARCHAR(1) NOT NULL,
    16.     JOB_DATA BLOB NULL,
    17.     PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
    18. );
    19.  
    20. CREATE TABLE XXL_JOB_QRTZ_TRIGGERS
    21.   (
    22.     SCHED_NAME VARCHAR(120) NOT NULL,
    23.     TRIGGER_NAME VARCHAR(200) NOT NULL,
    24.     TRIGGER_GROUP VARCHAR(200) NOT NULL,
    25.     JOB_NAME  VARCHAR(200) NOT NULL,
    26.     JOB_GROUP VARCHAR(200) NOT NULL,
    27.     DESCRIPTION VARCHAR(250) NULL,
    28.     NEXT_FIRE_TIME BIGINT(13) NULL,
    29.     PREV_FIRE_TIME BIGINT(13) NULL,
    30.     PRIORITY INTEGER NULL,
    31.     TRIGGER_STATE VARCHAR(16) NOT NULL,
    32.     TRIGGER_TYPE VARCHAR(8) NOT NULL,
    33.     START_TIME BIGINT(13) NOT NULL,
    34.     END_TIME BIGINT(13) NULL,
    35.     CALENDAR_NAME VARCHAR(200) NULL,
    36.     MISFIRE_INSTR SMALLINT(2) NULL,
    37.     JOB_DATA BLOB NULL,
    38.     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    39.     FOREIGN KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
    40.         REFERENCES XXL_JOB_QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP)
    41. );
    42.  
    43. CREATE TABLE XXL_JOB_QRTZ_SIMPLE_TRIGGERS
    44.   (
    45.     SCHED_NAME VARCHAR(120) NOT NULL,
    46.     TRIGGER_NAME VARCHAR(200) NOT NULL,
    47.     TRIGGER_GROUP VARCHAR(200) NOT NULL,
    48.     REPEAT_COUNT BIGINT(7) NOT NULL,
    49.     REPEAT_INTERVAL BIGINT(12) NOT NULL,
    50.     TIMES_TRIGGERED BIGINT(10) NOT NULL,
    51.     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    52.     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    53.         REFERENCES XXL_JOB_QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    54. );
    55.  
    56. CREATE TABLE XXL_JOB_QRTZ_CRON_TRIGGERS
    57.   (
    58.     SCHED_NAME VARCHAR(120) NOT NULL,
    59.     TRIGGER_NAME VARCHAR(200) NOT NULL,
    60.     TRIGGER_GROUP VARCHAR(200) NOT NULL,
    61.     CRON_EXPRESSION VARCHAR(200) NOT NULL,
    62.     TIME_ZONE_ID VARCHAR(80),
    63.     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    64.     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    65.         REFERENCES XXL_JOB_QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    66. );
    67.  
    68. CREATE TABLE XXL_JOB_QRTZ_SIMPROP_TRIGGERS
    69.   (          
    70.     SCHED_NAME VARCHAR(120) NOT NULL,
    71.     TRIGGER_NAME VARCHAR(200) NOT NULL,
    72.     TRIGGER_GROUP VARCHAR(200) NOT NULL,
    73.     STR_PROP_1 VARCHAR(512) NULL,
    74.     STR_PROP_2 VARCHAR(512) NULL,
    75.     STR_PROP_3 VARCHAR(512) NULL,
    76.     INT_PROP_1 INT NULL,
    77.     INT_PROP_2 INT NULL,
    78.     LONG_PROP_1 BIGINT NULL,
    79.     LONG_PROP_2 BIGINT NULL,
    80.     DEC_PROP_1 NUMERIC(13,4) NULL,
    81.     DEC_PROP_2 NUMERIC(13,4) NULL,
    82.     BOOL_PROP_1 VARCHAR(1) NULL,
    83.     BOOL_PROP_2 VARCHAR(1) NULL,
    84.     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    85.     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) 
    86.     REFERENCES XXL_JOB_QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    87. );
    88.  
    89. CREATE TABLE XXL_JOB_QRTZ_BLOB_TRIGGERS
    90.   (
    91.     SCHED_NAME VARCHAR(120) NOT NULL,
    92.     TRIGGER_NAME VARCHAR(200) NOT NULL,
    93.     TRIGGER_GROUP VARCHAR(200) NOT NULL,
    94.     BLOB_DATA BLOB NULL,
    95.     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    96.     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    97.         REFERENCES XXL_JOB_QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    98. );
    99.  
    100. CREATE TABLE XXL_JOB_QRTZ_CALENDARS
    101.   (
    102.     SCHED_NAME VARCHAR(120) NOT NULL,
    103.     CALENDAR_NAME  VARCHAR(200) NOT NULL,
    104.     CALENDAR BLOB NOT NULL,
    105.     PRIMARY KEY (SCHED_NAME,CALENDAR_NAME)
    106. );
    107.  
    108. CREATE TABLE XXL_JOB_QRTZ_PAUSED_TRIGGER_GRPS
    109.   (
    110.     SCHED_NAME VARCHAR(120) NOT NULL,
    111.     TRIGGER_GROUP  VARCHAR(200) NOT NULL, 
    112.     PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP)
    113. );
    114.  
    115. CREATE TABLE XXL_JOB_QRTZ_FIRED_TRIGGERS
    116.   (
    117.     SCHED_NAME VARCHAR(120) NOT NULL,
    118.     ENTRY_ID VARCHAR(95) NOT NULL,
    119.     TRIGGER_NAME VARCHAR(200) NOT NULL,
    120.     TRIGGER_GROUP VARCHAR(200) NOT NULL,
    121.     INSTANCE_NAME VARCHAR(200) NOT NULL,
    122.     FIRED_TIME BIGINT(13) NOT NULL,
    123.     SCHED_TIME BIGINT(13) NOT NULL,
    124.     PRIORITY INTEGER NOT NULL,
    125.     STATE VARCHAR(16) NOT NULL,
    126.     JOB_NAME VARCHAR(200) NULL,
    127.     JOB_GROUP VARCHAR(200) NULL,
    128.     IS_NONCONCURRENT VARCHAR(1) NULL,
    129.     REQUESTS_RECOVERY VARCHAR(1) NULL,
    130.     PRIMARY KEY (SCHED_NAME,ENTRY_ID)
    131. );
    132.  
    133. CREATE TABLE XXL_JOB_QRTZ_SCHEDULER_STATE
    134.   (
    135.     SCHED_NAME VARCHAR(120) NOT NULL,
    136.     INSTANCE_NAME VARCHAR(200) NOT NULL,
    137.     LAST_CHECKIN_TIME BIGINT(13) NOT NULL,
    138.     CHECKIN_INTERVAL BIGINT(13) NOT NULL,
    139.     PRIMARY KEY (SCHED_NAME,INSTANCE_NAME)
    140. );
    141.  
    142. CREATE TABLE XXL_JOB_QRTZ_LOCKS
    143.   (
    144.     SCHED_NAME VARCHAR(120) NOT NULL,
    145.     LOCK_NAME  VARCHAR(40) NOT NULL, 
    146.     PRIMARY KEY (SCHED_NAME,LOCK_NAME)
    147. );
    148.  
    149.  
    150.  
    151. CREATE TABLE `XXL_JOB_QRTZ_TRIGGER_INFO` (
    152.   `id` int(11) NOT NULL AUTO_INCREMENT,
    153.   `job_group` int(11) NOT NULL COMMENT '执行器主键ID',
    154.   `job_cron` varchar(128) NOT NULL COMMENT '任务执行CRON',
    155.   `job_desc` varchar(255) NOT NULL,
    156.   `add_time` datetime DEFAULT NULL,
    157.   `update_time` datetime DEFAULT NULL,
    158.   `author` varchar(64) DEFAULT NULL COMMENT '作者',
    159.   `alarm_email` varchar(255) DEFAULT NULL COMMENT '报警邮件',
    160.   `executor_route_strategy` varchar(50) DEFAULT NULL COMMENT '执行器路由策略',
    161.   `executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
    162.   `executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',
    163.   `executor_block_strategy` varchar(50) DEFAULT NULL COMMENT '阻塞处理策略',
    164.   `executor_timeout` int(11) NOT NULL DEFAULT '0' COMMENT '任务执行超时时间，单位秒',
    165.   `executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',
    166.   `glue_type` varchar(50) NOT NULL COMMENT 'GLUE类型',
    167.   `glue_source` mediumtext COMMENT 'GLUE源代码',
    168.   `glue_remark` varchar(128) DEFAULT NULL COMMENT 'GLUE备注',
    169.   `glue_updatetime` datetime DEFAULT NULL COMMENT 'GLUE更新时间',
    170.   `child_jobid` varchar(255) DEFAULT NULL COMMENT '子任务ID，多个逗号分隔',
    171.   PRIMARY KEY (`id`)
    172. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    173.  
    174. CREATE TABLE `XXL_JOB_QRTZ_TRIGGER_LOG` (
    175.   `id` int(11) NOT NULL AUTO_INCREMENT,
    176.   `job_group` int(11) NOT NULL COMMENT '执行器主键ID',
    177.   `job_id` int(11) NOT NULL COMMENT '任务，主键ID',
    178.   `executor_address` varchar(255) DEFAULT NULL COMMENT '执行器地址，本次执行的地址',
    179.   `executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
    180.   `executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',
    181.   `executor_sharding_param` varchar(20) DEFAULT NULL COMMENT '执行器任务分片参数，格式如 1/2',
    182.   `executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',
    183.   `trigger_time` datetime DEFAULT NULL COMMENT '调度-时间',
    184.   `trigger_code` int(11) NOT NULL COMMENT '调度-结果',
    185.   `trigger_msg` text COMMENT '调度-日志',
    186.   `handle_time` datetime DEFAULT NULL COMMENT '执行-时间',
    187.   `handle_code` int(11) NOT NULL COMMENT '执行-状态',
    188.   `handle_msg` text COMMENT '执行-日志',
    189.   `alarm_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '告警状态：0-默认、1-无需告警、2-告警成功、3-告警失败',
    190.   PRIMARY KEY (`id`),
    191.   KEY `I_trigger_time` (`trigger_time`),
    192.   KEY `I_handle_code` (`handle_code`)
    193. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    194.  
    195. CREATE TABLE `XXL_JOB_QRTZ_TRIGGER_LOGGLUE` (
    196.   `id` int(11) NOT NULL AUTO_INCREMENT,
    197.   `job_id` int(11) NOT NULL COMMENT '任务，主键ID',
    198.   `glue_type` varchar(50) DEFAULT NULL COMMENT 'GLUE类型',
    199.   `glue_source` mediumtext COMMENT 'GLUE源代码',
    200.   `glue_remark` varchar(128) NOT NULL COMMENT 'GLUE备注',
    201.   `add_time` timestamp NULL DEFAULT NULL,
    202.   `update_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP,
    203.   PRIMARY KEY (`id`)
    204. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    205.  
    206. CREATE TABLE XXL_JOB_QRTZ_TRIGGER_REGISTRY (
    207.   `id` int(11) NOT NULL AUTO_INCREMENT,
    208.   `registry_group` varchar(255) NOT NULL,
    209.   `registry_key` varchar(255) NOT NULL,
    210.   `registry_value` varchar(255) NOT NULL,
    211.   `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    212.   PRIMARY KEY (`id`)
    213. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    214.  
    215. CREATE TABLE `XXL_JOB_QRTZ_TRIGGER_GROUP` (
    216.   `id` int(11) NOT NULL AUTO_INCREMENT,
    217.   `app_name` varchar(64) NOT NULL COMMENT '执行器AppName',
    218.   `title` varchar(12) NOT NULL COMMENT '执行器名称',
    219.   `order` tinyint(4) NOT NULL DEFAULT '0' COMMENT '排序',
    220.   `address_type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '执行器地址类型：0=自动注册、1=手动录入',
    221.   `address_list` varchar(512) DEFAULT NULL COMMENT '执行器地址列表，多地址逗号分隔',
    222.   PRIMARY KEY (`id`)
    223. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    224.  
    225.  
    226. INSERT INTO `XXL_JOB_QRTZ_TRIGGER_GROUP`(`id`, `app_name`, `title`, `order`, `address_type`, `address_list`) VALUES (1, 'xxl-job-executor-sample', '示例执行器', 1, 0, NULL);
    227. INSERT INTO `XXL_JOB_QRTZ_TRIGGER_INFO`(`id`, `job_group`, `job_cron`, `job_desc`, `add_time`, `update_time`, `author`, `alarm_email`, `executor_route_strategy`, `executor_handler`, `executor_param`, `executor_block_strategy`, `executor_timeout`, `executor_fail_retry_count`, `glue_type`, `glue_source`, `glue_remark`, `glue_updatetime`, `child_jobid`) VALUES (1, 1, '0 0 0 * * ? *', '测试任务1', '2018-11-03 22:21:31', '2018-11-03 22:21:31', 'XXL', '', 'FIRST', 'demoJobHandler', '', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2018-11-03 22:21:31', '');
    228.  
    229. commit;
    230.

    执行后

     

     

    2、springBoot服务引用相关jar

    其实直接拉取源码就行：GitHub - xuxueli/xxl-job: A distributed task scheduling framework.（分布式任务调度平台XXL-JOB）

    1. <dependency>
    2. 			<groupId>org.springframework.bootgroupId>
    3. 			<artifactId>spring-boot-starter-webartifactId>
    4. 		dependency>
    5. 		<dependency>
    6. 			<groupId>org.springframework.bootgroupId>
    7. 			<artifactId>spring-boot-starter-freemarkerartifactId>
    8. 		dependency>
    9. 		<dependency>
    10. 			<groupId>org.springframework.bootgroupId>
    11. 			<artifactId>spring-boot-starter-mailartifactId>
    12. 		dependency>
    13. 		<dependency>
    14. 			<groupId>org.mybatis.spring.bootgroupId>
    15. 			<artifactId>mybatis-spring-boot-starterartifactId>
    16. 			<version>${mybatis-spring-boot-starter.version}version>
    17. 		dependency>
    18. 		
    19. 		<dependency>
    20. 			<groupId>mysqlgroupId>
    21. 			<artifactId>mysql-connector-javaartifactId>
    22. 			<version>${mysql-connector-java.version}version>
    23. 		dependency>
    24. 		
    25. 		<dependency>
    26. 			<groupId>org.quartz-schedulergroupId>
    27. 			<artifactId>quartzartifactId>
    28. 			<version>${quartz.version}version>
    29. 		dependency>
    30. 		
    31. 		<dependency>
    32. 			<groupId>com.xuxueligroupId>
    33. 			<artifactId>xxl-job-coreartifactId>
    34. 			<version>2.0.2version>
    35. 		dependency>

    3、配置文件相关

    1. ### web
    2. server.port=8080
    3. server.context-path=/xxl-job-admin
    4.  
    5. ### resources
    6. spring.mvc.static-path-pattern=/static/**
    7. spring.resources.static-locations=classpath:/static/
    8.  
    9. ### freemarker
    10. spring.freemarker.templateLoaderPath=classpath:/templates/
    11. spring.freemarker.suffix=.ftl
    12. spring.freemarker.charset=UTF-8
    13. spring.freemarker.request-context-attribute=request
    14. spring.freemarker.settings.number_format=0.##########
    15.  
    16. ### mybatis
    17. mybatis.mapper-locations=classpath:/mybatis-mapper/*Mapper.xml
    18.  
    19. ### xxl-job, datasource
    20. #spring.datasource.url=jdbc:mysql://192.168.43.174:3306/xxl-job?Unicode=true&characterEncoding=UTF-8&useSSL=false
    21. spring.datasource.url=jdbc:mysql://192.168.43.174:3306/xxl-job?Unicode=true&characterEncoding=UTF-8&useSSL=false
    22. spring.datasource.username=root
    23. spring.datasource.password=root
    24. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    25.  
    26. spring.datasource.type=org.apache.tomcat.jdbc.pool.DataSource
    27. spring.datasource.tomcat.max-wait=10000
    28. spring.datasource.tomcat.max-active=30
    29. spring.datasource.tomcat.test-on-borrow=true
    30. spring.datasource.tomcat.validation-query=SELECT 1
    31. spring.datasource.tomcat.validation-interval=30000
    32.  
    33. ### xxl-job email
    34. spring.mail.host=smtp.qq.com
    35. spring.mail.port=25
    36. spring.mail.username=xxx@qq.com
    37. spring.mail.password=xxx
    38. spring.mail.properties.mail.smtp.auth=true
    39. spring.mail.properties.mail.smtp.starttls.enable=true
    40. spring.mail.properties.mail.smtp.starttls.required=true
    41.  
    42.  
    43. ### xxl-job login
    44. xxl.job.login.username=admin
    45. xxl.job.login.password=123456
    46.  
    47. ### xxl-job, access token
    48. xxl.job.accessToken=
    49.  
    50. ### xxl-job, i18n (default empty as chinese, "en" as english)
    51. xxl.job.i18n=

    4、启动服务

    1. package com.xxl.job.admin;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5.  
    6. /**
    7.  * @author xuxueli 2018-10-28 00:38:13
    8.  */
    9. @SpringBootApplication
    10. public class XxlJobAdminApplication {
    11.  
    12. 	public static void main(String[] args) {
    13.         SpringApplication.run(XxlJobAdminApplication.class, args);
    14. 	}
    15.  
    16. }

    启动后访问web控制台：http://localhost:8080/xxl-job-admin

    点击登录

     

     5、点击任务管理器

    点击编辑看看以前注册的三台客户端

     

    也可以删除xxl-enjoy 执行器，重写添加；

    添加前两个参数就行

     

      6、点击任务管理查看以前注册的

    选择nandao,查看其状态

    点击编辑

       点击新增任务

    7、点击调度日志

     查看成功的日志的详情

     

    查看失败的日志的详情

     

    如图

     

    这种失败是因为没有添加配置执行器导致的。 

    8、新增任务

    这种编辑动态代码的模式，相当于直接修改生产环境的代码。保存后：

     

     点击GLUE编辑

     把自己测试好的业务代码粘贴进里面，点击保存

     备注

    点击关闭后就可以执行测试了

     

    查看客户端结果

     9、新增分片的业务

    保存后，点击执行测试

    参数

      结果 

     二、xxl-job的客户端

    1、springboot 项目 pom配置

    1.    
    2.         <dependency>
    3.             <groupId>com.xuxueligroupId>
    4.             <artifactId>xxl-job-coreartifactId>
    5.             <version>2.0.2version>
    6.         dependency>

    2、配置文件、

    1. ### 调度器的地址----- 发消息
    2. xxl.job.admin.addresses=http://localhost:8080/xxl-job-admin
    3. ### 当前执行器的标识名称，同一个名字的执行器构成集群
    4. xxl.job.executor.appname=xxl-enjoy
    5. # 执行器与调度器通信的ip / port
    6. xxl.job.executor.ip=
    7. #启动多个服务可以暂时改动端口号
    8. xxl.job.executor.port=9991
    9. ### job-job, access token
    10. xxl.job.accessToken=
    11. ### job-job log path
    12. xxl.job.executor.logpath=/logs/xxl/job
    13. ### job-job log retention days
    14. xxl.job.executor.logretentiondays=-1
    15.  
    16. #启动多个服务可以改端口号
    17. server.port=8281

    3、客户端配置分布式调度

    1.  
    2.  
    3. import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
    4. import org.slf4j.Logger;
    5. import org.slf4j.LoggerFactory;
    6. import org.springframework.beans.factory.annotation.Value;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.ComponentScan;
    9. import org.springframework.context.annotation.Configuration;
    10.  
    11. @Configuration
    12. @ComponentScan(basePackages = "com.xxl.job.executor.service.jobhandler")
    13. public class XxlConfig {
    14.     private Logger logger = LoggerFactory.getLogger(XxlConfig.class);
    15.  
    16.     @Value("${xxl.job.admin.addresses}")
    17.     private String adminAddresses;
    18.  
    19.     @Value("${xxl.job.executor.appname}")
    20.     private String appName;
    21.  
    22.     @Value("${xxl.job.executor.ip}")
    23.     private String ip;
    24.  
    25.     @Value("${xxl.job.executor.port}")
    26.     private int port;
    27.  
    28.     @Value("${xxl.job.accessToken}")
    29.     private String accessToken;
    30.  
    31.     @Value("${xxl.job.executor.logpath}")
    32.     private String logPath;
    33.  
    34.     @Value("${xxl.job.executor.logretentiondays}")
    35.     private int logRetentionDays;
    36.  
    37.  
    38.     @Bean(initMethod = "start", destroyMethod = "destroy")
    39.     public XxlJobSpringExecutor xxlJobExecutor() {
    40.         logger.info(">>>>>>>>>>> job-job config init.");
    41.         XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
    42.         xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
    43.         xxlJobSpringExecutor.setAppName(appName);
    44.         xxlJobSpringExecutor.setIp(ip);
    45.         xxlJobSpringExecutor.setPort(port);
    46.         xxlJobSpringExecutor.setAccessToken(accessToken);
    47.         xxlJobSpringExecutor.setLogPath(logPath);
    48.         xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
    49.  
    50.         return xxlJobSpringExecutor;
    51.     }
    52.  
    53. }

    4、任务核心

    1.  
    2.  
    3. import org.springframework.stereotype.Service;
    4.  
    5. @Service
    6. public class EnjoyBusiness {
    7.  
    8. 	/**
    9. 	 * index指示，现在跑的是第几片
    10. 	 * total指示，总共有几片
    11.      */
    12. 	public void process(int index,int total,String param) {
    13. 		if (total == 1){
    14. 			System.out.println("当前执行全业务处理,参数："+param);
    15. 			return;
    16. 		}
    17.  
    18. 		//分片任务
    19. 		if (index == 1 ){
    20. 			// select * from xxx limit 0,500
    21. 		} else {
    22. 			// select * from xxx limit 500,1000
    23. 		}
    24.  
    25. 		System.out.println("当前执行第 "+(index+1)+"/"+total+"片的数据,参数："+param);
    26. 	}
    27.  
    28. }

    5、三种job类型

    常规的

    1.  
    2.  
    3. import com.enjoy.business.EnjoyBusiness;
    4. import com.xxl.job.core.biz.model.ReturnT;
    5. import com.xxl.job.core.handler.IJobHandler;
    6. import com.xxl.job.core.handler.annotation.JobHandler;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.stereotype.Component;
    9.  
    10. /**
    11.  * 普通任务
    12.  */
    13. @JobHandler(value="enjoySimple") //value值对应的是调度中心新建任务的JobHandler
    14. @Component
    15. public class EnjoySimple extends IJobHandler {
    16.  
    17. 	@Autowired
    18. 	private EnjoyBusiness enjoyBusiness;
    19.  
    20. 	@Override
    21. 	public ReturnT<String> execute(String param) throws Exception {
    22. 		enjoyBusiness.process(1,1,param);
    23. 		return SUCCESS;
    24. 	}
    25.  
    26. }

    分片的

    1.  
    2.  
    3. import com.enjoy.business.EnjoyBusiness;
    4. import com.xxl.job.core.biz.model.ReturnT;
    5. import com.xxl.job.core.handler.IJobHandler;
    6. import com.xxl.job.core.handler.annotation.JobHandler;
    7. import com.xxl.job.core.util.ShardingUtil;
    8. import org.springframework.beans.factory.annotation.Autowired;
    9. import org.springframework.stereotype.Service;
    10.  
    11. /**
    12.  * 分片任务
    13.  */
    14. @JobHandler(value="enjoySharding")
    15. @Service
    16. public class EnjoySharding extends IJobHandler {
    17. 	@Autowired
    18. 	private EnjoyBusiness enjoyBusiness;
    19.  
    20. 	@Override
    21. 	public ReturnT<String> execute(String param) throws Exception {
    22. 		ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
    23.  
    24. 		int index = shardingVO.getIndex();
    25. 		int total = shardingVO.getTotal();
    26. 		enjoyBusiness.process(index,total,param);
    27.  
    28. 		return SUCCESS;
    29. 	}
    30.  
    31. }

    动态修改的

    1.  
    2.  
    3. import com.xxl.job.core.biz.model.ReturnT;
    4. import com.xxl.job.core.handler.IJobHandler;
    5.  
    6. public class EnjoyGlue extends IJobHandler {
    7.     public ReturnT<String> execute(String param) throws Exception {
    8.         System.out.println("测试GLUE任务，我已被执行");
    9.         return SUCCESS;
    10.     }
    11. }

    6、boot的启动类

    1. package com.enjoy;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.context.annotation.ComponentScan;
    6.  
    7. @SpringBootApplication
    8. public class XxlJobApp {
    9.  
    10. 	public static void main(String[] args) {
    11.         SpringApplication.run(XxlJobApp.class, args);
    12. 	}
    13.  
    14. }

    其他两个代码一样，类名不同而已。 

    7、依次启动三个客户端，启动时注意修改相关端口号

    相关端口映射

     

     8、演示到此，服务端和客户端的连接演示基本功能流程到此结束。下篇我们分析elastic-job敬请期待！

    另外xxl-job官方相关文档可参考：参考

  • 相关阅读:
    科研常用网站汇总
    笔记：电子设备接地，接的到底是什么地？
    ShardingJDBC：适配OceanBase
    SuperMap 是个什么鬼
    计算机毕设（附源码）JAVA-SSM基于渐进式网页应用的大众社交软件
    搭建RabbitMQ消息服务，整合SpringBoot实现收发消息
    JAVA_SSM+VUE校园二手物品交易平台(含论文)源码
    冒泡排序详解
    阿里也出手了！Spring CloudAlibaba AI问世了
    【说透Redis】如何解决Redis缓存雪崩、击穿与穿透
  • 原文地址：https://blog.csdn.net/nandao158/article/details/126103066