使用MQTT.fx接入物联网平台

视频演示

使用MQTT.fx，模拟设备接入物联网平台的操作如下。

配置MQTT.fx接入

1. 下载MQTT.fx Version 1.7.1 for Windows版本软件，完成安装。
   MQTT.fx更多信息，请访问MQTT.fx官网。
2. 打开MQTT.fx软件，单击菜单栏中的Extras，选择Edit Connection Profiles。
   
3. 在Edit Connection Profiles页面，完成以下参数的设置。
   1. 设置基本信息。
      

      参数	说明	示例
      Profile Name	输入您的自定义名称。	iot connection
      Profile Type	MQTT服务器连接，选择MQTT Broker。
      MQTT Broker Profile Settings
      Broker Address	接入域名。公共实例与企业版实例的MQTT接入域名获取方法，请参见查看实例终端节点。 此处仅输入域名，无需携带端口号。	本示例为2021年07月30日之前（不含当日）开通的公共实例接入。 a1oGs******.iot-as-mqtt.cn-shanghai.aliyuncs.com a1oGs******为本示例产品的productKey。 cn-shanghai为本示例所在地域。
      Broker Port	设置为1883。
      Client ID	MQTT的协议字段。 固定格式：${ClientID}|securemode=${Mode},signmethod=${SignMethod}|。 参数说明： ${ClientId}：设备、App或Web等场景下的Client ID信息。 注意 该值可自定义，长度在64个字符以内。若为设备的ID信息，建议使用您设备的MAC地址或SN码，方便您识别区分不同的设备。 ${Mode}：安全模式。 securemode=3：TCP直连模式，无需设置SSL/TLS信息。 securemode=2：TLS直连模式，需要设置SSL/TLS信息。 ${SignMethod}：算法类型，支持hmacmd5和hmacsha1。 注意 MQTT.fx的Client ID和设备的${ClientId}，切勿混淆。 不要遗漏参数之间及最后的竖线（|）。 设置参数时，请确保参数值中或参数值的前后均没有空格。 输入Client ID信息后，请勿单击Generate。	本示例设备clientId为12345，选择TLS直连模式和hmacsha1算法。 12345|securemode=2,signmethod=hmacsha1|
      General	本示例使用默认值。您也可以根据实际场景需求设置。

   2. 单击User Credentials，设置User Name和Password。
      

      参数	参数说明	示例
      User Name	由设备名DeviceName、and（&）和产品ProductKey组成。 固定格式：${DeviceName}&${ProductKey}。	Light&a1oGs****** Light为设备的DeviceName。 a1oGs******为设备的ProductKey。
      Password	通过选择的加密方法，以设备的DeviceSecret为密钥，将参数和参数值拼接后，加密生成Password。 注意 如果您使用的MQTT.fx版本，在粘贴Password后不显示具体的字符串，只要光标已从输入框的前部移至了后部，则表示粘贴成功，请勿重复粘贴。 请注意参数和参数值中字母的大小写。 可通过以下任一方法生成Password。 工具生成： 单击下载Password生成小工具。解压文件后，双击sign.html文件，根据网页提示，配置参数，生成password。 productKey、deviceName、deviceSecret：设备证书信息。可在控制台设备详情页查看。 timestamp：（可选）时间戳。 clientId：设备的ID信息，与MQTT.fx的Client ID中${clientId}一致。 method：选择签名算法类型，与MQTT.fx的Client ID中${SignMethod}一致。 通过加密函数手动生成，本文提供hmacsha1的加密Demo，请参见附录：加密Demo。 其中： ${productKey}、${deviceName}、${deviceSecret}：需替换为您的设备证书信息。 ${clientId}：替换为MQTT.fx的Client ID中${clientId}。	工具生成示例： 手动生成 本示例没有选择可选参数timestamp。

   3. TLS直连模式（即securemode=2）下，单击SSL/TLS，选中Enable SSL/TLS，设置Protocol为TLSv1.2。
      注意 TCP直连模式（即securemode=3）下，无需设置SSL/TLS信息，直接进入下一步。

      
4. 设置完成后，单击右下角的OK。
5. 单击Connect。
   右侧亮绿灯，表示连接成功。

   您可在物联网平台控制台，在对应实例下，选择设备管理 > 设备，选择产品，查看该设备状态，预期设备为在线状态。

   

下文通过测试自定义Topic的上下行通信，验证MQTT.fx与物联网平台连接是否成功。若测试与本示例结果不符，表示通信连接失败，您需根据日志信息，进行修正。

测试下行通信

1. 在物联网平台控制台对应实例下的产品详情页面，单击Topic类列表 > 自定义Topic，找到一个具有订阅权限的自定义Topic。
   本示例使用Topic：/a1oGs4X***/${deviceName}/user/get，您需替换${deviceName}为设备名称Light。

   更多信息，请参见自定义Topic。

2. 在MQTT.fx上单击Subscribe，在Subscribe文本框中，输入上一步的Topic，再单击Subscribe。

   订阅成功后，该Topic将显示在列表中。

   
3. 返回物联网平台，进入该设备的设备详情页面，在Topic列表页签下，单击已订阅Topic对应的发布消息。
   
4. 输入消息内容，单击确认。
   
5. 回到MQTT.fx上，查看接收到的消息。
   
6. 回到物联网平台，在设备详情页面，单击日志服务页签的前往查看，在日志服务页面，查看云到设备消息。
   

测试上行通信

1. 在物联网平台控制台对应实例下的产品详情页面，单击Topic类列表 > 自定义Topic，找到一个具有发布权限的自定义Topic。
   本示例使用Topic：/a1oGs4X***/${deviceName}/user/update/error，您需替换${deviceName}为设备名称Light。

   更多信息，请参见自定义Topic。

2. 在MQTT.fx上，单击Publish，在Publish文本框中，输入上一步的Topic。在文本编辑页面，输入要发送的消息内容，然后单击Publish。
   
3. 回到物联网平台，在设备详情页面，单击日志服务页签的前往查看，在日志服务页面，查看设备到云消息。
   

查看日志

在MQTT.fx上，单击Log查看操作日志和错误提示日志。

附录：加密Demo

package com.aliyun.iot.util;

import javax.crypto.Mac;
import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class SignDemo {

    public static String sign(Map<String, String> params, String deviceSecret, String signMethod) {
        //将参数Key按字典顺序排序
        String[] sortedKeys = params.keySet().toArray(new String[] {});
        Arrays.sort(sortedKeys);

        //生成规范化请求字符串
        StringBuilder canonicalizedQueryString = new StringBuilder();
        for (String key : sortedKeys) {
            if ("sign".equalsIgnoreCase(key)) {
                continue;
            }
            canonicalizedQueryString.append(key).append(params.get(key));
        }

        try {
            String key = deviceSecret;
            return encryptHMAC(signMethod, canonicalizedQueryString.toString(), key);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    public static String encryptHMAC(String signMethod, String content, String key) throws Exception {
        SecretKey secretKey = new SecretKeySpec(key.getBytes("utf-8"), signMethod);
        Mac mac = Mac.getInstance(secretKey.getAlgorithm());
        mac.init(secretKey);
        byte[] data = mac.doFinal(content.getBytes("utf-8"));
        return bytesToHexString(data);
    }

    public static final String bytesToHexString(byte[] bArray) {

        StringBuffer sb = new StringBuffer(bArray.length);
        String sTemp;
        for (int i = 0; i < bArray.length; i++) {
            sTemp = Integer.toHexString(0xFF & bArray[i]);
            if (sTemp.length() < 2) {
                sb.append(0);
            }
            sb.append(sTemp.toUpperCase());
        }
        return sb.toString();
    }

    public static void main(String args[]) {
        
        Map<String, String> params = new HashMap<String, String>();
        params.put("productKey", "${productKey}");
        params.put("deviceName", "${deviceName}");
        params.put("clientId", "${clientId}");
        //时间戳，可选参数。传入时，删除下面两行代码前的正斜线
        //String t = System.currentTimeMillis() + "";
        //params.put("timestamp", t);

        String sign = SignDemo.sign(params, "${deviceSecret}", "hmacsha1");
        System.out.print(sign);
    }

}

更多签名参数计算方法，请参见如何计算MQTT签名参数。