快捷導(dǎo)航

Spring?Cloud整合XXL-Job的示例代碼

更新時間：2023年05月15日 10:25:22 作者：冷艷無情的小媽

這篇文章主要介紹了springcloud整合xxl-job的示例代碼,主要分為四個過程，本文給大家介紹的非常詳細(xì)，需要的朋友可以參考下

第一步：

整合pom文件，在Spring Cloud中添加XXL-Job的依賴

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

第二步：

把XXL-Job中的lohback.xml導(dǎo)入到Spring Cloud 項(xiàng)目中

<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false" scan="true" scanPeriod="1 seconds">
 
    <contextName>logback</contextName>
<!--    日志文件位置-->
    <property name="log.path" value="D:/ZM/xxl-job-executor-sample-springboot.log"/>
 
    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
    </appender>
 
    <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <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>

第三步：

application.properties整合

server.port=8091
server.tomcat.max-threads=10
spring.application.name=service-order
 
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/shop?useSSL=false&serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&userSSL=false&allowPublicKeyRetrieval=true
spring.datasource.username=root
spring.datasource.password=123456
 
spring.jpa.properties.show-sql=true
spring.jpa.properties.database=mysql
spring.jpa.properties.database-platform=mysql
spring.jpa.properties.hibernate.ddl-auto=update
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL57Dialect
 
spring.cloud.nacos.discovery.server-addr=192.168.136.1:8848
#跟控制臺交流的端口，隨意制定一個未使用的端口即可
spring.cloud.sentinel.transport.port=9999
#指定控制臺服務(wù)的地址
spring.cloud.sentinel.transport.dashboard=localhost:8080
 
#關(guān)閉sentinel的CommonFilter實(shí)列化
spring.cloud.sentinel.filter.enabled=false
 
feign.sentinel.enabled=true
 
#通過修改配置來調(diào)整Ribbon的負(fù)載均衡策略
service-product.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule
 
#rocketMQ服務(wù)的地址
rocketmq.name-server=192.168.136.111:9876
# 生產(chǎn)者組
rocketmq.producer.group=shop-order
spring.cloud.nacos.config.namespace=public
spring.cloud.nacos.config.group=SEATE_GROUP
spring.cloud.alibaba.seata.tx-service-group=${spring.application.name}
spring.cloud.nacos.config.env=dev
 
logging.config=classpath:logback.xml
 
 
### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
xxl.job.admin.addresses=http://192.168.136.111:8080/xxl-job-admin
 
### xxl-job executor address
xxl.job.executor.appname=xxl-job-executor-sample
xxl.job.executor.ip=
xxl.job.executor.port=9999
 
### xxl-job, access token
xxl.job.accessToken=
 
### xxl-job log path
xxl.job.executor.logpath=/opt/module/xxl-job-2.0.1/jobhandler
### xxl-job log retention days
xxl.job.executor.logretentiondays=-1

第四步：

向Spring Cloud中導(dǎo)入XxlJobConfig.class

@Configuration
@ComponentScan(basePackages = "com.xxl.job.executor.service.jobhandler")
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;
    }

}