MQTT 消费者（旧）
组件介绍
组件可从MQTT代理或者MTQQ客户端提取数据流
配置标签
设置
参数介绍:
| 连接 | MQTT服务器地址 |
|---|---|
| ClientID | |
| 指定Topic | 要订阅的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 正确 是，尝试重新 连接到服务器。 错误 否，不要尝试重新连接到服务器。 |
案例
暂无