其他分享
首页 > 其他分享> > xxl-job(分布式任务调度平台)学习笔记 2022-07-25

xxl-job(分布式任务调度平台)学习笔记 2022-07-25

作者:互联网

原文地址:https://blog.csdn.net/weixin_43821679/article/details/109896696

1、传统定时任务

1.1 实现方法

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

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

1.1.2 根据业务需要,在方法上使用@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.1.3 启动项目就可以看控制台看到定时任务执行效果

1.2 缺点分析

2 初识xxl-job

3 xxl-job实战

3.1 源码


可分为有四大模块
doc:存放相关文档
xxl-job-admin:调度中心管理后台
xxl-job-core:框架核心包
xxl-job-executor-samples:集成不同执行器的案例代码

3.2 构建本地数据库


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

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

修改数据库连接,主要是修改username与password

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

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

任务管理,配置任务执行任务
调度日志,根据日志来查看任务具体的执行情况
执行器管理,选择自动注册就行,等执行器启动的时候会被调度中心监听到并加入地址列表

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

这里以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任务成功");
}

}

方式二:继承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任务成功");
    }
}

标签:执行器,25,07,任务,job,new,任务调度,public,xxl
来源: https://www.cnblogs.com/ziweigege/p/16516248.html