GIS数据共享:官方网站

Linux

当前位置:首页 > 操作系统 > Linux

xxl-job(分布式任务调度平台)的介绍和使用

1.传统的定时任务1.1实现方式在启动类上使用@EnableScheduling注解,表示开启定时任务@SpringBootApplication @EnableScheduling public class XxlJobExecutorApplication { ...

1.传统的定时任务

1.1实现方式

在启动类上使用@EnableScheduling注解,表示开启定时任务

@SpringBootApplication
@EnableScheduling
public class XxlJobExecutorApplication {
	public static void main(String[] args) {
        SpringApplication.run(XxlJobExecutorApplication.class, args);
	}
}

根据业务需要,在方法上使用@Scheduled注解,cron属性配置定时规则

@Component
public class ScheduledTask {
    private final static Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
    @Scheduled(cron = "0/10 * * * * ?") //每10秒执行一次
    public void scheduledTaskByCorn() {
        logger.info("定时任务开始 ByCorn:" + new Date());
        scheduledTask();
        logger.info("定时任务结束 ByCorn:" + new Date());
    }
    private void scheduledTask() {
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

启动项目就可以看控制台看到定时任务执行效果

在这里插入图片描述


1.2缺点分析

不支持集群:集群情况下容易造成任务重复问题

不支持失败重试:失败即结束,不支持重试

不支持动态调整:修改任务参数时需要修改代码,并且要重启服务

无报警机制:任务失败后没有提醒功能

无统一管理:没有办法手动关闭或开启任务


2.初识xxl-job

XXL-JOB是一个开源的,具有丰富的任务管理功能以及高性能,高可用等特点的轻量级分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展、开箱即用!!!

系统组成:


调度模块(调度中心): 负责管理调度信息,按照调度配置发出调度请求,自身不承担业务代码。调度系统与任务解耦,提高了系统可用性和稳定性,同时调度系统性能不再受限于任务模块; 支持可视化、简单且动态的管理调度信息,包括任务新建,更新,删除,任务报警等,所有上述操作都会实时生效,同时支持监控调度结果以及执行日志,支持执行器Failover

执行模块(执行器): 负责接收调度请求并执行任务逻辑。任务模块专注于任务的执行等操作,开发和维护更加简单和高效; 接收“调度中心”的执行请求、终止请求和日志请求等

在这里插入图片描述

在这里插入图片描述


3.xxl-job实战

3.1下拉xxl-job源码

官方文档:https://www.xuxueli.com/xxl-job/

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

gitee地址:https://github.com/xuxueli/xxl-job

在这里插入图片描述

可分为有四大模块
doc:存放相关文档
xxl-job-admin:调度中心管理后台
xxl-job-core:框架核心包
xxl-job-executor-samples:集成不同执行器的案例代码
注:本次实战使用的是xxl-job2.1.2版本

3.2构建本地数据库

在这里插入图片描述

可在这个目录下找到对应sql,并在本地执行创建项目所需要的数据库

在这里插入图片描述


3.3修改admin的application.properties并启动管理后台

修改数据库连接

在这里插入图片描述

启动后,访问http://localhost:8080/xxl-job-admin;默认登录账户名:admin。登录密码:123456

在这里插入图片描述

这是登录后先来到运行列表界面,这里以图形化来展示任务整体的执行情况

在这里插入图片描述

这是查看调度日志,根据日志来查看任务具体的执行情况

在这里插入图片描述

这是配置执行器,这边选择自动注册就行,等执行器启动的时候会被调度中心监听到并加入地址列表

在这里插入图片描述

这是配置任务执行任务的,以新配置的测试任务2为例

在这里插入图片描述


路由策略:多用于集群时的配置。这里属于本机测试,所以选第一个

Cron:执行规则,这里定的是两秒执行一次

JobHandler:定义执行器的名字,这里使用的是MyJobHandler


3.3编写执行器代码并测试定时任务

这里以xxl-job-executor-sample-springboot为例:

修改配制文件

xxl.job.admin.addresses:为调度中心的地址

xxl.job.executor.appname:这里对应的是执行器的AppName

xxl.job.executor.port:这里为RPC的监听端口

在这里插入图片描述

编写执行任务,有两种方式
方式一:Bean模式(在方法上使用@XxlJob注解定义执行器)

@Component
public class SampleXxlJob {

    @XxlJob("demoJobHandler")
    public ReturnT<String> demoJobHandler(String param) throws Exception {
        System.out.println("来了!老弟:" + param);
        return new ReturnT<String>(200, "demoJobHandler任务成功");
    }
}

我们执行测试任务1看看效果

在这里插入图片描述

在调度日志里面找出刚刚执行的任务,执行是成功的,这个执行备注就是构造方法ReturnT的第二个参数msg

在这里插入图片描述

方式二:继承IJobHandler的模式(并且在类上使用@JobHandler注解定义执行器)

@JobHandler(value = "MyJobHandler")
@Component
public class MyJobHandler extends IJobHandler {

    @Override
    public ReturnT<String> execute(String param) throws Exception {
        try {
            int a = 10;
            int b = 0;
            System.out.println(a/b);
        } catch (Exception e) {
            StringWriter stringWriter= new StringWriter();
            PrintWriter writer= new PrintWriter(stringWriter);
            e.printStackTrace(writer);
            StringBuffer buffer= stringWriter.getBuffer();
            return new ReturnT<String>(500, buffer.toString());
        }
        return new ReturnT<String>(200, "MyJobHandler任务成功");
    }
}

这里我自己创建了一个异常,就是为了测试调度中心是否可以捕捉到异常信息
那我们现在来执行测试任务2吧
可以看出这次调度是通的,但是执行过程中出现了异常,所以执行结果是失败的,并且异常信息也详细地展示出来

在这里插入图片描述

扫码查看

相关内容

文章评论

表情

共 0 条评论,查看全部
  • 这篇文章还没有收到评论,赶紧来抢沙发吧~

热门标签