xxlJob 分布式定时任务

1.下载地址

https://github.com/xuxueli/xxl-job

2.打开项目，并创建xxl-job数据库

3.修改xxl-job-admin配置并启动

默认账号 admin 默认密码 123456

4. 配置springboot项目，注册到xxljob中

4.1 引入maven依赖

<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>2.3.0</version>
</dependency>

4.2 修改 application.yml

xxl:
  job:
    admin:
      ##注册到启动的xxljob服务中
      addresses: http://127.0.0.1:8888/xxl-job-admin
    accessToken: default_token
    executor:
      ##执行器名称
      appname: xxl-job-executor-sample
      ##监听端口  同一服务下端口不能重复
      port: 9999
      logpath: /data/applogs/xxl-job/jobhandler
      logretentiondays: 30
      address:
      ip: 127.0.0.1

4.3 增加config配置

@Configuration
public class XxlJobConfig {
          
   
    private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

    @Value("${xxl.job.admin.addresses}")
    private String adminAddresses;

    @Value("${xxl.job.accessToken}")
    private String accessToken;

    @Value("${xxl.job.executor.appname}")
    private String appname;

    @Value("${xxl.job.executor.address}")
    private String address;

    @Value("${xxl.job.executor.ip}")
    private String ip;

    @Value("${xxl.job.executor.port}")
    private int port;

    @Value("${xxl.job.executor.logpath}")
    private String logPath;

    @Value("${xxl.job.executor.logretentiondays}")
    private int logRetentionDays;


    @Bean
    public XxlJobSpringExecutor xxlJobExecutor() {
          
   
        logger.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
        xxlJobSpringExecutor.setAppname(appname);
        xxlJobSpringExecutor.setAddress(address);
        xxlJobSpringExecutor.setIp(ip);
        xxlJobSpringExecutor.setPort(port);
        xxlJobSpringExecutor.setAccessToken(accessToken);
        xxlJobSpringExecutor.setLogPath(logPath);
        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);

        return xxlJobSpringExecutor;
    }
}

4.4 增加任务处理器 新版本中取消了 @JobHandler 注解，采用了@XxlJob注解

@Component
public class SampleXxlJob {
          
   
    private static Logger logger = LoggerFactory.getLogger(SampleXxlJob.class);
    
    @XxlJob("demoJobHandler")
    public void demoJobHandler() throws Exception {
          
   
        String param = XxlJobHelper.getJobParam();//参数信息
        logger.info(param);
        XxlJobHelper.log("XXL-JOB, Hello World.");//日志打印会输出到任务里
    }
}

5. 将项目配置到 xxljob 中

5.1 配置执行器

5.2 配置任务 5.3 设置任务状态，也可以单独执行一次

5.4 查看日志信息 5.5 路由策略-分片广播 在任务管理中，路由策略都是在单个节点上执行，如果单个节点扛不住会产生事故，为了处理这种情况我们用到了分片广播，也就是所有的节点都会执行，每个服务可以执行对应的数据，缓解服务端压力

@XxlJob("demo")
public void demo(){
          
   
    String jobParam = XxlJobHelper.getJobParam();
    System.out.println(jobParam);

    int shardIndex = XxlJobHelper.getShardIndex();//执行的第几个节点，从0开始
    int shardTotal = XxlJobHelper.getShardTotal();//所有节点数量

    System.out.println("shardIndex "+shardIndex);
    System.out.println("shardTotal "+shardTotal);
}

##打印信息
100
shardIndex 0
shardTotal 2

引入业务之后，参数作为每页数量，将index作为页数、total数量，对每个节点进行内部分页处理