任务调度，XXL-JOB实战

古城微笑少年丶 2023-01-07 01:27 168阅读 0赞

1.引入依赖包

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

2.引入配置文件

>     @Slf4j
>     @Configuration
>     @EnableConfigurationProperties(XxlJobProps.class)
>     public class XxlJobConfig {
>     
>         @Autowired
>         private XxlJobProps conf;
>     
>         @Bean
>         public XxlJobSpringExecutor xxlJobExecutor() {
>             log.info(">>>>>>>>>>> xxl-job config init.");
>             XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
>             xxlJobSpringExecutor.setAdminAddresses(conf.getAdmin().getAddresses());
>             xxlJobSpringExecutor.setAppname(conf.getExecutor().getAppName());
>             xxlJobSpringExecutor.setIp(conf.getExecutor().getIp());
>             xxlJobSpringExecutor.setPort(conf.getExecutor().getPort());
>             xxlJobSpringExecutor.setAccessToken(conf.getAccessToken());
>             xxlJobSpringExecutor.setLogPath(conf.getExecutor().getLogPath());
>             xxlJobSpringExecutor.setLogRetentionDays(conf.getExecutor().getLogRetentionDays());
>             return xxlJobSpringExecutor;
>         }
>     }

XxlJobProps 属性

>     @Data
>     @ConfigurationProperties(prefix = "xxl.job")
>     public class XxlJobProps {
>         /**
>          * 调度中心配置
>          */
>         private XxlJobAdminProps admin;
>     
>         /**
>          * 执行器配置
>          */
>         private XxlJobExecutorProps executor;
>     
>         /**
>          * 与调度中心交互的accessToken
>          */
>         private String accessToken;
>     
>         @Data
>         public static class XxlJobAdminProps {
>             /**
>              * 调度中心地址
>              */
>             private String addresses;
>         }
>     
>         @Data
>         public static class XxlJobExecutorProps {
>             /**
>              * 执行器名称
>              */
>             private String appName;
>     
>             /**
>              * 执行器 IP
>              */
>             private String ip;
>     
>             /**
>              * 执行器端口
>              */
>             private int port;
>     
>             /**
>              * 执行器日志
>              */
>             private String logPath;
>     
>             /**
>              * 执行器日志保留天数，-1
>              */
>             private int logRetentionDays;
>         }
>     }

xxl -job 地址配置

> xxl:  
>   job:  
>     admin:  
>       addresses: http://10.1.1.217:8080/xxl-job-admin  
>     executor:  
>       appname: carpool  
>       port: 9999  
>       logpath: /logs/xxl  
>       logretentiondays: 5

创建任务

> @Component  
> @Slf4j  
> public class UserJobHandler \{
> 
>     /\*\*  
>      \* 用户解冻任务，每天凌晨1点跑一次  
>      \*  
>      \* @param param  
>      \* @return  
>      \*/  
>     @XxlJob("thawUserJobHandler")  
>     public ReturnT<String> thawUserJobHandler(String param) \{  
>         log.info("begin --> thawUserJobHandler");  
>         //  
>         log.info("end --> thawUserJobHandler");  
>         return ReturnT.SUCCESS;  
>     \} 
> 
> \}

登录xxl admin 创建thawUserJobHandler

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zNDUwMzUyNg_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zNDUwMzUyNg_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210115095204211.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zNDUwMzUyNg==,size_16,color_FFFFFF,t_70