1. 任务中心

​ 任务中心用于对应用使用了xxl-job进行任务调度的管理,该功能依赖于xxl-job,应用可以使用原生的xxl-job使用方法;还有一种方法是应用在集成的时候使用NTC的封装进行使用。这两种方式只是应用集成xxl-job的不同,xxl-job管理界面可以不用原生提供的管理界面了,通过NTC管控台界面进行统一管理。下面主要介绍NTC封装的使用方法,原生的使用请参考xxl-job本身,这里不多加叙述。不管哪一种方法,都是需要安装xxl-job服务端的,NTC提供了一键部署的功能完成xxl-job的安装。

​ 所以在应用接入时请根据有无上述需求决定是否接入任务中心,具体的接入流程如下:

​ 1.安装mysql和xxl-job服务端,由于mysql和xxl-job服务端部署包等资料比较大,很多项目又没有这个任务中心这个需求,所以默认部署包ntc-版本号.zip没有提供,需要的时候可以向NTC团队申请ntcshell xxl-job package.zip,并且按照压缩包里面readme.txt进行操作即可。

​ 2.如果是原生使用xxl-job,做到这步骤就可以了,管控界面登录NTC任务中心菜单操作即可。

​ 3.点击应用中心-应用探针,点击对应系统配置管理

1589418838345

​ 4.开启任务执行器服务。

1616665837982

​ 4.设置执行器服务参数,指定地址和端口,在应用的属性文件进行设置(可以像快速接入一样跟其他探针属性设置在一起),如下属性:

#调度中心IP地址,可以手动进行修改,多个用逗号分隔
next.executorService.adminIps=127.0.0.1
#执行器端口,小于等于0则自动获取;默认端口为9999,单机部署多个执行器时,注意要配置不同执行器端口
next.executorService.port=9999

​ 5.接下来可以使用NTC封装的注解进行任务的定义,如下

​ @NextJob:使用在方法上,用于标识一个任务

​ 示例代码如下


  private static Log log = LogFactory.getLog(SampleNextJob.class);

  @NextJob(id = "demoJobHandler", name = "示例任务1")
  public ReturnT<String> demoJobHandler(String param) throws Exception {
    log.info("demoJobHandler.");
    log.info("param:" + param);
    for (int i = 0; i < 5; i++) {
      log.info("beat at:" + i);
      TimeUnit.SECONDS.sleep(2);
    }
    return ReturnT.SUCCESS;
  }

  @NextJob(id = "demoJobHandler2", name = "示例任务2")
  public ReturnT<String> demoJobHandler2(String param) {
    log.info("demoJobHandler2.");
    for (int i = 0; i < 5; i++) {
      log.info("beat at:" + i);
    }
    return ReturnT.SUCCESS;
  }

results matching ""

    No results matching ""