XXL 从

大家好，我是君哥。

散布式义务调度平台口头一次性调度义务，普通会教训上方的环节。

在上图中，调度中心从注册中心拉取口头器列表，而后选用一个口头器来口头义务，义务口头成功后，口头器会把义务口头结果通知调度中心。

干流的散布式义务调度平台，比如 XXL-JOB、PowerJob 等都设计了调度中心、口头器这两个外围组件。

调度中心的作用不光是便捷的义务触发，还包含治理口头器列表、义务结果治理等。

义务调度模式重要包含定时调度和 API 触发调度。

定时调度有两种模式，一种是调度中心在性能的义务口头期间给口头器发送义务调度信号，间接把义务动员。第二种是调度中心给义务口头器发送义务触发期间，义务口头器自己触发，比如经常使用提前队列。

API 触发调度普通是调度中心收到外部 API 恳求后，动员义务调度。

调度中心可以创立、降级、删除义务。下图来自 XXL-JOB 官方，XXL-JOB 在调度中心性能义务。

调度中心监控义务口头结果，检查义务口头日志，关于口头失败的义务也可以采取一些处置措施，比如从新触发义务口头。

定时义务对口头开局期间有要求，这就须要调度中心能够高效地把义务调度恳求收回去，不能积压调度义务。

调度战略选择了调度中心选用哪一个口头器来口头义务，比如第一个、最后一个、随机、轮询、广播等。

口头器是散布式义务调度系统中最外围的局部，它是真正口头跑批义务、选择跑批结果的组件。

口头器要想收到义务触发信号，必定首先在注册中心启动注册，被调度中心成功拉取到。

注册成功后，须要周期性地给注册中心发送心跳，让调度中心感知到。

为了保障整个调度平台的高可用，口头器必定集群部署，这样假设调度中心选用调度的节点产生缺点，可以启动重试把信号发送给下一个节点，不用担忧义务不能被成功调度。

口头器为了提高口头效率，普通会启动多线程。口头器应该能允许线程数量灵敏性能。比如一个数据量比拟大的义务，可以性能多线程分段处置。但为了不影响同一个口头器上的其余义务，不能把线程数性能地太高，比如可以经常使用一半的线程处置当前义务。

关于愈加复杂的批量义务，也可以设计成多个口头器介入来提高效率。比如一个义务调度到 4 个口头器口头，每个口头器 4 个线程介入，提高口头效率。

当一切的口头器都满负荷运转，会产生义务排队的状况，假设口头器集群可以灵活扩容，就可以参与几个口头器节点，调度中心把义务调度到新的节点上。

单个口头器很或许会产生批次义务排队的状况，有必要采取一些阻塞控制战略。比如依照入队顺序依次口头，或许摈弃排队的义务间接给调度中心前往失败。

调度中心和口头器是散布式义务调度平台的两个外围组件，调度中心担任义务触发和调度，口头器担任义务口头和结果反应。了解了这 2 个外围概念，就可以很容易地理解干流散布式调度平台的设计原理了。