基础信息
组件名称 ： mqtt-connector
组件版本： 1.0.0
组件类型： 系统默认
状 态： 正式发布
组件描述：通过MQTT 连接网关，发布或订阅MQTT broker相关的数据信息。
配置文件：
配置文件作为MQTT配置界面元素的基础，MQTT 所有高级配置均可以通过重构该配置文件体现在前端界面上。配置参数分为三组： 基础配置，连接配置，高级配置，一般情况可以随意扩展高级配置。
注： 配置文件仅供修改升级组件式利用，一般情况下对用户透明。无需做任何更改，除非用户需要手动维护组件心跳或通信端口时，一般情况下禁止修改。
df:component:name: mqtt-connectortype: 2 #1:采集器;2:接收器;3:转换器;4:存储器;5:解析器;6:状态解析器:7:同步器;8:消息通知transportPort: 49096 #内部akka通信端口heartbeatCron: 0/30 * * ? * * * #网关心跳数据上报时间parameter:connection[0]:name: Mqtt Brokerkey: urlrequired: trueinput-type: inputdescription: Mqtt Broker 地址包括主机和端口如tcp://127.0.0.1:8883value-type: stringconnection[1]:name: 认证类别key: auth-typerequired: truevalue-type: stringdefault-value: USERNAME #NONE, USERNAME, X509;input-type: selectselect-option: NONE|NONE,USERNAME|USERNAME,X509|X509connection[2]:name: Usernamekey: usernamerequired: falsevalue-type: stringinput-type: inputconnection[3]:name: Passwordkey: passwordrequired: falseinput-type: inputvalue-type: stringconnection[4]:name: CAkey: carequired: falseinput-type: inputvalue-type: stringconnection[5]:name: CRTkey: crtrequired: falseinput-type: inputvalue-type: stringconnection[6]:name: KEYkey: keyrequired: falseinput-type: inputvalue-type: stringconnection[7]:name: KEY-PASSkey: keyPassrequired: falseinput-type: inputvalue-type: stringbase[0]:name: receive topicskey: receive-topicsrequired: falsedefault-value: wmiot/+/+/data/postvalue-type: stringinput-type: inputdescription: 可以配置多个topic,各个topic之间用英文逗号,分隔，支持mqtt topic通配符。base[1]:name: receive qoskey: receive-qosrequired: falsevalue-type: intinput-type: selectselect-option: 0|0,1|1,2|2default-value: 1advance[0]:name: 客户端编号key: clientrequired: falsevalue-type: stringinput-type: inputdefault-value: iotmqttclient-1description: 客户端标识advance[1]:name: Keep alivekey: keep-aliverequired: falsevalue-type: intdefault-value: 15input-type: inputadvance[2]:name: Timeoutkey: completion-timeoutrequired: falsevalue-type: intdefault-value: 3000input-type: inputadvance[3]:name: Default topickey: default-send-topicrequired: falsevalue-type: stringdefault-value: default/wmiotmqttinput-type: inputadvance[4]:name: Default QoSkey: default-send-qosrequired: falsevalue-type: intdefault-value: 1input-type: selectselect-option: 0|0,1|1,2|2
组件测试
- 配置网关
从组件列表中选择mqtt-connector并拖动到作业设计器。
- 修改参数
修改右侧配置参数并保存，参数使用说明可以通过每个参数旁边的?查看。
配置带*号的必填项，重要参数： Mqtt broker ，认证方式，receiver topics。认证方式目前支持NONE和用户密码的方式，receiver topics支持多个并支持通配符，每个topic之间用英文逗号分割。如上图所示做好相关的基础配置。
- 启动网关
注意观察执行日志，确保网关正常运行，状态status 字段为1时表示正常运行中
- 测试验证
1）前提准备：
已经安装并启动MQTT Broker，本例采用EMQX, 安装配置过程略。
MQTT broker 信息： 地址：192.168.3.192， 端口： 1883， 用户名：develop，密码： 123456
准备好MQTT 客户端工具并启动，本例采用MQTTX。连接到EMQX：
测试该工具能正常发送topic到EMQX:
2）进入到轻云UC通用设计中心，进入到设计器，并拖动mqtt-connector组件到画板。
按规划中的信息配置好mqtt-connector配置信息：
这里的receiver topic指令为: qingcloudtech/iot/+/+/data/put,qingcloudtech/iot/+/+/data/receiver。即通过该topic 收到来自设备端的数据信息。本实例只说明设备数据采集过程，指令下行相关的操作说明请参见另外的操作手册。
3）切换到UC设计器，重启mqtt网关，可以从执行日志板块看到心跳数据。
4）通过mqttx发送数据。
切换的UC设计器，从日志记录中看到如下信息，表明设备信息发送成功。
