MQTT 生产者（旧）
组件介绍
MQTT生产者步骤可以在近乎实时中将消息发布到MQTT 代理中.
配置标签
设置
参数介绍:
| 字段 | 字段说明 |
|---|---|
| 连接 | 指定此步骤将连接到以发送或接收消息的 MQTT 服务器的地址。 |
| 客户端ID | 为 MQTT 客户端指定唯一 ID。MQTT 服务器使用此客户端 ID来识别每个不同的客户端和该客户端的当前状态。 |
| 指定Topic | 选择指定topic以输入特定主题名称。然后，在**"Topic name**"字段中，输入要发布到流数据（消息）的 MQTT 主题的名称。每个MQTT Productor步骤都将启动一个用于发布线程。选择**"从字段中获取数据"以基于来自在同一转换流中生成行的另一个步骤中的字段指定主题名称。使用下拉列表，然后选择要使用的字段的名称。可以使用此选项动态控制主题名称的值设置**。每个单独的消息仍然只有一个主题，但进入MQTT 生产者步骤的每一行将生成一条可能具有不同主题的新消息。 |
| 从字段获取数据 | |
| 字段名 | |
| 服务器数量 | |
| 消息字段 |
安全
参数介绍:
| 字段 | 字段说明 |
|---|---|
| 用户名 | 访问MQTT的用户名 |
| 密码 | 与用户名一起的密码 |
| 使用安全协议 | 是否使用SSL |
| ssl属性 | ssl.context 供应商指定基础 JSSE 提供程序。 |
| ssl.keyStore指定包含要密钥管理器使用的 KeyStore 对象的文件的名称 | |
| ssl.enabledCipherSuites指定启用了哪些密码。值取决于提供程序 | |
| ssl.keyManager指定将用于创建 KeyManagerFactory 对象的算法，而不是使用平台中可用的默认算法 | |
| ssl.keyStorePassword 密码 | |
| ssl.trustManager 指定将用于创建 TrustManagerFactory 对象的算法，而不是使用平台中可用的默认算法 | |
| ssl.TrustStore指定包含要信任管理器使用的 KeyStore 对象的文件的名称。 |
选项
参数介绍:
| 字段 | 字段说明 |
|---|---|
| keep alive Interval | 指定在 PDI 客户端完成传输一个控制数据包的点和它开始发送下一个控制数据包的点之间允许经过的最大间隔秒数。 |
| Max Inflight | 为在给定时间要处理的最大消息数指定一个数字 |
| Connection Timeout | 指定在未收到消息时断开的时间（以秒为单位 |
| Clean Session | 指定代理是存储或清除会话的消息。选择以下选项 True: 当设置为True时，代理不会存储客户端的任何信息。将清除上一个持久会话的所有信息。 False：当设置为False时，代理将存储客户端的所有订阅。当 QoS（服务质量）参数设置为 1 或 2 时，将存储所有错过的消息。有关详细信息，请参阅"设置"选项卡中的服务质量参数。 |
| Storge Level | 指示消息是存储在内存中还是存储在磁盘上。 默认值（空白）是内存。 对于磁盘，输入有效的路径 |
| Server URIs | 指定 MQTT 服务器的通用资源标识符 （URI）。 |
| MQTT Version | 指定此步骤连接到的 MQTT 协议版本。 |
| Automatic Reconnect | 使客户端在服务器断开连接时可以尝试自动重新连接到服务器。选择 True 或 False True: 是，尝试重新连接到服务器。 False：否，不要尝试重新连接到服务器。 |
案例
暂无