> Java > java지도 시간 > SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

WBOY
풀어 주다: 2023-05-14 18:58:06
앞으로
1199명이 탐색했습니다.

1. XxlJob 소개

XXL-JOB은 분산 작업 스케줄링 플랫폼입니다. 핵심 설계 목표는 빠른 개발, 쉬운 학습, 경량 및 쉬운 확장입니다. 이제 소스 코드가 공개되어 많은 회사의 온라인 제품 라인에 연결되어 즉시 사용할 수 있습니다.

분산 작업 스케줄링을 사용하는 이유는 무엇인가요? 분산 프로젝트이든 nginx 로드 밸런싱이든

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

2와 같은 기존의 예약된 작업 구현 방법은 만족하기가 매우 느립니다. job

Download

http://gitee.com/xuxueli0323/xxl-jobDownload

2.2 예약된 작업 구현 단계

1. 데이터베이스의 프로젝트에서 sql 스크립트를 실행합니다

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

2. 디렉터리 구조 설명

xxl-job-admin: 디스패치 센터
xxl-job-core: 공개 종속성
xxl-job-executor-samples: Executor 샘플(적절한 버전의 Executor를 선택하거나, 직접 사용하거나, 참조하여 기존 프로젝트를 Executor로 변환할 수 있습니다)
: xxl-job-executor-sample -springboot: Springboot를 통해 실행기를 관리합니다. 이 방법을 권장합니다.
: xxl-job-executor-sample-frameless: 프레임리스 버전

3. 파견 센터 구성 파일 수정

###
server.port=8080
server.servlet.context-path=/xxl-job-admin

### 액츄에이터
management.server.servlet.context-path=/actuator
management.health.mail.enabled=false

# ## 리소스
spring.mvc.servlet.load-on-startup=0
spring.mvc.static-path-pattern=/static/**
spring.resources.static-locations=classpath:/static/

# ## freemarker
spring.freemarker.templateLoaderPath=classpath:/templates/
spring.freemarker.suffix=.ftl
spring.freemarker.charset=UTF-8
spring.freemarker.request-context-attribute=request
spring.freemarker .settings.number_format=0.#########

### mybatis
mybatis.mapper-locations=classpath:/mybatis-mapper/*Mapper.xml
#mybatis.type- aliases-package =com.xxl.job.admin.core.model

### xxl-job, datasource
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding= UTF-8&autoReconnect =true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

### 데이터 소스 풀
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.hikari.minimum-idle=10
spring.datasource.hikari.maximum-pool-size=30
spring.datasource.hikari. 자동 커밋 =true
spring.datasource.hikari.idle-timeout=30000
spring.datasource.hikari.pool-name=HikariCP
spring.datasource.hikari.max-lifetime=900000
spring.datasource.hikari.connection- timeout=10000
spring.datasource.hikari.connection-test-query=SELECT 1
spring.datasource.hikari.validation-timeout=1000

### xxl-job, 이메일 경보 사서함, 예약된 작업 실행이 실패하는 경우, 메시지가 이메일
spring.mail.host=smtp.qq.com
spring.mail.port=25
spring.mail.username=XXX@qq.com
spring.mail.from=XXX@qq로 푸시됩니다. .com
spring.mail.password=인증 코드
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail. smtp.starttls.required=true
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory

### xxl-job, 액세스 토큰 디스패치 센터 통신 TOKEN [선택 사항]: 활성화되는 경우 비어 있지 않음
## # 통신 토큰이 구성된 경우 파견 센터 및 실행자 서비스의 accessToken이 일관되어야 합니다
xxl.job.accessToken=

### xxl-job, i18n(기본값은 zh_CN이며 다음을 수행할 수 있습니다. "zh_CN", "zh_TC" 및 "en" 선택)
# 파견 센터 국제화 구성 [필수]: 기본값은 "zh_CN"/중국어 간체, 선택 범위는 "zh_CN"/중국어 간체, "zh_TC"/중국어 번체 and "en "/English;
xxl.job.i18n=zh_CN

## xxl-job, Triggerpool max size
# 스레드 풀 최대 스레드 구성 예약 [필수]
xxl.job.triggerpool.fast.max=200
xxl.job.triggerpool.slow.max=100

### xxl-job, 로그 보존 일수
#스케줄링 센터 로그 테이블 데이터 보존 일수 [필수]: 만료된 로그는 자동으로 정리되며 한도가 클 때 적용됩니다. 7 이상, 그렇지 않으면 -1과 같이 자동 정리 기능을 끄십시오.
xxl.job.logretentiondays=30

위 구성이 올바르게 수행되면 프로젝트를 컴파일, 패키징 및 배포할 수 있습니다.

스케줄링 센터 접속 주소: http://localhost:8080/xxl-job-admin (이 주소는 실행자가 콜백 주소로 사용됩니다)

로그인 후 기본 로그인 계정은 "admin/123456"입니다. , 실행 인터페이스는 그림과 같습니다.

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

4. 실행기 프로젝트 구성

xxl-job-executor-sample-frameless 기본 방식(권장되지 않음)
"Executor" 프로젝트: xxl-job-executor-sample-springboot(실행을 위한 여러 버전 제공) 여러 개의 Executor 중에서 선택할 수 있으며, springboot 버전을 예로 들어 직접 사용할 수도 있고, 기존 프로젝트를 참조하여 Executor로 변환할 수도 있습니다.)
기능: "Scheduling Center"의 스케줄링 및 실행을 담당합니다. ; 실행기를 직접 배치하거나 액추에이터를 기존 비즈니스 프로젝트에 통합할 수 있습니다.

# 웹 포트
server.port=8081
# 웹 없음
#spring.main.web-environment=false

# log config
logging.config=classpath:logback.xml
# 스케줄링 센터 배포 루트 주소 [선택]: 파견 센터 클러스터 배포 주소가 여러 개인 경우 쉼표로 구분하세요. 실행자는 "실행자 하트비트 등록" 및 "작업 결과 콜백"에 이 주소를 사용합니다. 비어 있으면 자동 등록이 꺼집니다.
xxl.job.admin.addresses=http://127.0.0.1:8080/ xxl-job -admin

# 실행자 통신 TOKEN [선택 사항]: 비어 있지 않으면 활성화됨
xxl.job.accessToken=

# 실행자 AppName [선택 사항]: 실행자 하트비트 등록 그룹화 기반이 비어 있으면 자동 등록이 꺼집니다.
xxl.job.executor.appname=xxl-job-executor-llp
# 실행자 등록 [선택 사항]: 이 구성은 등록 주소로 선호됩니다. 비어 있는 경우 내장된 서비스 "IP:PORT"가 사용됩니다. 등록 주소. 이는 컨테이너 유형 실행기 동적 IP 및 동적 매핑 포트 문제에 대한 보다 유연한 지원을 제공합니다.
xxl.job.executor.address=
# 실행자 IP [선택 사항]: 네트워크 카드가 여러 개인 경우, IP가 바인딩되지 않도록 수동으로 설정할 수 있습니다. 호스트이며 통신에만 유용합니다. "실행자 등록" 및 "스케줄링 센터 요청 및 트리거 작업"에 사용됩니다.
xxl.job.executor.ip=
# 실행자 포트 번호 [선택 사항]: 더 적은 경우 자동으로 가져옵니다. 0 이상, 기본 포트는 9999, 독립형입니다. 여러 실행기를 배포할 때 서로 다른 실행기 포트를 구성해야 합니다.
xxl.job.executor.port=0
# 실행기 실행 로그 파일 저장 디스크 경로 [선택 사항] : 이 경로에 대한 읽기 및 쓰기 권한이 필요합니다. 비어 있으면 기본 경로를 사용하세요.
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
# 실행기 로그를 저장할 일 수 파일 [선택 사항]: 만료된 로그는 자동으로 정리되며 제한 값이 3 이상일 때 적용됩니다. 그렇지 않으면 -1과 같이 자동 정리 기능을 끕니다.
xxl.job.executor.logretentiondays=30

5. 실행자 추가

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

6. 예약된 작업 추가

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

7. 테스트용 예약된 작업 실행

스케줄링 로그 보기SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

3. SpringBoot는 XxlJob을 통합합니다SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

3.1 SpringBoot 프로젝트 생성 및 종속성 도입

package com.xxl.job.executor.service.jobhandler;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class TestXxlJob {
    private static Logger logger = LoggerFactory.getLogger(TestXxlJob.class);
    @XxlJob(value = "testJobHandler", init = "init", destroy = "destroy")
    public void testJobHandler() throws Exception {
        logger.info("进入xxlJob定时任务。。。。");
    }
    public void init(){
        logger.info("init");
    }
    public void destroy(){
        logger.info("destroy");
    }
    @XxlJob("testJobHandler02")
    public void demoJobHandler() throws Exception {
        XxlJobHelper.log("XXL-JOB, Hello World.");
        logger.info("进入testJobHandler02定时任务。。。。");
    }
}
로그인 후 복사

3.2 쓰기 속성 구성 파일

# 웹 포트

server.port=8081
# no web

#spring.main.web-environment =false

# log config
logging.config=classpath:logback.xml

# 스케줄링 센터 배포 루트 주소 [선택]: 스케줄링 등 중앙 클러스터 배포에 주소가 여러 개인 경우 쉼표로 구분합니다. 실행자는 "실행자 하트비트 등록" 및 "작업 결과 콜백"에 이 주소를 사용합니다. 비어 있으면 자동 등록이 꺼집니다.

xxl.job.admin.addresses=http://127.0.0.1:8080/ xxl-job -admin

# 실행자 통신 TOKEN [선택 사항]: 비어 있지 않으면 활성화됨
xxl.job.accessToken=llp

# 실행자 AppName [선택 사항]: 실행자 하트비트 등록 그룹화 기반이 비어 있으면 자동 등록을 끕니다.
xxl.job.executor.appname=xxl-job-executor-llp

# 실행자 등록 [선택 사항]: 등록 주소로 이 구성을 사용하는 것이 우선입니다. 비어 있는 경우 내장된 서비스 "IP:PORT"입니다. 등록 주소로 사용됩니다. 이는 컨테이너 유형 실행기 동적 IP 및 동적 매핑 포트 문제에 대한 보다 유연한 지원을 제공합니다.

xxl.job.executor.address=
# 실행자 IP [선택 사항]: 네트워크 카드가 여러 개인 경우, IP가 바인딩되지 않도록 수동으로 설정할 수 있습니다. 호스트이며 통신에만 유용합니다. "실행자 등록" 및 "스케줄링 센터 요청 및 트리거 작업"에 사용됩니다.
xxl.job.executor.ip=127.0.0.1
# 실행자 포트 번호 [선택 사항]: 다음 경우 자동으로 획득됩니다. 0보다 작거나 같습니다. 기본 포트는 9999입니다. 단일 시스템에 여러 실행기를 배포할 때 서로 다른 실행기 포트를 구성해야 합니다.
xxl.job.executor.port=9999
# 실행기 실행 로그 파일 저장 디스크; 경로 [선택 사항]: 이 경로에 대한 읽기 및 쓰기 권한이 필요합니다. 비어 있으면 기본 경로를 사용하세요.
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
# 일수 실행기 로그 파일 저장 [선택 사항]: 만료된 로그는 자동으로 정리됩니다. 제한 값은 3보다 크거나 같습니다. 그렇지 않으면 -1과 같이 자동 정리 기능을 끕니다.
xxl.job.executor.logretentiondays =30


디스패치 센터에서 작업을 생성할 때 Executor에서 구성한 앱 이름과 앱 이름이 일치해야 합니다. IP 및 포트를 구성하는 것이 좋습니다.

3.3 xxljob 구성 클래스 작성

<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>${稳定版}</version>
</dependency>
로그인 후 복사

3.4 테스트를 위한 작업 클래스 작성

@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;
    @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;
    }
    /**
     * 针对多网卡、容器内部署等情况,可借助 "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: &#39;xxx.xxx.xxx.&#39;
     *
     *      3、获取IP
     *          String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
     */
}
로그인 후 복사

실행자 만들기

작업 만들기SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

查看后台执行日志

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

如果需要xxlJob邮件报警功能,则需要在xxl-job-admin中进行配置邮件信息,并在创建任务时指定配置的邮箱地址

### xxl-job, email报警邮箱,如果定时任务执行失败会推送消息给该邮箱
spring.mail.host=smtp.qq.com
spring.mail.port=25
spring.mail.username=XXX@qq.com
spring.mail.from=XXX@qq.com
spring.mail.password=授权码
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.starttls.required=true
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory

ps:如果定时任务执行频率很高,频繁失败的话,那收邮件就是一个噩梦~

SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법

4.XxlJob部署

4.1 jar包部署方式

jar包部署的方式比较简单,将项目编译打包部署到服务器上,其他服务和xxljob调度器之间网络、接口相通即可

4.2 Docker 镜像方式搭建调度中心

下载镜像

# Docker地址:https://hub.docker.com/r/xuxueli/xxl-job-admin/     (建议指定版本号)
docker pull xuxueli/xxl-job-admin
# 如需自定义 mysql 等配置,可通过 "-e PARAMS" 指定,参数格式 PARAMS="--key=value  --key2=value2" ;
# 配置项参考文件:/xxl-job/xxl-job-admin/src/main/resources/application.properties
# 如需自定义 JVM内存参数 等配置,可通过 "-e JAVA_OPTS" 指定,参数格式 JAVA_OPTS="-Xmx512m" ;
docker run -e PARAMS="--spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai" -p 8080:8080 -v /tmp:/data/applogs --name xxl-job-admin  -d xuxueli/xxl-job-admin:{指定版本}
로그인 후 복사

위 내용은 SpringBoot가 XxlJob 분산 작업 스케줄링 플랫폼을 통합하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:yisu.com
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿