nats客户端
  x/natsClient组件:v0.21.0+ NATS客户端组件。用于将消息发布到NATS消息服务器的指定主题。
# 配置
该组件支持通过server字段复用共享的连接客户端,避免重复创建连接。详见组件连接复用。
| 字段 | 类型 | 必填 | 说明 | 默认值 | 
|---|---|---|---|---|
| topic | string | 是 | 发布主题,支持使用组件配置变量进行动态配置 | 无 | 
| server | string | 是 | NATS服务器地址,格式为host:port | 无 | 
| username | string | 否 | NATS服务器认证用户名 | 无 | 
| password | string | 否 | NATS服务器认证密码 | 无 | 
# 工作原理
- 组件初始化时会根据配置连接到NATS服务器
 - 接收到消息后,将消息内容发布到指定的topic
 - 发布成功后通过Success链路由,失败则通过Failure链路由
 - 组件会自动管理连接的生命周期,包括重连、心跳等
 
# Relation Type
- Success: 消息成功发布到NATS服务器时,原始消息发送到
Success链路 - Failure: 以下情况消息发送到
Failure链路:- 连接NATS服务器失败
 - 发布消息失败
 - topic配置错误
 
 
# 执行结果
组件仅负责消息发布,不会修改原始消息的任何内容:
- msg保持不变
 - metadata保持不变
 - msgType保持不变
 
# 配置示例
   {
    "id": "s2",
    "type": "natsClient",
    "name": "往nats server推送数据",
    "configuration": {
      "server": "127.0.0.1:4222",
      "topic": "/device/msg/${deviceId}"
    }
  }
 1
2
3
4
5
6
7
8
9
2
3
4
5
6
7
8
9
在 GitHub 上编辑此页  (opens new window)
  上次更新: 2025/09/03, 10:09:04