怎么通过MQTT协议接入OneNET平台

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传递协议，专为资源受限的设备和低带宽、不可靠网络环境设计。它最初由IBM开发，现已成为物联网领域的标准协议之一。那设备通过MQTT协议接入OneNET平台要怎么办？

以下是使用MQTT协议接入中国移动OneNET物联网平台的简明步骤：

1. 平台准备

注册账号：访问OneNET官网注册开发者账号
创建产品：进入控制台 → 创建新产品，选择接入协议为MQTT
添加设备：在产品下创建设备，记录产品ID、设备名称和鉴权信息（APIKey或Token）

2. MQTT连接参数

服务器地址：mqtt.heclouds.com
端口号：
- 非加密：1883
- SSL加密：8883
客户端ID：设备名称
用户名：产品ID
密码：使用Token或APIKey生成（推荐Token方式更安全）

密码生成示例（Token方式）：

import hashlib
product_id = "your_product_id"
device_name = "your_device_name"
api_key = "your_api_key"

# 生成过期时间戳（示例为1小时后）
expire = int(time.time()) + 3600

# 计算签名
sign_str = f"products/{product_id}/devices/{device_name}".encode()
sign = hashlib.sha1(sign_str + api_key.encode()).hexdigest()

# 组合最终密码
password = f"version=2018-10-31&res={sign_str}&et={expire}&method=sha1&sign={sign}"

3. 连接示例（Python伪代码）

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("连接成功")
        # 订阅命令主题
        client.subscribe(f"$sys/{product_id}/{device_name}/thing/command/post")
    else:
        print(f"连接失败，错误码: {rc}")

client = mqtt.Client(client_id=device_name, protocol=mqtt.MQTTv311)
client.username_pw_set(username=product_id, password=password)
client.connect("mqtt.heclouds.com", 1883, 60)
client.on_connect = on_connect
client.loop_start()

4. 数据上传

使用标准物模型格式（JSON）发布数据到属性主题：

topic = f"$sys/{product_id}/{device_name}/thing/property/post"
payload = {
    "id": "123",
    "version": "1.0",
    "params": {
        "temperature": 25.6,
        "humidity": 45
    }
}
client.publish(topic, json.dumps(payload), qos=1)

5. 命令接收

订阅命令响应主题并处理消息：

def on_message(client, userdata, msg):
    payload = json.loads(msg.payload)
    print("收到命令:", payload)
    # 处理命令并回复
    reply_topic = f"$sys/{product_id}/{device_name}/thing/property/post/reply"
    client.publish(reply_topic, json.dumps({"id": payload["id"], "code":200}))

client.on_message = on_message