RuleGo RuleGo
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 流式计算
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • 🌊StreamSQL
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 流式计算
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • 🌊StreamSQL
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文

广告采用随机轮播方式显示 ❤️成为赞助商
  • 快速入门

  • 规则链

  • 标准组件

    • 标准组件概述
    • 公共

      • 节点引用
      • 节点组
      • 迭代器
      • 遍历
      • 并行网关
      • 汇聚
      • 条件分支
      • 包容分支
        • 配置
        • Relation Type
        • 执行结果
        • 与条件分支的区别
        • 配置示例
      • 中断(break)
      • 结束节点
    • 过滤器

    • 动作

    • 转换器

    • 外部的

    • 流

  • 扩展组件

  • 自定义组件

  • 组件市场

  • 可视化

  • AOP

  • 触发器

  • 高级主题

  • RuleGo-Server

  • 问题

目录

包容分支

inclusive组件:包容分支组件。与switch条件分支不同,inclusive会评估所有配置的case表达式,并将消息同时路由到所有匹配的关系;如果无任何匹配,则路由到默认的Default关系;当表达式执行出错时,消息将被路由到Failure关系。

# 配置

字段 类型 说明 默认值
cases Case列表 条件表达式列表 无

Case配置项:

字段 类型 说明 默认值
case string 条件表达式 无
then string 路由关系名称 无

表达式使用 expr (opens new window) 引擎,支持以下内置变量:

  • id - 消息ID
  • ts - 消息时间戳(毫秒)
  • data - 消息原始内容
  • msg - 消息体。若dataType为JSON,可通过 msg.field 访问字段,例如: msg.temperature > 50
  • metadata - 消息元数据,例如 metadata.customerName
  • type - 消息类型
  • dataType - 数据类型

表达式示例:

  • msg.temperature > 50
  • msg.temperature > 50 && metadata.customerName == 'rulego'
  • upper(metadata.customerName[:4]) == 'GO'
  • replace(toJSON(msg),'name','productName')
  • msg.humidity >= 80 || msg.temperature >= 30

更多expr表达式语法和函数请参考:expr语言定义 (opens new window)

# Relation Type

  • Case.then: 当匹配到某个case表达式时,消息将被路由到该case配置的then关系链(可能同时命中多个分支)
  • Default: 当所有case表达式都匹配失败时,消息将被路由到Default关系链
  • Failure: 当表达式执行出错时,消息将被路由到Failure关系链

# 执行结果

该组件是纯路由组件,不会修改传入的msg、metadata和msgType内容。它会为每个匹配到的case分支分别转发一次消息;当无任何匹配时转发到Default关系。

实现参考:在 d:\github\rulego\components\common\inclusive_node.go:66 中,组件遍历所有case表达式,命中后收集对应关系并通过 TellNext 同时路由到多个关系;未命中则路由到默认关系。

# 与条件分支的区别

  • switch(条件分支):按顺序匹配case表达式,命中第一个后停止匹配,仅路由到一个分支。
  • inclusive(包容分支):评估所有case表达式,命中的所有分支会被同时路由;若全部未命中则路由到Default。
  • 错误处理:两者一致,表达式执行错误时路由到Failure。

# 配置示例

{
  "ruleChain": {
    "id": "inc-01",
    "name": "测试包容分支",
    "debugMode": true,
    "root": true
  },
  "metadata": {
    "endpoints": [],
    "nodes": [
      {
        "id": "node_inclusive",
        "additionalInfo": {
          "description": "",
          "layoutX": 480,
          "layoutY": 280
        },
        "type": "inclusive",
        "name": "包容分支",
        "debugMode": false,
        "configuration": {
          "cases": [
            {
              "case": "msg.temperature>=20 && msg.temperature<=50",
              "then": "Case1"
            },
            {
              "case": "msg.temperature>50",
              "then": "Case2"
            }
          ]
        }
      },
      {
        "id": "node_case1",
        "additionalInfo": {
          "description": "",
          "layoutX": 840,
          "layoutY": 160
        },
        "type": "jsTransform",
        "name": "case1",
        "debugMode": false,
        "configuration": {
          "jsScript": "msg=msg||{}\nmsg.match='Case1'\nreturn {'msg':msg,'metadata':metadata,'msgType':msgType};"
        }
      },
      {
        "id": "node_case2",
        "additionalInfo": {
          "description": "",
          "layoutX": 840,
          "layoutY": 280
        },
        "type": "jsTransform",
        "name": "case2",
        "debugMode": false,
        "configuration": {
          "jsScript": "msg=msg||{}\nmsg.match='Case2'\nreturn {'msg':msg,'metadata':metadata,'msgType':msgType};"
        }
      },
      {
        "id": "node_default",
        "additionalInfo": {
          "description": "",
          "layoutX": 840,
          "layoutY": 380
        },
        "type": "jsTransform",
        "name": "default",
        "debugMode": false,
        "configuration": {
          "jsScript": "msg=msg||{}\nmsg.match='Default'\nreturn {'msg':msg,'metadata':metadata,'msgType':msgType};"
        }
      }
    ],
    "connections": [
      { "fromId": "node_inclusive", "toId": "node_case1", "type": "Case1" },
      { "fromId": "node_inclusive", "toId": "node_case2", "type": "Case2" },
      { "fromId": "node_inclusive", "toId": "node_default", "type": "Default" }
    ]
  }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
在 GitHub 上编辑此页 (opens new window)
上次更新: 2025/11/27, 10:15:33
条件分支
中断(break)

← 条件分支 中断(break)→

Theme by Vdoing | Copyright © 2023-2025 RuleGo Team | Apache 2.0 License

  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式