如何使用自定义MQTT Topic通信_物联网平台(IoT)-阿里云帮助中心

用户可以直接通过SDK提供的MQTT API与阿里云物联网平台通信，即可以通过向指定的Topic发送消息的方式将数据发送到阿里云物联网平台，也可以通过订阅指定的Topic从阿里云物联网平台接收数据，这些Topic都是用户自定义的。

通信流程图

使用MQTT Topic与物联网平台通信的流程示意图如下：

通过调用IOT_MQTT_Construct()接口调用，建立设备和云平台之间的长连接。
- 该接口用来向云平台发起连接请求，需要的“签名信息”可以通过dev_sign功能中的IOT_Sign_MQTT()获得。
- 连接成功后，会返回一个handle参数，这是连接的句柄，可用作之后所有MQTT网络接口的输入参数。
通过IOT_MQTT_Subscribe()接口调用，可以向云平台表达设备将接收哪些Topic上的报文。
进入业务主循环。
- 通过IOT_MQTT_Publish()或IOT_MQTT_Publish_Simple()，可将消息上报到云端。
- IOT_MQTT_Yield()用于接收云端下发的消息，并调用用户在IOT_MQTT_Subscribe()时指定的回调函数，用于对数据进行处理。

函数名	说明
IOT_MQTT_CheckStateNormal	MQTT连接后，调用此函数检查长连接是否正常。
IOT_MQTT_Construct	MQTT实例的构造函数，入参为`iotx_mqtt_param_t`结构体，连接MQTT服务器，并返回被创建的句柄。
IOT_MQTT_Destroy	MQTT实例的摧毁函数，入参为 `IOT_MQTT_Construct`创建的句柄。
IOT_MQTT_Publish	MQTT会话阶段，组织一个完整的`MQTT Publish`报文，向服务端发送消息发布报文。
IOT_MQTT_Publish_Simple	MQTT会话阶段，组织一个完整的`MQTT Publish`报文，向服务端发送消息发布报文，参数中不含结构体等复杂数据类型。
IOT_MQTT_Subscribe	MQTT会话阶段，组织一个完整的`MQTT Subscribe`报文，向服务端发送订阅请求。
IOT_MQTT_Subscribe_Sync	MQTT会话阶段，组织一个完整的`MQTT Subscribe`报文，向服务端发送订阅请求，并等待应答。
IOT_MQTT_Unsubscribe	MQTT会话阶段，组织一个完整的`MQTT UnSubscribe`报文，向服务端发送取消订阅请求。
IOT_MQTT_Yield	MQTT会话阶段，MQTT主循环函数，内含了心跳的维持，服务器下行报文的收取等。

以下函数为可选实现，如果希望SDK提供MQTT通道功能，则需要用户对接。

函数名	说明
HAL_UptimeMs	返回设备加电以来到当前时间点过去的毫秒数
HAL_SleepMs	按照入参指定的毫秒数睡眠相应时间
HAL_SSL_Destroy	销毁一个TLS连接，用于MQTT功能，加密连接的情况
HAL_SSL_Establish	建立一个TLS连接，用于MQTT功能，加密连接的情况
HAL_SSL_Read	从一个TLS连接中读数据，用于MQTT功能，加密连接的情况
HAL_SSL_Write	向一个TLS连接中写数据，用于MQTT功能，加密连接的情况
HAL_TCP_Destroy	销毁一个TLS连接，用于MQTT功能
HAL_TCP_Establish	建立一个TCP连接，包含了域名解析的动作和TCP连接的建立
HAL_TCP_Read	在指定时间内，从TCP连接读取流数据，并返回读到的字节数
HAL_TCP_Write	在指定时间内，向TCP连接发送流数据，并返回发送的字节数

说明

SDK提供的用户API接口都列在src/mqtt/mqtt_api.h，可能需要对接的HAL函数都列在src/mqtt/mqtt_wrapper.h，具体以代码为准。