宜信开源微服务任务调度平台（SIA-TASK）

时间 2019-11-08

原文原文链接

背景

不管是互联网应用或者企业级应用，都充斥着大量的批处理任务。经常须要一些任务调度系统帮助开发者解决问题。随着微服务化架构的逐步演进，单体架构逐渐演变为分布式、微服务架构。在此的背景下，不少原先的任务调度平台已经不能知足业务系统的需求。因而出现了一些基于分布式的任务调度平台。这些平台各有其特色，但各有不足之处，好比不支持任务编排、与业务高耦合、不支持跨平台等问题。很是不符合新一代微服务架构的需求，所以宜信公司开发了微服务任务调度平台（SIA-TASK）。git

SIA是宜信公司基础开发平台Simple is Awesome的简称，SIA-TASK（微服务任务调度平台）是其中的一项重要产品，SIA-TASK契合当前微服务架构模式，具备跨平台，可编排，高可用，无侵入，一致性，异步并行，动态扩展，实时监控等特色。github

项目简介

SIA-TASK是任务调度的一体式解决方案。对任务进行元数据采集，而后进行任务可视化编排，最终进行任务调度，而且对任务采起全流程监控，简单易用。对业务彻底无侵入，经过简单灵活的配置便可生成符合预期的任务调度模型。sql

SIA-TASK借鉴微服务的设计思想，获取分布在每一个任务执行器上的任务元数据，上传到任务注册中心。利用在线方式进行任务编排，可动态修改任务时钟，采用HTTP做为任务调度协议，统一使用JSON数据格式，由调度中心进行时钟解析，执行任务流程，进行任务通知。多线程

关键术语

任务（Task）: 基本执行单元，执行器对外暴露的一个HTTP调用接口;
做业（Job）: 由一个或者多个存在相互逻辑关系（串行/并行）的任务组成，任务调度中心调度的最小单位;
计划（Plan）: 由若干个顺序执行的做业组成，每一个做业都有本身的执行周期，计划没有执行周期;
任务调度中心（Scheduler）: 根据每一个的做业的执行周期进行调度，即按照计划、做业、任务的逻辑进行HTTP请求;
任务编排中心（Config）: 编排中心使用任务来建立计划和做业;
任务执行器（Executer）: 接收HTTP请求进行业务逻辑的执行;
Hunter：Spring项目扩展包，负责执行器中的任务抓取，上传注册中心，业务可依赖该组件进行Task编写。

微服务任务调度平台的特性

基于注解自动抓取任务，在暴露成HTTP服务的方法上加入@OnlineTask注解，@OnlineTask会自动抓取方法所在的IP地址，端口，请求路径，请求方法，请求参数格式等信息上传到任务注册中心(zookeeper)，并同步写入持久化存储中，此方法即任务;
基于注解无侵入多线程控制，单一任务实例必须保持单线程运行，任务调度框架自动拦截@OnlineTask注解进行单线程运行控制，保持在一个任务运行时不会被再次调度。并且整个控制过程对开发者彻底无感知。
调度器自适应任务分配，任务执行过程当中出现失败，异常时。能够根据任务定制的策略进行多点从新唤醒任务，保证任务的不间断执行。
高度灵活任务编排模式，SIA-TASK的设计思想是以任务为原子，把多个任务按照执行的关系组合起来造成一个做业。同时运行时分为任务调度中心和任务编排中心，使得做业的调度和做业的编排分隔开来，互不影响。在咱们须要调整做业的流程时，只须要在编排中心进行处理便可。同时编排中心支持任务按照串行，并行，分支等方式组织关系。在相同任务不一样任务实例时，也支持多种调度方式进行处理。