将传入消息数据作为回复发送给设备的 Remote Procedure Call (RPC)。
回复根据元数据属性路由回发起服务和会话。
消息路由至 Success 连接（成功时）或 Failure 连接（错误时）。
用法
处理设备RPC请求并发送回复的典型流程如下：
-
当设备向平台发送RPC请求时，会自动创建类型为
TO_SERVER_RPC_REQUEST的Rule Engine消息。消息数据包含设备的RPC payload，元数据包含路由回复所需的服务ID、会话ID和请求ID。 -
在Rule Chain中处理该消息以准备响应。可能涉及用附加数据丰富消息、转换payload、调用外部系统或生成适当回复所需的任何其他业务逻辑。
-
一旦消息数据中准备好响应，将消息路由至RPC call reply节点。节点将使用元数据将回复发送回发起设备。
-
重要：确保在消息处理过程中保留服务ID、会话ID和请求ID元数据属性。若这些值丢失或被覆盖，回复无法路由回设备。
配置
配置参数指定用于识别服务、会话和请求的元数据键名，以便发送回复。
- Service Id - 服务标识符的元数据键名。默认值为
serviceId。标识应接收回复的发起服务。 - Session Id - 会话标识符的元数据键名。默认值为
sessionId。标识服务内的具体会话。 - Request Id - 请求标识符的元数据键名。默认值为
requestId。标识要回复的具体RPC请求。
这些参数可为高级用例自定义，但默认值在大多数场景下工作良好，通常无需更改。RPC消息的元数据中已包含路由参数（服务ID、会话ID、请求ID）。
JSON Schema
消息处理算法
- 节点验证消息发起者为
DEVICE。若验证失败，处理失败。 - 节点使用配置的键名从消息元数据中提取服务ID、会话ID和请求ID。若任一值缺失，处理失败。
- 节点验证消息数据（回复体）非空。若为空，处理失败。
- 节点通过检查元数据中是否存在
edgeId判断消息是否来自Edge设备：- 若存在edge ID：将回复保存到Edge事件队列以便异步投递给Edge。
- 若不存在edge ID：使用RPC服务直接将回复发送给设备。
- 成功完成处理后，消息经
Success连接转发。
输出连接
Success- RPC回复已成功发送（直接发送或加入Edge投递队列）。传出消息与传入消息相同。
Failure- 处理过程中发生错误，例如：
- 发起者不是
DEVICE - 元数据中缺少服务ID
- 元数据中缺少会话ID
- 元数据中缺少请求ID
- 消息数据（回复体）为空
- 无法从元数据解析edge ID或设备ID
- 保存Edge事件失败
- 发起者不是
- 处理过程中发生错误，例如：
示例
示例1 — 简单RPC回复
传入消息
发起者：DEVICE。
数据：
1
2
3
{
"timestamp": 1727712000000
}
元数据：
1
2
3
4
5
{
"serviceId": "monolith",
"sessionId": "550e8400-e29b-41d4-a716-446655440000",
"requestId": "12345"
}
节点配置
1
2
3
4
5
{
"serviceIdMetaDataAttribute": "serviceId",
"sessionIdMetaDataAttribute": "sessionId",
"requestIdMetaDataAttribute": "requestId"
}
传出消息
传出消息与传入消息相同。经 Success 连接路由。
结果
设备请求当前服务器时间，服务器以当前UNIX时间戳（毫秒）回复。RPC回复发送回服务 monolith、会话 550e8400-e29b-41d4-a716-446655440000，对应请求ID 12345。