rulego 是一款基于 go 语言打造的轻量级、高效率、可嵌入、支持组件化编排的新一代规则引擎。它助力开发者快速构建松耦合、高灵活性的系统，轻松应对复杂多变的业务逻辑。rulego 内置丰富的可复用组件，涵盖数据聚合、条件过滤、消息分发、格式转换、上下文丰富化以及各类动作执行等能力，并原生支持与多种协议（如 http、mqtt、grpc、websocket 等）及外部系统无缝对接与集成，广泛适用于自动化营销、物联网平台、企业应用集成等场景。其架构在内存占用与运行性能方面经过深度优化，资源消耗极低——既可部署于云端支撑高并发请求，也适配边缘设备，在资源受限环境下稳定运行，完美契合边缘计算与 iot 实时处理需求。
该项目已在低代码开发、业务逻辑编排、异构数据集成、工作流引擎、大模型智能体协同、边缘智能、流程自动化、IoT 平台等多个前沿技术领域展现出强大的适应性与扩展潜力。
典型应用场景
-
边缘智能处理： 可将
RuleGo部署于边缘服务器，对原始设备数据进行本地预处理（如筛选、聚合、统计计算），再按需上传至云端；所有处理与分发逻辑均通过规则链动态配置，无需重启服务即可生效，是国产化替代Node-RED的理想选择。 - 物联网平台中枢： 接收海量设备上报数据，依据规则链完成实时判断与响应，触发单个或多个联动动作，例如发送邮件通知、推送告警消息、调用其他设备接口或对接第三方系统。
- 智能数据路由： 根据消息类型、内容标签或元数据特征，自动选择 HTTP、MQTT 或 gRPC 协议，将数据精准分发至不同下游系统。
- 跨系统集成枢纽： 充当“数字胶水”，灵活连接各类异构系统与通信协议，包括 gRPC 服务、SSH 命令、Webhook 回调、Kafka 消息队列、关系型/时序数据库、ChatGPT 接口及各类 SaaS 应用系统。
- 多源异构数据统一治理： 支持从 MQTT、HTTP、WebSocket、消息中间件（如 RabbitMQ/Kafka）、gRPC、TCP/UDP 等多种协议接入数据，统一完成清洗、过滤、结构化转换后，分发至数据库、核心业务系统或可视化仪表盘。
-
高频变更业务解耦： 将易变、强定制化的业务模块抽离主程序，交由
RuleGo规则链统一管理，实现业务策略热更新，避免因逻辑调整导致服务重启。 -
复杂业务流程编排： 将核心业务能力封装为自定义组件，借助
RuleGo进行图形化或代码化编排与调度，支持运行时动态替换、参数化配置与逻辑重组。 - 微服务协同中枢： 对接并编排多个微服务节点，或按需动态调用第三方 API 完成特定任务，统一聚合结果并返回给上游。
- 业务代码与规则逻辑分离： 如用户积分体系、信贷风控引擎等典型场景，将判定逻辑下沉至规则层，提升可维护性与策略迭代效率。
- 端到端自动化平台： 覆盖 CI/CD 流水线、RPA 流程自动化、营销活动引擎、量化交易系统等多样化自动化需求。
-
低代码/无代码平台底座： 可作为低代码平台、iPaaS 集成平台、ETL 工具或类
Langflow/Dify的 AI 应用框架核心引擎——例如对接大模型解析用户意图后，自动触发对应规则链，驱动后续系统交互或业务处理。 - MCP（Model Context Protocol）服务支持： 自动将规则链（即工作流）、组件能力、开放 API 注册为标准 MCP 工具，供 AI 智能体直接调用；企业可通过 RuleGo 快速打通 AI 能力与现有业务系统的最后一环，实现真正的智能协同。
架构图
可视化界面
风格 1：
风格 2：
本次更新日志
rulego-core
- feat(components): join 组件新增错误透传能力，支持将执行异常传递至后续节点
- feat(components): end 组件增强错误处理机制，允许将前序节点异常信息注入回调函数
- feat(components): 新增 break 组件，用于显式中断当前规则链执行流程
- feat(components): for 循环组件支持运行时中断控制（break/continue 语义）
- feat(components): delay 延迟组件支持从消息元数据中动态读取时间偏移量
- feat(components): join/groupAction 组件支持将各分支执行结果合并至同一 map 结构
- feat(components): function 函数组件支持参数化配置，提升复用灵活性
- feat(components): 函数注册接口新增 display name 与 description 字段，便于可视化展示与说明
- feat: 规则链执行支持实例级取消操作，提升任务可控性
- feat: 引擎新增多节点执行状态恢复能力，保障断点续执可靠性
- feat: 新增 Config.OnEndWithFailure 配置项，控制发生错误时是否仍触发 onEnd 回调
- fix: 修复部分边界条件下引擎 onEnd 回调未被正确调用的问题
- fix: 解决执行快照（snapshot）写入过程中的数据竞争风险
- perf: 优化超时控制上下文创建与销毁性能，降低延迟开销
- perf: 调整 onEnd 回调执行顺序，确保逻辑一致性与可观测性
- chore(ci): 编译产物体积压缩，减小发布包尺寸
rulego-components
- feat: OPC UA write 组件扩展数据类型支持，覆盖 int、double、数组等多种常见类型
- chore(ci): 升级底层依赖库版本，提升安全性与兼容性
本次重点说明
- 本版本聚焦稳定性提升，集中修复多项关键 Bug，强烈建议用户升级以获得更健壮的运行体验。
- 诚邀参与 Gitee 2025 年度最受欢迎开源项目评选活动，为 RuleGo 投上宝贵一票！? ? (RuleGo)
- 诚邀参与 Gitee 2025 年度最受欢迎开源项目评选活动，为 StreamSQL 投上宝贵一票！? ? (StreamSQL)
其他信息
- 欢迎前往 Gitee 或 GitHub 提交 Issue、PR 或使用建议
- 若认可本项目价值，欢迎点亮 Star 支持我们持续演进
- 官方文档站点：rulego.cc
- 在线编辑器地址：editor.rulego.cc
- 体验地址 1
- 体验地址 2
源码获取地址：点击下载
