文档章节

使用xxl-job-spring-boot-starter开发xxl-job执行器

centychen
 centychen
发布于 05/10 15:29
字数 678
阅读 534
收藏 6

简述

本文简单描述如何使用xxl-job-spring-boot-starter开发xxl-job的执行器服务。

开发步骤

添加依赖

创建一个Spring Boot项目

  • 添加依赖包
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.1.4.RELEASE</version>
    <exclusions>
        <!-- exclude tomcat -->
        <exclusion>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-tomcat</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-undertow</artifactId>
    <version>2.1.4.RELEASE</version>
</dependency>

<dependency>
    <groupId>cn.centychen</groupId>
    <artifactId>xxl-job-spring-boot-starter</artifactId>
    <version>1.0.0-RELEASE</version>
</dependency>

修改xxl-job配置

添加以下xxl-job配置,也可不配置,不配置则使用默认值。

xxl-job:
  admin:
    admin-addresses: http://localhost:8080/xxl-job-admin
  executor:
    app-name: xxl-job-spring-boot-starter-example #默认为 xxl-job-executor
    access-token: #默认为空
    log-path: logs/applogs/xxl-job/jobhandler #默认为 logs/applogs/xxl-job/jobhandler
    log-retention-days: 10 #默认为 10
    ip: #默认为空
    port: 9999 #默认为 9999

编写任务处理器

创建DemoJobHandler.class类,继承IJobHandler抽象类,示例代码如下:

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.stereotype.Component;

@JobHandler("demoJobHandler")
@Component
public class DemoJobHandler extends IJobHandler {

    @Override
    public ReturnT<String> execute(String s) throws Exception {
        XxlJobLogger.log("This is a demo job.");
        Thread.sleep(5 * 1000L);
        return SUCCESS;
    }
}

启动测试

添加执行器

在调度中心->执行器管理中增加执行器。 add-executor-image.png

启动执行器

  • 启动示例执行器服务,启动成功log如下:

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v2.1.4.RELEASE)

2019-05-10 14:26:16.523  INFO 1444 --- [           main] c.c.s.s.xxljob.example.Application       : Starting Application on centdeMacBook-Pro.local with PID 1444 (/Users/cent/source-java/xxl-job-spring-boot-starter-example/target/classes started by cent in /Users/cent/source-java/xxl-job-spring-boot-starter-example)
2019-05-10 14:26:16.532  INFO 1444 --- [           main] c.c.s.s.xxljob.example.Application       : No active profile set, falling back to default profiles: default
2019-05-10 14:26:19.039  WARN 1444 --- [           main] io.undertow.websockets.jsr               : UT026010: Buffer pool was not set on WebSocketDeploymentInfo, the default pool will be used
2019-05-10 14:26:19.067  INFO 1444 --- [           main] io.undertow.servlet                      : Initializing Spring embedded WebApplicationContext
2019-05-10 14:26:19.067  INFO 1444 --- [           main] o.s.web.context.ContextLoader            : Root WebApplicationContext: initialization completed in 1641 ms
2019-05-10 14:26:19.351  INFO 1444 --- [           main] o.s.s.concurrent.ThreadPoolTaskExecutor  : Initializing ExecutorService 'applicationTaskExecutor'
2019-05-10 14:26:19.483  INFO 1444 --- [           main] c.c.s.s.x.a.XxlJobAutoConfiguration      : >>>>>>>>>>> xxl job config init...
2019-05-10 14:26:19.490  INFO 1444 --- [           main] c.xxl.job.core.executor.XxlJobExecutor   : >>>>>>>>>>> xxl-job register jobhandler success, name:demoJobHandler, jobHandler:cn.centychen.springboot.starter.xxljob.example.handler.DemoJobHandler@660f0c
2019-05-10 14:26:19.543  INFO 1444 --- [           main] c.x.r.r.provider.XxlRpcProviderFactory   : >>>>>>>>>>> xxl-rpc, provider factory add service success. serviceKey = com.xxl.job.core.biz.ExecutorBiz, serviceBean = class com.xxl.job.core.biz.impl.ExecutorBizImpl
2019-05-10 14:26:19.699  INFO 1444 --- [           main] org.xnio                                 : XNIO version 3.3.8.Final
2019-05-10 14:26:19.714  INFO 1444 --- [           main] org.xnio.nio                             : XNIO NIO Implementation Version 3.3.8.Final
2019-05-10 14:26:19.809  INFO 1444 --- [           main] o.s.b.w.e.u.UndertowServletWebServer     : Undertow started on port(s) 8080 (http) with context path ''
2019-05-10 14:26:19.814  INFO 1444 --- [           main] c.c.s.s.xxljob.example.Application       : Started Application in 4.35 seconds (JVM running for 6.302)
2019-05-10 14:26:19.831  INFO 1444 --- [      Thread-14] com.xxl.rpc.remoting.net.Server          : >>>>>>>>>>> xxl-rpc remoting server start success, nettype = com.xxl.rpc.remoting.net.impl.netty_http.server.NettyHttpServer, port = 9999
  • 执行器启动成功后,在调度中心的执行器记录中可以查看到注册信息。 executor-info-image.png

添加调度任务

在调度中心->任务管理中添加一个调度任务,配置如下图: add-task-image.png

执行调度任务

启动调度任务,查看调度日志。

示例源码

© 著作权归作者所有

centychen
粉丝 40
博文 31
码字总数 30489
作品 0
广州
技术主管
私信 提问
centychen/xxl-job-spring-boot-starter

xxl-job-spring-boot-starter 简述 本项目将xxl-job-core包简单封装成spring boot starter,方便通过Spring Boot方式开发xxl-job的executor 使用方法 添加依赖 创建一个Spring Boot项目 添加...

centychen
05/14
0
0
docker部署xxl-job 通用反射执行器

docker部署xxl-job 通用反射执行器 原因 最近在公司写一些job,公司使用的是spring boot提供的注解形式实现的。 这样在自测的时候很麻烦,而且测试提测的时候需要修改cron表达式->提交git->...

幸运券发放
07/31
0
0
java分布式任务调度xxl-job

小陈博主2017-11-30 21:11:56 前言碎语 在单机应用时期,任务调度一般都是基于spring schedule和集成quartz来实现的,当系统发展成分布式服务,应用多实例的时候,任务就会出现多次调用的问题...

u011277123
2017/12/13
0
0
任务调度系统 xxl-job,新版本 V1.3.x 新特性速览

xxl-job 1.3.x 版本发布,改进内容包括: 1.推荐使用“远程任务”,易于系统解耦,任务对应的JobHander统称为“执行器”;遗弃“本地任务”模式; 2.推荐使用JETTY方式,调度+回调双向通讯,重...

许雪里
2016/05/22
4.1K
21
进击的微服务实战派丨 Micro Service Open Talk 上海站

一、活动介绍 2016年10月,Spring Cloud 中国社区(http://springcloud.cn) 作为国内首个 Spring Cloud 构建微服务架构的交流社区正式成立,致力于为 Spring Boot 和 Spring Cloud 技术人员提...

又拍云
2017/09/27
106
0

没有更多内容

加载失败,请刷新页面

加载更多

三分钟,让你弄清楚Python中函数的括号使用

一直以来对python中函数括号的使用,有点分不清楚,到底什么时候用括号,什么时候不用括号,造成了很大困惑。 执行结果: 根据结果来分析: 1、 x = aaa aaa是一个类名,后面没加括号,打印结...

每天学Python
19分钟前
3
0
腾讯开源进入爆发期,Plato助推十亿级节点图计算进入分钟级时代

腾讯开源再次迎来重磅项目,14日,腾讯正式宣布开源高性能图计算框架Plato,这是在短短一周之内,开源的第五个重大项目。 相对于目前全球范围内其它的图计算框架,Plato可满足十亿级节点的超...

云计算头条
54分钟前
3
0
佣金计算

佣金计算 一、佣金计算 佣金计算分为:三级分销、股东分红、区域分销。 1、三级分销:展示的是三级分销的具体信息。可对其进行搜索和高级搜索。 三级分销的具体展示情况是对订单号、订单金额...

Geek-Chic
58分钟前
4
0
测试

If you are planning an outdoor event, you must be looking for a suitable tent. If yes, there are so many different options available these days. Renting or buying a tent will se......

阿锋zxf
今天
11
0
Java面试通关要点汇总集

基础篇 基本功 面向对象的特征 final, finally, finalize 的区别 int 和 Integer 有什么区别 重载和重写的区别 抽象类和接口有什么区别 说说反射的用途及实现 说说自定义注解的场景及实现 HT...

java后端开发
今天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部