本文将通过实例介绍如何通过MQTT.fx连接并消费MQ消息。
本例中,topic名为:test,订阅名为:sub123
打开MQTT.fx客户端,进入客户端配置页面,
设置Profile Name,本例中为test-mq
设置接入地址与端口,并设置username与password,其中:
username设置为MQ_ID,password见安全鉴权,本例中:password示例如下:
version=2018-10-31&res=mqs%2FA18F3248E9306BE160C6E95BFEE5B257F&et=1548643432&method=sha1&sign=S7uiBwW7Pv5%2FfbtGmQI%2F94hLyGw%3D
点击SSL/TLS进入加密设置
选择CA certificate file,导入证书
点击OK,完成配置
点击配置文件选择箭头,选择配置test-mq
点击Connect,连接MQ服务
选择Subscribe配置,输入订阅名称,订阅命名规则如下:
$sys/pb/consume/$MQ_ID/$TOPIC/$SUB
本例中订阅名称为:
$sys/pb/consume/A18F3248E9306BE160C6E95BFEE5B257F/test/sub123
选择 QoS1,点击Subscribe
用户可以使用平台的模拟工具产生设备消息,操作如下:
进入设备列表 -> 数据流 -> 模拟数据工具
点击发送数据,完成消息的模拟产生
在MQTT.fx客户端,可以查看到当前接收到的数据,数据格式见开发指南