MQTT端云对接

tos_mqtt_connect

int tos_mqtt_connect(char *host, const char *port, mqtt_con_param_t *param);

• 功能描述

连接MQTT服务器。

• 参数解释

IN/OUT参数名描述[in]host服务器IP地址或域名[in]port服务器端口[in]param连接参数

• 返回值

成功，返回socket fd。

失败，返回-1。

tos_mqtt_publish

int tos_mqtt_publish(int sock, mqtt_pub_param_t *param);

• 功能描述

发布MQTT消息

• 参数解释

IN/OUT参数名描述[in]socksocket fd，由tos_mqtt_connect获取。[in]param消息发布参数

• 返回值

0，发布成功。

-1，发布失败。

tos_mqtt_subscribe

int tos_mqtt_subscribe(int sock, mqtt_sub_param_t *param);

• 功能描述

订阅MQTT消息

• 参数解释

IN/OUT参数名描述[in]socksocket fd，由tos_mqtt_connect获取。[in]param消息订阅参数

• 返回值

0，订阅成功。

-1，订阅失败。

tos_mqtt_receive

int tos_mqtt_receive(char *topic, int topic_len, unsigned char *payload, int payload_len);

• 功能描述

收取MQTT消息

• 参数解释

IN/OUT参数名描述[out]topic收取到的MQTT topic[in]topic_lenMQTT topic buffer长度[out]payload收取到的payload[in]payload_lenpayload buffer长度

• 返回值

成功，返回收取到的payload长度。

失败，返回-1。