Spring Boot 使用 XXL-JOB

摘要:
1、 配置部署调度中心1.1下载源代码https:
一、配置部署调度中心

1.1 下载源码

https://github.com/xuxueli/xxl-job

1.2 数据库初始化

执行 /xxl-job/doc/db/tables_xxl_job.sql

1.3 修改配置

/xxl-job/xxl-job-admin/src/main/resources/application.properties

server.port=8080

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_pwd

xxl.job.accessToken=

上面几个配置根据需求修改,其他的可以不用修改

执行器默认端口是 9999,可以通过 xxl.job.executor.port 修改

1.4 部署

编译代码,启动调度中心

java -jar xxl-job-admin-2.2.1-SNAPSHOT.jar

调度中心访问地址:http://localhost:8080/xxl-job-admin , 默认登录账号:admin/123456

二、使用

2.1 添加依赖包

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

2.2 添加配置

复制 /xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/core/config/XxlJobConfig.java 到项目

2.3 修改配置

xxl:
  job:
    admin:
      # 调度中心部署跟地址 [选填]:如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调";为空则关闭自动注册
      addresses: http://127.0.0.1:8080/xxl-job-admin
      # 执行器通讯TOKEN [选填]:非空时启用
    accessToken:

    executor:
      # 执行器AppName [选填]:执行器心跳注册分组依据;为空则关闭自动注册
      appname: xxl-job-executor-sample
      # 执行器注册 [选填]:优先使用该配置作为注册地址,为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。
      address:
      # 执行器IP [选填]:默认为空表示自动获取IP,多网卡时可手动设置指定IP,该IP不会绑定Host仅作为通讯实用;地址信息用于 "执行器注册" 和 "调度中心请求并触发任务";
      ip:
      # 执行器端口号 [选填]:小于等于0则自动获取;默认端口为9999,单机部署多个执行器时,注意要配置不同执行器端口;
      port: 9999
      # 执行器运行日志文件存储磁盘路径 [选填] :需要对该路径拥有读写权限;为空则使用默认路径;
      logpath: /data/applogs/xxl-job/jobhandler
      # 执行器日志文件保存天数 [选填] : 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能;
      logretentiondays: 30

2.4 添加测试任务

  1. 在Spring Bean实例中,开发Job方法,方式格式要求为 “public ReturnT execute(String param)”
  2. 为Job方法添加注解 “@XxlJob(value=”自定义jobhandler名称”, init = “JobHandler初始化方法”, destroy = “JobHandler销毁方法”)”,注解value值对应的是调度中心新建任务的JobHandler属性的值。
  3. 执行日志:需要通过 “XxlJobLogger.log” 打印执行日志;

可以拷贝 /xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java 中的代码

2.5 调度中心添加新任务

http://localhost:8080/xxl-job-admin/jobinfo ,添加成功后即可看到效果

XXL开源社区

免责声明:文章转载自《Spring Boot 使用 XXL-JOB》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇[2020牛客暑期多校训练营(第一场)虚树 Infinite Tree]【HoorayOS】开源的Web桌面应用框架(文件夹功能分析)下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

TCP/IP协议(一)网络基础知识 网络七层协议

参考书籍为《图解tcp/ip》-第五版。这篇随笔,主要内容还是TCP/IP所必备的基础知识,包括计算机与网络发展的历史及标准化过程(简述)、OSI参考模型、网络概念的本质、网络构建的设备等     下面是协议层从底层至顶层的一个模型图:   一、计算机网络的背景 1.1 计算机的发展 有人说:“20世纪最伟大的发明就是计算机”,自诞生伊始,计算机经历了...

Jmeter从数据库中读取数据

Jmeter从数据库中读取数据 1、测试计划中添加Mysql Jar包 2、添加线程组 3、添加 jdbc connection configuration   4、添加JDBC Request,从数据库中获取数据, 注意:1.Variable Name必须与第3步中的Variable Name保持一致。            2.Result var...

socket网络编程(一)——初识socket

出现一项技术,首先我们弄懂一下,为什么要出现。那么为什么要出现socket这玩意呢?可以很简单的用一句话来概括: 为了实现两台计算机的通信   1、socket诞生的原因 两台装有操作系统的机子要想实现通信,第一要联网,第二通信双方一定制定某种规则。我们平时最为常见的http请求也是一种通信协议,只不过它是属于应用层的。http协议将要发送的数据封装后,...

linux socket编程client获取使用的ip和port

今天为了测试机器绑定多ip时socket client使用的ip和port, 因此查询资料看了下如何获取client的ip和port(系统自选而不是bind绑定) 主要是对连接的描述符通过getsockname 函数获取client的地址信息,函数说明如下 #include <sys/socket.h> int getsockname(int...

每个文件之间延迟启动批处理bat方法之一

每个文件之间延迟启动批处理bat方法之一 知识点:xp程序中通过ping 127.0.0.1 -n 20 来实现延时操作,ping本地地址20行。            win7中通过timeout 20 来实现延时20秒。 新建批处理bat文件,  .txt→.bat 改扩展名或txt里另存为.bat就可以 例B是路径名包含空格类的需要用引号" "否则会...

Bing Maps进阶系列三:使用地图图像服务(ImageryService)

  地图图像服务(ImageryService)提供了根据地理位置(经度和纬度)坐标和地图的缩放级别解析出对应于地图图片系统的完整地图数据元数据,包括图片映射地址、图片大小等一系列详细参数。通过该服务的服务接口也可以反向实现通过指定地理位置坐标、地图缩放级别和图片大小(高度和宽度)来生成不同的地图图片。   一、添加ImageryService的Web服务引...