分布式任务调度，定时任务的处理方案

方案一：使用异步任务+定时任务可以结合使用，实现在指定时间或周期内异步执行任务的功能（单单使用定时任务会阻塞主线程）

适用场景：
Spring 定时任务是 Spring 框架提供的一种轻量级的任务调度方案，它的特点是简单易用、轻量级。Spring 定时任务的执行是在单个节点上进行的，如果需要分布式任务调度，需要自己实现相应的解决方案。

使用步骤

1.导入依赖版本自己控制

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-task</artifactId></dependency>
</dependencies>

2.启动类加上@EnableScheduling

3.编写业务
cron表达式在线生成
https://cron.qqe2.com/

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
/* 定时任务*      1、@EnableScheduling 开启定时任务*      2、@Scheduled  开启一个定时任务*      3、自动配置类 TaskSchedulingAutoConfiguration 异步任务*      1、@EnableAsync 开启异步任务功能*      2、@Async 给希望异步执行的方法上标注*      3、自动配置类 TaskExecutionAutoConfiguration 属性绑定在TaskExecutionProperties/
@Slf4j
@Component
public class HelloSchedule {/* 1、Spring中6位组成，不允许第7位的年* 2、在周几的位置，1-7代表周一到周日； MON-SUN* 3、定时任务不应该阻塞。默认是阻塞的*      1）、可以让业务运行以异步的方式，自己提交到线程池*              CompletableFuture.runAsync(()->{*                  xxxxService.hello();*              },executor);*      2）、支持定时任务线程池；设置 TaskSchedulingProperties；*              spring.task.scheduling.pool.size=5*      3）、让定时任务异步执行*          异步任务；*     解决：使用异步+定时任务来完成定时任务不阻塞的功能；@Async@Scheduled(cron = "* * * ? * 5")//表达式public void hello()  {log.info("执行业务...");}
}

方案二：引入中间件xxl-job

XXL-Job 是一个基于 Spring 的分布式任务调度框架，它的特点是分布式、可靠性高、易于管理。XXL-Job 提供了任务调度、执行、报警、日志等完整的功能，支持任务失败重试、任务失败告警等机制，能够保证任务执行的高可靠性和稳定性。同时，XXL-Job 的任务执行是分布式的，可以将任务分发到多个节点执行，提高任务执行效率。

使用 XXL-Job 需要在项目中引入 XXL-Job 的相关依赖，并进行相关配置。同时，XXL-Job 还提供了一个可视化的任务管理平台，可以方便地管理和监控任务的执行情况。

XXL-Job 的使用场景一般是执行复杂的分布式定时任务，例如：订单超时未支付处理、大数据分析等。如果只是执行简单的定时任务，则可以使用 Spring 定时任务。

使用步骤

A.本地安装
码云：https://gitee.com/xuxueli0323/xxl-job
1.下载项目 2.导入里面的数据库 3.启动服务
B.虚拟机安装
要在 Linux 系统上使用 Docker 部署 XXL-Job，可以按照以下步骤进行操作：
1.拉取 XXL-Job 镜像：可以从 Docker Hub 上拉取 XXL-Job 镜像，执行以下命令：
docker pull xuxueli/xxl-job-admin:latest # 拉取 XXL-Job Admin 镜像
docker pull xuxueli/xxl-job-executor:latest # 拉取 XXL-Job Executor 镜像
2.创建 XXL-Job 容器：

a. 创建 XXL-Job Admin 容器：
docker run -d --name xxl-job-admin -p 8080:8080 xuxueli/xxl-job-admin
这个命令将会创建一个名为 xxl-job-admin 的容器，并且将容器的 8080 端口映射到宿主机的 8080 端口，使得我们可以通过浏览器访问到 XXL-Job 的管理界面。
b. 创建 XXL-Job Executor 容器：
docker run -d --name xxl-job-executor
-e PARAMS="–xxl.job.admin.address=http://xxl-job-admin:8080/xxl-job-admin"
xuxueli/xxl-job-executor
这个命令将会创建一个名为 xxl-job-executor 的容器，并且将 XXL-Job Admin 的地址配置到容器中，使得 Executor 能够与 Admin 进行通信。
至此，XXL-Job 在 Docker 中的部署就完成了。通过浏览器访问 http://ip:8080/xxl-job-admin/，即可进入 XXL-Job 的管理界面。

那么如何使用xxl-job进行任务调度呢
1.进入管理界面，新增执行器

2.在需要添加任务调度的服务中添加依赖

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

3.配置yml，改ip和hander

xxl:job:admin: addresses: http://----ip---/xxl-job-adminexecutor:appname: #你在管理页面命名的handeraddress: ip: port: 9999logpath: /data/applogs/xxl-job/jobhandlerlogretentiondays: 30accessToken: default_token

4.复制配置文件，文件在xxl-job项目的 xxl-job-2.3.1\\xxl-job-executor-samples\\xxl-job-executor-sample-springboot\\src\\main\\java\\com\\xxl\\job\\executor\\core\\config 的XxlJobConfig

package com.xuecheng.media.config;import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/* xxl-job config @author xuxueli 2017-04-28*/
@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;@Beanpublic 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;}/* 针对多网卡、容器内部署等情况，可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP；      1、引入依赖：*          <dependency>*             <groupId>org.springframework.cloud</groupId>*             <artifactId>spring-cloud-commons</artifactId>*             <version>${version}</version>*         </dependency>      2、配置文件，或者容器启动变量*          spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'      3、获取IP*          String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();*/}

成功的标志

配置已经完成，那么如何使用呢？其实使用跟spring自带的定时任务很像
1.在服务中定义任务，一般写在service层

2.登上xxl-job的admin配置cron和spring的定时任务是一样的，但是提供了更人性化，和更丰富的功能.

自己自定义配置任务的执行周期和策略