原文地址：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