Introduction

在xxl-job上做的一些更改，包括代码逻辑完善等。 原先的README文档请看 这里

调整内容

xxl-job-common

• 新增xxl-job-common模块，用于存放admin和core共用的类
• 调整了一些Maven依赖
• 增加了线程池的优雅关闭，以及线程工厂统一命名工具

xxl-job-admin

• 整体SpringBoot化，原来的通过Instance获取单实例的方式调整为Bean注入；
• 一些单线程任务的调整；
• 调度主逻辑的调整，由原先的编程式事务调整为声明式事务，更安全，更简单；
• 在调度逻辑上添加了一些代码注释，方便理解；
• 取消对core模块的依赖，改由引入common模块；
• 增加了对Controller接口的参数校验，方便验证请求；
• 优化了全局异常处理，取消原有的WebExceptionResolver ，使用GlobalExceptionHandler操作全局异常
• 对/api下的所有接口进行了统一的token验证

@Component
public class PermissionInterceptor implements AsyncHandlerInterceptor {
  // 省略

  @Override
  public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
    // 对JobApiController下的接口统一进行token的校验
    if (request.getRequestURI().startsWith(Constants.NEED_CHECK_TOKEN_URI)) {
      if (StringUtils.hasText(adminConfig.getAccessToken()) && !adminConfig.getAccessToken().equals(request.getHeader(Constants.XXL_JOB_ACCESS_TOKEN))) {
        throw new XxlJobException("The access token is wrong.");
      }
    }
    return true;    // proceed with the next interceptor
  }

}

• admin统一对所有注册地址进行探活，删除心跳失败的地址
• 对在admin上手动填写的执行器，也进行统一探活
• 在admin上手动填写执行器的地址时，同步操作xxl_job_registry表

xxl-job-core

• 调整了部分代码，包括例如对象非null，集合非空，以及字符串非空的判断；
• 重构了Executor启动模块的代码，基本都使用了构造函数的方式启动线程；
• 类的一些属性上的调整，例如一些缓存数据，通过单独的类来管理一些缓存数据；
• 一些轮询的线程，如果可以调整为定时任务的，均调整为使用定时任务线程池处理任务，取代原先的定义线程，之后Thread.sleep()的方式实现调度；

public class A {
  ScheduledThreadPoolExecutor threadPool = new ScheduledThreadPoolExecutor();
}

• 删除了非Spring模式下的启动模式；
• 调整了Http服务器的启动方式，改为主线程生成；
• 在部分类中存在线程关闭的场景，也通过Spring的bean生命周期的一些方式，关闭线程或者线程池；

// 例如
public class A implements DisposableBean {
    @Override
    public void destroy() throws Exception {
        // 关闭线程或者线程池
    }
}

优化了部分代码，包括AdminManager的生成方式等，具体见AdminManagerClientWrapper ;

• 在客户端(应用端)增加了添加job,删除job,更新job方法AdminManager;

public class Test {

    @Resources
    private AdminManagerClientWrapper wrapper;

    public void addJob() {
        AddXxlJobInfoDto infoDto = new AddXxlJobInfoDto();
        wrapper.getAdminManager().addJob(infoDto);
    }

    public void deleteJob() {
        DeleteXxlJobInfoDto infoDto = new DeleteXxlJobInfoDto();
        wrapper.getAdminManager().deleteJob(infoDto);
    }

    public void updateJob() {
        UpdateXxlJobInfoDto infoDto = new UpdateXxlJobInfoDto();
        wrapper.getAdminManager().updateJob(infoDto);
    }
}

• 完善了@XxlJob注解功能，提供自动注册job任务
  • 暂时会根据job_desc判断是否重复，不重复则新增
• 取消了重复注册的逻辑，改为只在启动时注册一次，心跳检测改为统一由admin处理
• 当不填写admin的地址时，取消注册的逻辑

xxl-job-spring-boot-starter

• 新增的spring-boot-starter模块;
• 增加了属性的配置项，以及属性关联；
• 增加了启动时xxl-job的启动Logo的打印；
• 调整了spring模式下的一些bean注入的方式，原先都是通过Instance实例的方式获取，后统一通过Spring管理bean。

todo

• 新增调度类型，固定延迟
• XxlJobGroup中的app_name字段唯一性(done)
• XxlJobInfo中的job_desc字段唯一性(done)
• core的Http服务对路由处理，使用策略模式重构
• xxl_job_registry表三个字段唯一(done)
• 优化心跳检测逻辑，僵尸节点持久化，集群环境下的心跳检测使用分布式锁进行单节点检测；
• 使用java时间轮算法优化Admin调度器
• 主从架构，主节点负责任务分发和心跳检测，从节点负责执行任务
• 分布式锁增加spi实现