GRPC Stream Endpoint v0.28.0+ 提供了基于 gRPC 流式通信的端点实现，支持与 gRPC 服务端建立长连接，接收服务端推送的消息并通过路由转发处理。

特性

• 自动重连：当连接断开时会自动尝试重新建立连接
• 单路由模式：每个端点实例只支持配置一个消息处理路由
• 共享连接：相同服务器地址(Server)的多个端点实例会复用同一个gRPC连接，避免重复创建连接

Type

endpoint/grpc/stream

配置参数

字段	类型	说明	默认值
server	string	gRPC服务器地址	127.0.0.1:9000
service	string	gRPC服务名称	ble.DataService
method	string	gRPC方法名称	StreamData
headers	map[string]string	请求头	无
request	string	请求数据（JSON格式）	无
checkInterval	int	gRPC服务器检查间隔(毫秒)	10000

路由配置

只允许配置一个路由，且路由的 from.path 必须设置为 *，表示处理所有来源的消息。

配置示例

{
  "id": "GRPC Stream",
  "type": "endpoint/grpc/stream",
  "name": "GRPC Stream",
  "debugMode": false,
  "configuration": {
  "server": "127.0.0.1:9000",
  "service": "helloworld.Greeter",
  "method": "SayHello",
  "checkInterval": 10000
  },
  "routers": [
  {
  "from": {
  "path": ""
  },
  "to": {
  "path": "bkn3fIAr8x4w:MQTT",
  "wait": false
  }
  }
  ]
}

输出参数

从gRPC服务器接收到的消息会被转换为 RuleMsg 格式并发送到规则链：

• data：gRPC服务器返回的JSON格式数据
• dataType：JSON
• type：默认为空