Springboot项目引入xxl-job

# 执行maven打包 mvn clean install <h1>构建Docker镜像，镜像名称中不允许使用下划线</h1><p>docker build -t xxl-job:latest .

<dependency> <groupId>com.xuxueli</groupId> <artifactId>xxl-job-core</artifactId> <version>${project.parent.version}</version> </dependency>

xxl: job: admin: addresses: <a href="https://www.php.cn/link/7ece221bf3f5dbddbe3c2770ac19b419">https://www.php.cn/link/7ece221bf3f5dbddbe3c2770ac19b419</a> AccessToken:  executor: appname: xxl-job-executor-sample address:  ip:  port: 8082 logpath: /data/applogs/xxl-job/jobhandler logretentiondays: 30

<?xml version="1.0" encoding="UTF-8"?> <configuration debug="false" scan="true" scanPeriod="1 seconds"> <contextName>logback</contextName> <property name="log.path" value="/data/applogs/xxl-job/xxl-job-executor-sample-springboot.log"/> <appender class="ch.qos.logback.core.ConsoleAppender" name="console"> <encoder> <pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern> </encoder> </appender> <appender class="ch.qos.logback.core.rolling.RollingFileAppender" name="file"> <file>${log.path}</file> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <fileNamePattern>${log.path}.%d{yyyy-MM-dd}.zip</fileNamePattern> </rollingPolicy> <encoder> <pattern>%date %level [%thread] %logger{36} [%file : %line] %msg%n</pattern> </encoder> </appender> <root level="info"> <appender-ref ref="console"/> <appender-ref ref="file"/> </root> </configuration>

package com.cgd.xxljobexecutor.config;</p><p>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;</p><p>/**</p><ul><li><p>xxl-job config</p></li><li></li><li><p>@author xuxueli 2017-04-28 */ @Configuration public class XxlJobConfig { private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);</p><p>@Value("${xxl.job.admin.addresses}") private String adminAddresses;</p><p>@Value("${xxl.job.accessToken}") private String accessToken;</p><p>@Value("${xxl.job.executor.appname}") private String appname;</p><p>@Value("${xxl.job.executor.address}") private String address;</p><p>@Value("${xxl.job.executor.ip}") private String ip;</p><p>@Value("${xxl.job.executor.port}") private int port;</p><p>@Value("${xxl.job.executor.logpath}") private String logPath;</p><p>@Value("${xxl.job.executor.logretentiondays}") private int logRetentionDays;</p><p>@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; }</p><p>/**</p><ul><li>针对多网卡、容器内部署等情况，可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP；</li><li></li><li>1、引入依赖：</li><li><dependency></li><li><groupId>org.springframework.cloud</groupId></li><li><artifactId>spring-cloud-commons</artifactId></li><li><version>${version}</version></li><li></dependency></li><li></li><li>2、配置文件，或者容器启动变量</li><li>spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'</li><li></li><li>3、获取IP</li><li>String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress(); */ }

package com.cgd.xxljobexecutor.xxlJob;</li></ul></li></ul><p>import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.handler.annotation.XxlJob; import org.springframework.stereotype.Component;</p><p>/**</p><ul><li>@author chengd</li><li>@version 1.0</li><li>@date 2021/5/19 15:24 */ @Component public class PushJob { @XxlJob("PushJobHandler") public ReturnT<String> PushJobHandler(String param){ ReturnT<String> returnT = new ReturnT<>(); returnT.setCode(ReturnT.SUCCESS_CODE); returnT.setContent("test"); returnT.setMsg("<p style="color:red">test</p>"); return returnT; } }