xxl-job 任务调度使用

布满荆棘的人生 2023-05-21 08:42 18阅读 0赞

服务端代码下载  
[xxl-job-master][]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDMwNTYz_size_16_color_FFFFFF_t_70]

application.properties

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDMwNTYz_size_16_color_FFFFFF_t_70 1]

--------------------

客户端

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDMwNTYz_size_16_color_FFFFFF_t_70 2]

pom.xml

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

DemoJobHandler.java

import com.xxl.job.core.biz.model.ReturnT;
    import com.xxl.job.core.handler.annotation.XxlJob;
    import org.springframework.stereotype.Component;
    
    import static com.xxl.job.core.biz.model.ReturnT.SUCCESS;
    
    @Component
    public class DemoJobHandler { 
    
        @XxlJob("jobDemo")
        public ReturnT<String> jobDemo(String s) { 
            System.out.println("excuting......");
            return SUCCESS;
        }
    }

XxlJobConfig.java

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.ComponentScan;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    //指定任务Handler所在包路径
    @ComponentScan(basePackages = "com.hikari.cloud")
    public class XxlJobConfig { 
        private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);
     
        @Value("${xxl.job.admin.addresses}")
        private String adminAddresses;
     
        @Value("${xxl.job.executor.appname}")
        private String appName;
     
        @Value("${xxl.job.executor.ip}")
        private String ip;
     
        @Value("${xxl.job.executor.port}")
        private int port;
     
        @Value("${xxl.job.accessToken}")
        private String accessToken;
     
        @Value("${xxl.job.executor.logpath}")
        private String logPath;
     
        @Value("${xxl.job.executor.logretentiondays}")
        private int logRetentionDays;
     
     
        @Bean(initMethod = "start", destroyMethod = "destroy")
        public XxlJobSpringExecutor xxlJobExecutor() { 
            logger.info("====xxl-job config init====");
            XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
            xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
            xxlJobSpringExecutor.setAppName(appName);
            xxlJobSpringExecutor.setIp(ip);
            xxlJobSpringExecutor.setPort(port);
            xxlJobSpringExecutor.setAccessToken(accessToken);
            xxlJobSpringExecutor.setLogPath(logPath);
            xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
            return xxlJobSpringExecutor;
        }
     
    }

application.yml

---
    ## xxl-job 的访问地址
    xxl:
      job:
        admin:
          addresses: http://localhost:8080/xxl-job-admin
        executor:
          appname: xxl-job
          ip: localhost
          port: 6811
          logpath: E:/it_test/xxl-job/
          logretentiondays: -1
        accessToken:

[xxl-job-master]: https://download.csdn.net/download/qq_25430563/12360773
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDMwNTYz_size_16_color_FFFFFF_t_70]: /images/20230521/ab4c311496cf47bb9f8ffbf48f617261.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDMwNTYz_size_16_color_FFFFFF_t_70 1]: /images/20230521/b4edae6e694740e4ba33e988ba7d5309.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDMwNTYz_size_16_color_FFFFFF_t_70 2]: /images/20230521/d5e5ed1cf1bf4332833909d535416b79.png