ThingsBoard远程RPC调用设备

使用 RPC 功能

客户端 RPC

从设备发送客户端 RPC

平台处理客户端RPC

服务器端 RPC

服务器端RPC结构

发送服务器端RPC

使用 RPC 功能

客户端 RPC 请求由两个字段组成，这两个字段都是必填的：

• method - 用于区分 RPC 调用的方法名称。例如，“getCurrentTime”或“getWeatherForecast”。参数的值是一个字符串。
• params - 用于处理请求的附加参数。该值是 JSON。如果不需要参数，请保留空 JSON“{}”。

RPC 请求示例：

{
   "method": "getCurrentTime",
   "params": {}
}

RPC 响应可以是任何数字、字符串或 JSON。例如：

1631881236974

从设备发送客户端 RPC

ThingsBoard 提供了一个 API 来从设备发送 RPC 命令。该 API 特定于每个受支持的网络协议。您可以在相应的参考页面查看 API 和示例：​​​​​​

LwM2M 和 SNMP 协议尚不支持客户端 RPC。

平台处理客户端RPC

客户端 RPC 命令转换为消息类型为“TO_SERVER_RPC_REQUEST”的规则引擎消息。该消息包含基于唯一 UUID 的标识符，该标识符存储在“requestId”元数据字段中。您可以设计规则链以使用转换、丰富或任何其他规则节点类型 来处理传入消息。一旦传入消息转换为响应消息，就应该使用RPC Call Reply节点向设备发送回复。

例如，让我们修改根规则链以处理“getCurrentTime”客户端 RPC 并回复当前时间（以毫秒为单位）。我们将使用“Script”转换节点和以下 JS 代码：

var rpcResponse;
if (msg.method === "getCurrentTime"){
   rpcResponse = new Date().getTime();
} else {
   rpcResponse = "Unknown RPC request method: " + msg.method;  
}
return {msg: rpcResponse, metadata: metadata, msgType: msgType};

将RPC命令发送到服务端必须PUBLISH消息发送到下面主题：

v1/devices/me/rpc/request/$request_id

$request_id表示请求的整型标识符服务端必须发布到下面主题：

v1/devices/me/rpc/response/$request_id

• 将请求发送到服务器

• 收到服务器的响应

服务器端 RPC

服务器端 RPC 功能允许您将请求从平台发送到设备，并可选择将响应返回到平台。

服务器端 RPC 调用的典型用例是各种远程控制：重新启动、打开/关闭引擎、更改 GPIO/执行器的状态、更改配置参数等。

服务器端RPC分为单向和双向：

• 单向 RPC 请求不需要设备提供任何回复。

双向 RPC 请求期望在可配置的超时时间内收到设备的响应。

 在 3.3 版本之前，ThingsBoard 仅支持轻量级RPC。轻量级 RPC 调用是短暂的，通常在 30 秒内，这是对平台的任何 REST API 调用的默认超时。由于它们的生命周期很短，因此没有理由将它们存储到数据库中。它们存在于服务器的内存中，假设如果服务器挂掉，仪表板小部件将向集群中的其他 ThingsBoard 服务器发送相同的请求。轻量级 RPC 消耗少量资源，因为它们的处理不会调用任何输入/输出操作，接受审计日志和规则引擎消息的存储。

从 3.3 版本开始，ThingsBoard 提供了对持久RPC 调用的支持。持久 RPC 具有可配置的生命周期并存储在数据库中。当您的设备可能长时间无法访问时，持久 RPC 非常有用。这种情况通常发生在网络连接不良或节能模式(PSM)的情况下。

服务器端RPC结构

服务器端RPC请求体由多个字段组成：

• method - 强制，用于区分 RPC 调用的方法名称。例如，“getCurrentTime”或“getWeatherForecast”。参数的值是一个字符串。
• params - 强制，用于处理请求的参数。该值是 JSON。如果不需要参数，请保留空 JSON“{}”。
• timeout - 可选，处理超时值（以毫秒为单位）。默认值为 10000（10 秒）。最小值为 5000（5 秒）。
• 过期时间- 可选，纪元时间值（以毫秒为单位，UTC 时区）。如果存在超时，则覆盖该超时。
• 持久性- 可选，请参阅[持久性]与[轻量级]RPC。默认值为“假”。
• 重试- 可选，定义在网络和/或设备端发生故障时将重新发送持久 RPC 的次数。
• extraInfo - 可选，定义将添加到[持久 RPC 事件]的持久 RPC 的元数据。

RPC 请求示例：

{
   "method": "setGPIO",
   "params": {
     "pin": 4,
     "value": 1
   },
  "timeout": 30000
}

发送服务器端RPC

服务器端 RPC 通常使用 REST API 或仪表板小部件发送。事实上，仪表板小部件使用相同的 REST API。一旦平台收到 RPC，它就会验证有效负载并运行权限检查。然后，服务器端RPC命令被转换为规则引擎消息。规则引擎可以用附加参数来丰富命令，并最终将命令传送到设备。

我们来详细回顾一下如何发送命令：

客户端订阅服务端RPC命令必须SUBSCRIBE消息发送下面主题：

v1/devices/me/rpc/request/+

订阅后客户端会收到一条命令作为对相应主题的PUBLISH命令：

v1/devices/me/rpc/request/$request_id

$request_id表示请求的整型标识符。

客户端PUBLISH下面主题进行响应：

v1/devices/me/rpc/response/$request_id

• 使用RPC debug terminal在仪表板调试

• 订阅服务器RPC命令

• 请求”connect”发送到设备

• 收到设备的响