java 分布式调度,ideal-job

今天药忘吃喽~ 2023-01-13 09:17 62阅读 0赞

![3c0538f87b98e695038e4d841e13e17b.png][]

![License-GPL%203.0-blue.svg?longCache=true&style=flat-square][License-GPL_203.0-blue.svg_longCache_true_style_flat-square]

![Spring%20Boot-2.3.3-yellow.svg?style=flat-square][Spring_20Boot-2.3.3-yellow.svg_style_flat-square]

![Project%20Reactor-Dysprosium%20SR12-orange.svg?longCache=true&style=flat-square][Project_20Reactor-Dysprosium_20SR12-orange.svg_longCache_true_style_flat-square]

![RSocket-1.0.2-brightgreen.svg?longCache=true&style=flat-square][RSocket-1.0.2-brightgreen.svg_longCache_true_style_flat-square]

介绍

ideal-job是一个分布式任务调度系统，其设计目标是简单可靠、易于上手、能够以低耦合的方式与业务系统进行集成。

工程结构

ideal-job

├── ideal-job-common -- 公共模块

├── ideal-job-samples -- 示例模块

├ └── ideal-job-sample-springboot -- springboot搭建的执行器示例

├── ideal-job-scheduler -- 调度器模块

├ ├── http\_script -- 调度器http接口调用脚本

├ ├── ideal-job-scheduler-api -- 开放api接口，业务方引用该api内定义的接口实现任务管理

├ ├── ideal-job-scheduler-client -- 开放api接口的http客户端实现

├ ├── ideal-job-scheduler-client-springboot-starter -- 开放api接口的http客户端springboot-starter

├ ├── ideal-job-scheduler-core -- 调度器核心代码

├ └── ideal-job-scheduler-server -- 调度器服务

├── ideal-job-worker -- 执行器核心依赖

└── ideal-job-worker-springboot-starter -- 执行器springboot-starter

页面预览

本工程仅包含后端服务模块，前端管理页面见 ideal-job-web。

调度器管理页面

![5cce6824eee9041b0278dcebd0ef537f.png][]

任务管理页面

![51d154f697df136fc273ef00ffbddbb9.png][]

软件架构

![6ad0d28508805603e6be4d568e6964ae.png][]

部署方式

调度器支持单点和集群方式部署。

数据存储

元数据存储在关系型数据库中。

客户端接入

提供java sdk，通过Rsocket与调度器集群建立长连接。

消息可靠性

集群内部维护客户端注册表，只要客户端连接到任意一个集群节点便可保障消息不丢失。

服务性能

调度器采用reactive stream技术栈，除数据库操作(默认JPA模式下，后续考虑引入R2DBC)外均为异步IO，可保证服务器资源最大化利用。

特性

提供简单易用的web管理页面。

功能丰富的openAPI，采用HTTP对外提供服务(提供Java SDK)。可通过接口对任务进行管理，方便业务系统无缝集成。

多种任务负载均衡策略。

安装教程

将代码clone到本地。

修改ideal-job-scheduler-server模块下配置文件的数据库和redis配置。

maven打包通过java命令运行，也可在IDE中直接运行。

注意： 服务端需要监听两个端口，他们分别是：

server.por http服务端口，对外提供任务管理功能。

spring.rsocket.server.port roskcet监听端口，客户端通过此端口与调度器建立连接。

使用说明

xxxx

TODO

添加WEB管理页面。

任务执行日志采集、web页面支持日志实时刷新。

服务监控和异常告警功能。

[3c0538f87b98e695038e4d841e13e17b.png]: /images/20221022/ce97b94c56464c259d6195aac68bb543.png
[License-GPL_203.0-blue.svg_longCache_true_style_flat-square]: https://img.shields.io/badge/License-GPL%203.0-blue.svg?longCache=true&style=flat-square
[Spring_20Boot-2.3.3-yellow.svg_style_flat-square]: https://img.shields.io/badge/Spring%20Boot-2.3.3-yellow.svg?style=flat-square
[Project_20Reactor-Dysprosium_20SR12-orange.svg_longCache_true_style_flat-square]: https://img.shields.io/badge/Project%20Reactor-Dysprosium%20SR12-orange.svg?longCache=true&style=flat-square
[RSocket-1.0.2-brightgreen.svg_longCache_true_style_flat-square]: https://img.shields.io/badge/RSocket-1.0.2-brightgreen.svg?longCache=true&style=flat-square
[5cce6824eee9041b0278dcebd0ef537f.png]: /images/20221022/1325c3bb52a743bdae4b80c8da0801a2.png
[51d154f697df136fc273ef00ffbddbb9.png]: /images/20221022/32315023f0944bf3a9646aff6df19b61.png
[6ad0d28508805603e6be4d568e6964ae.png]: /images/20221022/f295af07e32645a6bee7ffb67684d1f8.png