ElasticJob 开发者手册-京东云开发者社区

ElasticJob 可插拔架构提供了 SPI 的扩展点。
对于开发者来说，可以十分方便的对功能进行定制化扩展。
 
本章节将 ElasticJob 的 SPI 扩展点悉数列出。
如无特殊需求，用户可以使用 ElasticJob 提供的内置实现；
高级用户则可以参考各个功能模块的接口进行自定义实现。

ElasticJob 社区非常欢迎开发者将自己的实现类反馈至[开源社区](https://github.com/apache/shardingsphere-elasticjob/pulls)，让更多用户从中收益。
# 错误处理策略

错误处理策略，用于作业失败时的处理策略。

| *SPI 名称*              | *详细说明*                         |
| ----------------------- | --------------------------------- |
| JobErrorHandler         | 作业执行错误处理策略                 |

| *已知实现类*             | *详细说明*                          |
| ----------------------- | --------------------------------- |
| LogJobErrorHandler      | 记录作业异常日志，但不中断作业执行     |
| ThrowJobErrorHandler    | 抛出系统异常并中断作业执行            |
| IgnoreJobErrorHandler   | 忽略系统异常且不中断作业执行          |
| EmailJobErrorHandler    | 发送邮件消息通知，但不中断作业执行     |
| WechatJobErrorHandler   | 发送企业微信消息通知，但不中断作业执行 |
| DingtalkJobErrorHandler | 发送钉钉消息通知，但不中断作业执行    |
# 作业类名称提供策略
作业类名称提供策略，用于在不同的容器环境下提供准确的作业类名称。

| *SPI 名称*                       | *详细说明*                        |
| ------------------------------- | --------------------------------- |
| JobClassNameProvider            | 作业类名称提供策略                  |

| *已知实现类*                     | *详细说明*                         |
| ------------------------------- | --------------------------------- |
| DefaultJobClassNameProvider     | 标准环境下的作业类名称提供策略        |
| SpringProxyJobClassNameProvider | Spring 容器环境下的作业类名称提供策略 |
# 线路规划
## Kernel

- [x] Unified Job Config API
    - [x] Core Config
    - [x] Type Config
    - [x] Root Config
- [x] Job Types
    - [x] Simple
    - [x] Dataflow
    - [x] Script
    - [x] Http（3.0.0-beta 提供）
- [x] Event Trace
    - [x] Event Publisher
    - [x] Database Event Listener
    - [ ] Other Event Listener
- [ ] Unified Schedule API
- [ ] Unified Resource API

## ElasticJob-Lite

- [x] Distributed Features
    - [x] High Availability
    - [x] Elastic scale in/out
    - [x] Failover
    - [x] Misfire
    - [x] Idempotency
    - [x] Reconcile
- [x] Registry Center
    - [x] ZooKeeper
    - [ ] Other Registry Center Supported
- [x] Lifecycle Management
    - [x] Add/Remove
    - [x] Pause/Resume
    - [x] Disable/Enable
    - [x] Shutdown
    - [x] Restful API
    - [x] Web Console
- [x] Job Dependency
    - [x] Listener
    - [ ] DAG
- [x] Spring Integrate
    - [x] Namespace
    - [x] Bean Injection
    - [x] Spring Boot Starter（3.0.0-alpha 提供）

## ElasticJob-Cloud
- [x] Transient Job
    - [x] High Availability
    - [x] Elastic scale in/out
    - [x] Failover
    - [x] Misfire
    - [x] Idempotency
- [x] Daemon Job
    - [x] High Availability
    - [x] Elastic scale in/out
    - [ ] Failover
    - [ ] Misfire
    - [x] Idempotency
- [x] Mesos Scheduler
    - [x] High Availability
    - [x] Reconcile
    - [ ] Redis Based Queue Improvement
    - [ ] Http Driver
- [x] Mesos Executor
    - [x] Executor Reuse Pool
    - [ ] Progress Reporting
    - [ ] Health Detection
    - [ ] Log Redirect
- [x] Lifecycle Management
    - [x] Job Add/Remove
    - [ ] Job Pause/Resume
    - [x] Job Disable/Enable
    - [ ] Job Shutdown
    - [x] App Add/Remove
    - [x] App Disable/Enable
    - [x] Restful API
    - [x] Web Console
- [ ] Job Dependency
    - [ ] Listener
    - [ ] Workflow
    - [ ] DAG
- [x] Job Distribution
    - [x] Mesos Based Distribution
    - [ ] Docker Based Distribution
- [x] Resources Management
    - [x] Resources Allocate
    - [ ] Cross Data Center
    - [ ] A/B Test
- [x] Spring Integrate
    - [x] Bean Injection

# 作业分片策略

作业分片策略，用于将作业在分布式环境下分解成为任务使用。

| *SPI 名称*                             | *详细说明*                                                     |
| ------------------------------------- | ------------------------------------------------------------- |
| JobShardingStrategy                   | 作业分片策略                                                    |

| *已知实现类*                           | *详细说明*                                                      |
| ------------------------------------- | -------------------------------------------------------------- |
| AverageAllocationJobShardingStrategy  | 根据分片项平均分片                                               |
| OdevitySortByNameJobShardingStrategy  | 根据作业名称哈希值的奇偶数决定按照作业服务器 IP 升序或是降序的方式分片 |
| RotateServerByNameJobShardingStrategy | 根据作业名称轮询分片                                             |

# 线程池策略

线程池策略，用于执行作业的线程池创建。

| *SPI 名称*                             | *详细说明*                         |
| ------------------------------------- | --------------------------------- |
| JobExecutorServiceHandler             | 作业执行线程池策略                  |

| *已知实现类*                           | *详细说明*                         |
| ------------------------------------- | --------------------------------- |
| CPUUsageJobExecutorServiceHandler     | 根据 CPU 核数 * 2 创建作业处理线程池 |
| SingleThreadJobExecutorServiceHandler | 使用单线程处理作业                  |