本文提供設(shè)備通過(guò)HTTP協(xié)議接入物聯(lián)網(wǎng)平臺(tái)的示例代碼。

物聯(lián)網(wǎng)平臺(tái)支持設(shè)備通過(guò)HTTP協(xié)議接入。相關(guān)配置說(shuō)明，請(qǐng)參見(jiàn)HTTPS連接通信。

本文提供基于Java HTTP的接入示例代碼，介紹如何配置設(shè)備通過(guò)HTTP協(xié)議接入物聯(lián)網(wǎng)平臺(tái)的請(qǐng)求參數(shù)，計(jì)算設(shè)備端簽名等。

<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>fastjson</artifactId>
  <version>1.2.83</version>
</dependency>

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.util.Set;
import java.util.SortedMap;
import java.util.TreeMap;

import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import javax.net.ssl.HttpsURLConnection;

import com.alibaba.fastjson.JSONObject;

/**
 * 設(shè)備使用HTTP協(xié)議接入阿里云物聯(lián)網(wǎng)平臺(tái)。 
 * 協(xié)議規(guī)范說(shuō)明，請(qǐng)參見(jiàn)《HTTP協(xié)議規(guī)范》。
 * 數(shù)據(jù)格式，請(qǐng)參見(jiàn)《HTTP連接通信》。
 */
public class IotHttpClient {

    // 地域ID，以華東2（上海）為例。
    private static String regionId = "cn-shanghai";

    // 定義加密方式，MAC算法可選以下算法：HmacMD5、HmacSHA1，需和signmethod一致。
    private static final String HMAC_ALGORITHM = "hmacsha1";

    // token有效期7天，失效后需要重新獲取。
    private String token = null;

    /**
     * 初始化HTTP客戶端。
     * 
     * @param productKey，產(chǎn)品key。
     * @param deviceName，設(shè)備名稱。
     * @param deviceSecret，設(shè)備密鑰。
     */
    public void conenct(String productKey, String deviceName, String deviceSecret) {
        try {
            // 注冊(cè)地址。
            URL url = new URL("https://iot-as-http." + regionId + ".aliyuncs.com/auth");

            HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-type", "application/json");
            conn.setDoOutput(true);
            conn.setDoInput(true);

            // 獲取URLConnection對(duì)象對(duì)應(yīng)的輸出流。
            PrintWriter out = new PrintWriter(conn.getOutputStream());
            // 發(fā)送請(qǐng)求參數(shù)。
            out.print(authBody(productKey, deviceName, deviceSecret));
            // flush輸出流的緩沖。
            out.flush();

            // 獲取URLConnection對(duì)象對(duì)應(yīng)的輸入流。
            BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
            // 讀取URL的響應(yīng)。
            String result = "";
            String line = "";
            while ((line = in.readLine()) != null) {
                result += line;
            }
            System.out.println("----- auth result -----");
            System.out.println(result);

            // 關(guān)閉輸入輸出流。
            in.close();
            out.close();
            conn.disconnect();

            // 獲取token。
            JSONObject json = JSONObject.parseObject(result);
            if (json.getIntValue("code") == 0) {
                token = json.getJSONObject("info").getString("token");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 發(fā)送消息。
     * 
     * @param topic，發(fā)送消息的Topic。
     * @param payload，消息內(nèi)容。
     */
    public void publish(String topic, byte[] payload) {
        try {
            // 注冊(cè)地址。
            URL url = new URL("https://iot-as-http." + regionId + ".aliyuncs.com/topic" + topic);

            HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-type", "application/octet-stream");
            conn.setRequestProperty("password", token);
            conn.setDoOutput(true);
            conn.setDoInput(true);

            // 獲取URLConnection對(duì)象對(duì)應(yīng)的輸出流。
            BufferedOutputStream out = new BufferedOutputStream(conn.getOutputStream());
            out.write(payload);
            out.flush();

            // 獲取URLConnection對(duì)象對(duì)應(yīng)的輸入流。
            BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
            // 讀取URL的響應(yīng)。
            String result = "";
            String line = "";
            while ((line = in.readLine()) != null) {
                result += line;
            }
            System.out.println("----- publish result -----");
            System.out.println(result);

            // 關(guān)閉輸入輸出流。
            in.close();
            out.close();
            conn.disconnect();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 生成認(rèn)證請(qǐng)求內(nèi)容。
     * 
     * @param params，認(rèn)證參數(shù)。
     * @return 認(rèn)證請(qǐng)求消息體。
     */
    private String authBody(String productKey, String deviceName, String deviceSecret) {

        // 構(gòu)建認(rèn)證請(qǐng)求。
        JSONObject body = new JSONObject();
        body.put("productKey", productKey);
        body.put("deviceName", deviceName);
        body.put("clientId", productKey + "." + deviceName);
        body.put("timestamp", String.valueOf(System.currentTimeMillis()));
        body.put("signmethod", HMAC_ALGORITHM);
        body.put("version", "default");
        body.put("sign", sign(body, deviceSecret));

        System.out.println("----- auth body -----");
        System.out.println(body.toJSONString());

        return body.toJSONString();
    }

    /**
     * 設(shè)備端簽名。
     * 
     * @param params，簽名參數(shù)。
     * @param deviceSecret，設(shè)備密鑰。
     * @return 簽名十六進(jìn)制字符串。
     */
    private String sign(JSONObject params, String deviceSecret) {

        // 請(qǐng)求參數(shù)按字典順序排序。
        Set<String> keys = getSortedKeys(params);

        // sign、signmethod和version除外。
        keys.remove("sign");
        keys.remove("signmethod");
        keys.remove("version");

        // 組裝簽名明文。
        StringBuffer content = new StringBuffer();
        for (String key : keys) {
            content.append(key);
            content.append(params.getString(key));
        }

        // 計(jì)算簽名。
        String sign = encrypt(content.toString(), deviceSecret);
        System.out.println("sign content=" + content);
        System.out.println("sign result=" + sign);

        return sign;
    }

    /**
     * 獲取JSON對(duì)象排序后的key集合。
     * 
     * @param json，需要排序的JSON對(duì)象。
     * @return 排序后的key集合。
     */
    private Set<String> getSortedKeys(JSONObject json) {
        SortedMap<String, String> map = new TreeMap<String, String>();
        for (String key : json.keySet()) {
            String value = json.getString(key);
            map.put(key, value);
        }
        return map.keySet();
    }

    /**
     * 使用HMAC_ALGORITHM加密。
     * 
     * @param content，明文。
     * @param secret，密鑰。
     * @return 密文。
     */
    private String encrypt(String content, String secret) {
        try {
            byte[] text = content.getBytes(StandardCharsets.UTF_8);
            byte[] key = secret.getBytes(StandardCharsets.UTF_8);
            SecretKeySpec secretKey = new SecretKeySpec(key, HMAC_ALGORITHM);
            Mac mac = Mac.getInstance(secretKey.getAlgorithm());
            mac.init(secretKey);
            return byte2hex(mac.doFinal(text));
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    /**
     * 二進(jìn)制轉(zhuǎn)十六進(jìn)制字符串。
     * 
     * @param b，二進(jìn)制數(shù)組。
     * @return 十六進(jìn)制字符串。
     */
    private String byte2hex(byte[] b) {
        StringBuffer sb = new StringBuffer();
        for (int n = 0; b != null && n < b.length; n++) {
            String stmp = Integer.toHexString(b[n] & 0XFF);
            if (stmp.length() == 1) {
                sb.append('0');
            }
            sb.append(stmp);
        }
        return sb.toString().toUpperCase();
    }

    public static void main(String[] args) {
        String productKey = "您的productKey";
        String deviceName = "您的deviceName";
        String deviceSecret = "您的deviceSecret";
        IotHttpClient client = new IotHttpClient();
        client.conenct(productKey, deviceName, deviceSecret);
        // 發(fā)送消息的Topic。可在控制臺(tái)自定義，設(shè)備有發(fā)布權(quán)限。
        String updateTopic = "/" + productKey + "/" + deviceName + "/user/update";
        client.publish(updateTopic, "hello http".getBytes(StandardCharsets.UTF_8));
        client.publish(updateTopic, new byte[] { 0x01, 0x02, 0x03 });
    }
}