数据流转 · 开箱即用

轻量消息驱动型数据管道工具

在 Web 管理端把「跨库同步 / 批处理 / 调存储过程」配成可复用任务,通过 MQ / 定时 / 手动触发执行,并提供完整的日志、脏数据、死信与审计能力。

当前版本 v1.3.0 · Windows / Linux · 运行仅需 JRE 21+

为什么选 RockPipe

它不是大数据集群,也不是全功能 ETL / 实时流平台,而是企业数据流转的轻量调度中枢。

跨平台 · 开箱即用

支持 Windows、Linux;ZIP 含 jar、预构建前端与启停脚本。现场只需 JRE 21+,无需 Node / Maven / 独立前端部署。

配置即可用

数据源、任务节点可视化编排;SQL 占位符助手降低编写成本;消息队列按需配置。

多种触发

可选 RocketMQ 消息、定时 Cron、运维「立即执行」,可组合;不强制部署 MQ。

可测可发

流程测试与正式发布分离,改完先测再上线。

运维闭环

执行日志 → 节点详情 → 脏数据 / 死信 → 审计 / 健康检查。

安全可控

登录认证、三角色权限、IP 白名单、密码策略、强制改密。

产品形态

管理端与执行后端同包单进程托管,解压启动后通过浏览器安装向导即可。

运维 / 开发

管理端(Web)

数据源、MQ、任务编排、测试、发布、运维查询。

系统自动运行

执行后端

消费触发、按节点执行、写日志与容错。与管理端同一 ZIP、同一进程托管。

产品界面

管理端实机截图:任务列表与编排。

RockPipe 管理端 — 任务列表
任务列表 — 运行区 / 工作区,行内立即执行、编排、发布与执行日志
RockPipe 管理端 — 任务编排
任务编排 — 任务属性、节点编排,顶栏流程测试 / 去发布 / 保存

功能亮点

配置数据源与任务,测试通过后发布,执行过程可查可追。

数据源

按库类型选 JDBC 模板,填写账号密码与连接池;保存前可测试连接。密码加密存储。

消息队列(按需)

仅当任务启用 MQ 触发时需要。仅用定时 / 手动触发可不配置、不部署 RocketMQ。

任务编排

依赖条件、抽取、加载、执行 SQL / SQL 脚本可视化编排;占位符助手预览替换效果。

流程测试与发布

流式展示各节点结果与耗时;测试通过后再发布启用,改完先测再上线。

执行与运维

任务侧执行日志抽屉;全局日志、脏数据、死信、健康与审计可查可导出。

安全与治理

超管 / 管理员 / 普通用户三角色、IP 白名单、密码策略与强制改密。

下载 RockPipe

ZIP 绿色包,解压即可启动。需要试用、部署协助或技术交流,也可通过顶栏「联系」沟通。