2023-02-18 20:36:50 浏览:3714 作者:管理员
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吧
可以看出这次调度是通的,但是执行过程中出现了异常,所以执行结果是失败的,并且异常信息也详细地展示出来
上一篇:
使用frp工具实现内网穿透连接
下一篇:
查看Linux ssh登录、访问记录