用一份 JSON 串起 HTTP / Dubbo / WebService / SQL / 脚本：开源服务编排引擎 service-arrange

源码仓库Gitee·GitHub写在前面日常业务里一个“下单”动作背后往往要调十几个接口HTTP 主单服务、Dubbo 库存、WebService 老物流、一段 SQL 校验、再加个 Shell 通知脚本。写死在代码里链路看不清、改动牵一发动全身换个顺序、加个失败补偿就得发版。service-arrange想解决的就是这件事把这条调用链画成一张图导出成一份 DSLJSON由引擎负责解析、调度、重试、补偿和追踪。改流程不用改代码改图就行。它是什么一个基于 DSL 的轻量级服务编排Service Arrangement引擎 可视化编排控制台前端画布产出 DSLJSON——全系统唯一契约后端引擎负责解析 → 调度 → 执行 → 编排决策 / 循环 / 补偿消息驱动RabbitMQ Spring Cloud Stream、MongoDB 存储、ZooKeeper 分布式锁。定位类比轻量版工作流引擎但强调“服务调用”而非“人工审批”。核心能力1. DSL 即契约节点与连线同构连线本身也是一个 Cell扁平cells数组 groups补偿组 运行期全局参数。取值表达式统一为#节点id$jsonpath支持#header_$X-Token、#dynamicParams_$idx等。前端导出与后端解析严格遵循同一份规范含 11 条校验规则 R1~R11。2. 可视化编排控制台零依赖纯 HTML5 ES5 JavaScript无框架、无构建、无 npm installnode serve.js即可跑起来。左侧分类折叠调色板、右键菜单、双击编辑、属性面板分组、连线圆头圆角、历史脏数据自愈支持导入导出与 DSL 校验。3. 20 种算子覆盖主流调用形态类别算子外部调用HTTP、SQLJDBC 直连、DubboHTTP 网关泛化、WebServiceSOAP脚本Shell、Jar、Python内部算子数据映射、规则转换、数据结果、决策、JSON↔XML 互转、延时补偿数据映射补偿、HTTP / Dubbo / WebService 补偿画布上统一算子节点node_op真实类型由data.opType延迟解析CellTypeMapper新增算子无需改引擎调度代码。4. 完整的流程治理Plan草稿 / 发布 / 停用 版本快照生产可开启发布门禁require-published仅已发布 Plan 可运行运行幂等X-Idempotency-Key命中直接返回既有实例全链路traceIdTraceFilter→ MDC →Inst单任务超时RetryRules.timeoutMs优先全局兜底失败按RetryRules重试并受退避上限保护实例取消 / 恢复GET /health应用 Mongo 双探活。5. 可靠性设计ZooKeeper 实例级分布式锁保证同一实例串行调度抢锁失败带次数上限的线性退避重排队超限强制 ack 丢弃防消息热点空转毒消息处理次数上限循环线次数上限防条件恒真打满线程失败走补偿分支支持补偿强组合实现局部事务回滚。6. 工程细节统一返回{code, msg, data}RestControllerAdvice全局异常IllegalArgumentException→ 400HTTP / Dubbo / MongoDB 出网超时Mongo 连接池参数消费端并发与背压阈值全部可配置。架构浏览器 ──REST──▶ web 模块Inst / Plan / InstQuery / InstLog / Health 控制器 TraceFilter GlobalExceptionHandler │ ▼ engine 核心引擎 DslParser ──▶ Inst图结构──▶ TaskInterface(convert) ──▶ Task │ │ │ TaskRunConsumer ◀── TaskProductor ◀──┘ │ │ │ Execute.runProcess按 cellType 路由到 20 个算子 │ │ └── TaskResultConsumer加 ZK 实例锁 → 决策/循环/补偿编排 → 投递下一批 │ ┌─────────────────┼─────────────────┐ ▼ ▼ ▼ RabbitMQ MongoDB ZooKeeper技术栈Java 8 / Maven 多模块、Spring Boot Spring Cloud Stream、Spring Data MongoDB、Curator ZooKeeper、SpEL 自定义取值表达式、Hutool前端零依赖静态站点。快速开始前置依赖JDK 8、Maven、MongoDB27017、RabbitMQ5672、ZooKeeper2181。# 1. 克隆Gitee 主仓库 / GitHub 镜像 git clone https://gitee.com/huangrenhui/service-arrange.git cd service-arrange 2. 构建并启动后端默认 8082上下文路径 /servicearrange mvn clean package -DskipTests java -jar backend/web/target/service-arrange.jar 3. 启动前端控制台零依赖127.0.0.1:5173 cd frontend node serve.js验证服务就绪curl http://localhost:8082/servicearrange/health # {code:200,msg:success,data:{status:UP,mongo:UP}}30 秒跑通一条流程# 1. 保存流程模型DSL 可从控制台导出或参考 backend/web/src/main/resources/hrh_http.json curl -X POST http://localhost:8082/servicearrange/plan/save \ -H Content-Type: application/json \ -d {name:订单链路,dsl:{...},remark:demo} 2. 发布生产建议 task.orchestration.require-published: true curl -X POST http://localhost:8082/servicearrange/plan/publish?idplanId 3. 运行幂等键可选traceId 自动生成 curl -X POST http://localhost:8082/servicearrange/inst/run/or/getResult/planId?servea_optTyperun -H X-Idempotency-Key: order-20261018-001 -H Content-Type: application/json -d {orderId:A1001} 4. 观察 curl http://localhost:8082/servicearrange/inst/detail?idinstId # 实例 任务 日志 curl http://localhost:8082/servicearrange/instlog/list?instIdinstId # 节点级日志共 17 个 REST 接口流程模型 6 个、运行实例 1 个、实例查询与干预 4 个、实例日志 1 个、算子注册 4 个、健康检查 1 个。界面一览控制台共 6 个视图实例列表、编排设计器、运行记录、运行详情、算子注册、Schema 工具。实例列表展示状态徽标、发布状态与版本、节点数与运行次数每个实例可直接进入编排 / 发布 / 运行 / 运行记录。编排设计器是核心左侧为分类节点库HTTP / SQL / Shell / 内部算子画布支持普通线、决策线、循环线、补偿线四种线型节点可拖拽、右键菜单编辑、属性面板分组配置顶部工具栏提供导入 / 导出 / 校验 / 保存 / 发布 / 保存并运行。运行记录与运行详情每次运行生成一条记录详情页的编排图按结果染色成功 / 失败 / 跳过 / 运行中 / 未执行并可下钻到算子级日志。算子注册把外部 API 登记成可复用资产注册后即可在任意实例的编排页拖拽使用Schema 工具用于维护开始 / 结束节点的出入参 Schema。点「保存并运行」时开始节点的 JsonSchema 会自动渲染成运行入参表单一个完整案例订单履约链路带补偿流程开始 → 数据映射组装入参→ HTTP 主单 → WebService 物流 → 结束同时为 HTTP 节点挂接补偿组补偿数据映射 → HTTP 补偿任一节点失败即触发补偿回滚。成功运行6 个节点全部成功实例状态SUCCESS出参携带物流单号即上面 04 / 05 两张图。失败运行WebService 物流节点连接超时 → 实例记ERRO日志 → 命中补偿线 → 依次执行 HTTP 补偿 / Dubbo 补偿 → 实例置FAIL未执行节点置「跳过」这就是「局部事务 补偿」的落地形态不引入分布式事务协议用一张图把回滚动作声明出来失败路径与成功路径同样可观测。文档仓库内置 17 篇文档从入门到运维全覆盖快速开始、项目总览、DSL 规范唯一契约、执行引擎与调度流程、数据模型与消息模型、REST 接口说明、企业编排能力、算子扩展指南、前端控制台说明、配置说明、部署指南、测试指南、系统架构、编码规范、功能清单、项目现状、文档说明。入口从docs/文档说明.md开始按角色给了最短阅读路径。文档仓库内置 17 篇文档从入门到运维全覆盖快速开始、项目总览、DSL 规范唯一契约、执行引擎与调度流程、数据模型与消息模型、REST 接口说明、企业编排能力、算子扩展指南、前端控制台说明、配置说明、部署指南、测试指南、系统架构、编码规范、功能清单、项目现状、文档说明。入口从docs/文档说明.md开始按角色给了最短阅读路径。仓库地址Gitee主仓库https://gitee.com/huangrenhui/service-arrangeGitHub镜像https://github.com/HuangRenhui/service-arrangeLicenseGPL-3.0。结语如果你也在为“散落各处的服务调用怎么串成一条可观测、可重试、可补偿的链路”头疼可以拿它当一个轻量起点DSL 契约清晰、算子可插拔、控制台零依赖开箱即用文档把每个设计决策和实现差距都写清楚了。欢迎 Star / Issue / PR。