wordpress博客建站,app立即打开,wordpress 图片墙,金融手机网站模板STM32rt-thread使用MQTT协议连接腾讯物联网平台 一、腾讯云sdk下载1、进入腾讯物联网平台文件[点击链接跳转](https://cloud.tencent.com.cn/document/product/1081/48356)2、下载csdk 二、移植腾讯云sdk1、将上面解压的文件夹复制到自己工程目录下2、文件添加到自己工程 三、连… STM32rt-thread使用MQTT协议连接腾讯物联网平台 一、腾讯云sdk下载1、进入腾讯物联网平台文件[点击链接跳转](https://cloud.tencent.com.cn/document/product/1081/48356)2、下载csdk 二、移植腾讯云sdk1、将上面解压的文件夹复制到自己工程目录下2、文件添加到自己工程 三、连接腾讯云 一、腾讯云sdk下载
1、进入腾讯物联网平台文件点击链接跳转
2、下载csdk 二、移植腾讯云sdk
1、将上面解压的文件夹复制到自己工程目录下 只复制图中4个文件夹就可以。
2、文件添加到自己工程 注意这几个文件夹 选rt-thread平台就行这都是人家写好的可以直接使用。
三、连接腾讯云
#include signal.h
#include stdbool.h
#include stdio.h
#include stdlib.h
#include string.h#include qcloud_iot_export.h
#include qcloud_iot_import.h
#include service_mqtt.h
#include utils_getopt.h
#include lite-utils.h#ifdef AUTH_MODE_CERT
static char sg_cert_file[PATH_MAX 1]; // full path of device cert file
static char sg_key_file[PATH_MAX 1]; // full path of device key file
#endiftypedef struct {bool power_off;uint8_t brightness;uint16_t color;char device_name[MAX_SIZE_OF_DEVICE_NAME 1];
} LedInfo;static DeviceInfo sg_devInfo;
static LedInfo sg_led_info;// led attributes, corresponding to struct LedInfo
static char *sg_property_name[] {power_switch, brightness, color, name};// users log print callback
static bool log_handler(const char *message)
{// return true if print successreturn false;
}// MQTT event callback
static void _mqtt_event_handler(void *pclient, void *handle_context, MQTTEventMsg *msg)
{MQTTMessage *mqtt_messge (MQTTMessage *)msg-msg;uintptr_t packet_id (uintptr_t)msg-msg;switch (msg-event_type) {case MQTT_EVENT_UNDEF:Log_i(undefined event occur.);break;case MQTT_EVENT_DISCONNECT:Log_i(MQTT disconnect.);break;case MQTT_EVENT_RECONNECT:Log_i(MQTT reconnect.);break;case MQTT_EVENT_PUBLISH_RECVEIVED:Log_i(topic message arrived but without any related handle: topic%.*s, topic_msg%.*s,mqtt_messge-topic_len, mqtt_messge-ptopic, mqtt_messge-payload_len, mqtt_messge-payload);break;case MQTT_EVENT_SUBCRIBE_SUCCESS:Log_i(subscribe success, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_SUBCRIBE_TIMEOUT:Log_i(subscribe wait ack timeout, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_SUBCRIBE_NACK:Log_i(subscribe nack, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_UNSUBCRIBE_SUCCESS:Log_i(unsubscribe success, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_UNSUBCRIBE_TIMEOUT:Log_i(unsubscribe timeout, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_UNSUBCRIBE_NACK:Log_i(unsubscribe nack, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_PUBLISH_SUCCESS:Log_i(publish success, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_PUBLISH_TIMEOUT:Log_i(publish timeout, packet-id%u, (unsigned int)packet_id);break;case MQTT_EVENT_PUBLISH_NACK:Log_i(publish nack, packet-id%u, (unsigned int)packet_id);break;default:Log_i(Should NOT arrive here.);break;}
}// Setup MQTT construct parameters
static int _setup_connect_init_params(MQTTInitParams *initParams)
{int ret;ret HAL_GetDevInfo((void *)sg_devInfo);if (QCLOUD_RET_SUCCESS ! ret) {return ret;}initParams-region sg_devInfo.region;initParams-device_name sg_devInfo.device_name;initParams-product_id sg_devInfo.product_id;#ifdef AUTH_MODE_CERTchar certs_dir[PATH_MAX 1] certs;char current_path[PATH_MAX 1];char *cwd getcwd(current_path, sizeof(current_path));if (cwd NULL) {Log_e(getcwd return NULL);return QCLOUD_ERR_FAILURE;}#ifdef WIN32sprintf(sg_cert_file, %s\\%s\\%s, current_path, certs_dir, sg_devInfo.dev_cert_file_name);sprintf(sg_key_file, %s\\%s\\%s, current_path, certs_dir, sg_devInfo.dev_key_file_name);
#elsesprintf(sg_cert_file, %s/%s/%s, current_path, certs_dir, sg_devInfo.dev_cert_file_name);sprintf(sg_key_file, %s/%s/%s, current_path, certs_dir, sg_devInfo.dev_key_file_name);
#endifinitParams-cert_file sg_cert_file;initParams-key_file sg_key_file;
#elseinitParams-device_secret sg_devInfo.device_secret;
#endifinitParams-command_timeout QCLOUD_IOT_MQTT_COMMAND_TIMEOUT;initParams-keep_alive_interval_ms QCLOUD_IOT_MQTT_KEEP_ALIVE_INTERNAL;initParams-auto_connect_enable 1;initParams-event_handle.h_fp _mqtt_event_handler;initParams-event_handle.context NULL;return QCLOUD_RET_SUCCESS;
}static void property_topic_publish(void *pClient, const char *message, int message_len)
{char topic[256] {0};int size;size HAL_Snprintf(topic, 256, $thing/up/property/%s/%s, sg_devInfo.product_id, sg_devInfo.device_name);if (size 0 || size 256 - 1) {Log_e(buf size topic length!);return;}PublishParams pubParams DEFAULT_PUB_PARAMS;pubParams.qos QOS0;pubParams.payload_len message_len;pubParams.payload (void *)message;IOT_MQTT_Publish(pClient, topic, pubParams);
}static void property_get_status(void *pClient)
{char message[256] {0};int message_len 0;static int sg_get_status_index 0;sg_get_status_index;message_len HAL_Snprintf(message, sizeof(message), {\method\:\get_status\, \clientToken\:\%s-%d\},sg_devInfo.product_id, sg_get_status_index);property_topic_publish(pClient, message, message_len);
}static void property_report(void *pClient)
{char message[256] {0};int message_len 0;static int sg_report_index 0;sg_report_index;message_len HAL_Snprintf(message, sizeof(message),{\method\:\report\, \clientToken\:\%s-%d\, \params\:{\power_switch\:%d, \color\:%d, \brightness\:%d, \name\:\%s\}},sg_devInfo.product_id, sg_report_index, sg_led_info.power_off, sg_led_info.color,sg_led_info.brightness, sg_devInfo.device_name);// only change the brightness in the demosg_led_info.brightness % 100;sg_led_info.brightness;property_topic_publish(pClient, message, message_len);
}static void property_control_handle(void *pClient, const char *token, const char *control_data)
{char *params NULL;char *property_param NULL;char message[256] {0};int message_len 0;params LITE_json_value_of(params, (char *)control_data);if (NULL params) {Log_e(Fail to parse params);return;}for (int i 0; i sizeof(sg_property_name) / sizeof(sg_property_name[0]); i) {property_param LITE_json_value_of(sg_property_name[i], params);if (NULL ! property_param) {Log_i(\t%-16s %-10s, sg_property_name[i], property_param);if (i 1) {// only change the brightness in the demosg_led_info.brightness atoi(property_param);}HAL_Free(property_param);}}// method: control_replymessage_len HAL_Snprintf(message, sizeof(message),{\method\:\control_reply\, \code\:0, \clientToken\:\%s\}, token);property_topic_publish(pClient, message, message_len);HAL_Free(params);
}static void property_get_status_reply_handle(const char *get_status_reply_data)
{char *data NULL;char *report NULL;char *property_param NULL;data LITE_json_value_of(data, (char *)get_status_reply_data);if (NULL data) {Log_e(Fail to parse data);return;}report LITE_json_value_of(reported, (char *)data);if (NULL report) {Log_e(Fail to parse report);HAL_Free(data);return;}for (int i 0; i sizeof(sg_property_name) / sizeof(sg_property_name[0]); i) {property_param LITE_json_value_of(sg_property_name[i], report);if (NULL ! property_param) {Log_i(\t%-16s %-10s, sg_property_name[i], property_param);if (i 1) {sg_led_info.brightness atoi(property_param);}HAL_Free(property_param);}}HAL_Free(report);HAL_Free(data);
}static void property_report_reply_handle(const char *report_reply_data)
{char *status NULL;status LITE_json_value_of(status, (char *)report_reply_data);if (NULL status) {Log_e(Fail to parse data);return;}Log_i(report reply status: %s, status);HAL_Free(status);
}void unbind_device_callback(void *pContext, const char *msg, uint32_t msgLen)
{Log_i(unbind device.);
}// callback when MQTT msg arrives
static void property_message_callback(void *pClient, MQTTMessage *message, void *userData)
{char property_data_buf[QCLOUD_IOT_MQTT_RX_BUF_LEN 1] {0};int property_data_len 0;char *type_str NULL;char *token_str NULL;if (message NULL) {return;}Log_i(Receive Message With topicName:%.*s, payload:%.*s, (int)message-topic_len, message-ptopic,(int)message-payload_len, (char *)message-payload);property_data_len sizeof(property_data_buf) message-payload_len ? message-payload_len : QCLOUD_IOT_MQTT_RX_BUF_LEN;memcpy(property_data_buf, message-payload, property_data_len);type_str LITE_json_value_of(method, property_data_buf);if (NULL type_str) {Log_e(Fail to parse method);return;}token_str LITE_json_value_of(clientToken, property_data_buf);if (NULL type_str) {Log_e(Fail to parse token);HAL_Free(type_str);return;}if (0 strncmp(type_str, control, sizeof(control) - 1)) {// method: controlproperty_control_handle(pClient, token_str, property_data_buf);} else if (0 strncmp(type_str, get_status_reply, sizeof(get_status_reply) - 1)) {// method: get_status_replyproperty_get_status_reply_handle(property_data_buf);} else if (0 strncmp(type_str, report_reply, sizeof(report_reply) - 1)) {// method: report_replyproperty_report_reply_handle(property_data_buf);} else {// do nothing}HAL_Free(token_str);HAL_Free(type_str);
}// subscribe MQTT topic and wait for sub result
static int subscribe_property_topic_wait_result(void *client)
{char topic_name[128] {0};int size HAL_Snprintf(topic_name, sizeof(topic_name), $thing/down/property/%s/%s, sg_devInfo.product_id,sg_devInfo.device_name);if (size 0 || size sizeof(topic_name) - 1) {Log_e(topic content length not enough! content size:%d buf size:%d, size, (int)sizeof(topic_name));return QCLOUD_ERR_FAILURE;}SubscribeParams sub_params DEFAULT_SUB_PARAMS;sub_params.qos QOS0;sub_params.on_message_handler property_message_callback;int rc IOT_MQTT_Subscribe(client, topic_name, sub_params);if (rc 0) {Log_e(MQTT subscribe FAILED: %d, rc);return rc;}int wait_cnt 10;while (!IOT_MQTT_IsSubReady(client, topic_name) (wait_cnt 0)) {// wait for subscription resultrc IOT_MQTT_Yield(client, 1000);if (rc) {Log_e(MQTT error: %d, rc);return rc;}wait_cnt--;}if (wait_cnt 0) {return QCLOUD_RET_SUCCESS;} else {Log_e(wait for subscribe result timeout!);return QCLOUD_ERR_FAILURE;}
}#ifdef LOG_UPLOAD
// init log upload module
static int _init_log_upload(MQTTInitParams *init_params)
{LogUploadInitParams log_init_params;memset(log_init_params, 0, sizeof(LogUploadInitParams));log_init_params.region init_params-region;log_init_params.product_id init_params-product_id;log_init_params.device_name init_params-device_name;
#ifdef AUTH_MODE_CERTlog_init_params.sign_key init_params-cert_file;
#elselog_init_params.sign_key init_params-device_secret;
#endif#if defined(__linux__) || defined(WIN32)log_init_params.read_func HAL_Log_Read;log_init_params.save_func HAL_Log_Save;log_init_params.del_func HAL_Log_Del;log_init_params.get_size_func HAL_Log_Get_Size;
#endifreturn IOT_Log_Init_Uploader(log_init_params);
}#endifstatic bool sg_loop_test false;
static int parse_arguments(int argc, char **argv)
{int c;while ((c utils_getopt(argc, argv, c:l)) ! EOF) switch (c) {case c:if (HAL_SetDevInfoFile(utils_optarg))return -1;break;case l:sg_loop_test true;break;default:HAL_Printf(usage: %s [options]\n [-c config file for DeviceInfo] \n [-l ] loop test or not\n,argv[0]);return -1;}return 0;
}int main(int argc, char **argv)
{int rc;// init log levelIOT_Log_Set_Level(eLOG_DEBUG);IOT_Log_Set_MessageHandler(log_handler);// parse arguments for device info file and loop test;rc parse_arguments(argc, argv);if (rc ! QCLOUD_RET_SUCCESS) {Log_e(parse arguments error, rc %d, rc);return rc;}// init connectionMQTTInitParams init_params DEFAULT_MQTTINIT_PARAMS;rc _setup_connect_init_params(init_params);if (rc ! QCLOUD_RET_SUCCESS) {Log_e(init params error, rc %d, rc);return rc;}#ifdef LOG_UPLOAD// _init_log_upload should be done after _setup_connect_init_params and before IOT_MQTT_Constructrc _init_log_upload(init_params);if (rc ! QCLOUD_RET_SUCCESS)Log_e(init log upload error, rc %d, rc);
#endif// create MQTT client and connect with servervoid *client IOT_MQTT_Construct(init_params);if (client ! NULL) {Log_i(Cloud Device Construct Success);} else {rc IOT_MQTT_GetErrCode();Log_e(MQTT Construct failed, rc %d, rc);return QCLOUD_ERR_FAILURE;}#ifdef SYSTEM_COMMlong time 0;// get system timestamp from serverrc IOT_Get_Sys_Resource(client, eRESOURCE_TIME, sg_devInfo, time);if (QCLOUD_RET_SUCCESS rc) {Log_i(system time is %ld, time);} else {Log_e(get system time failed!);}
#endif// subscribe normal topics hererc subscribe_property_topic_wait_result(client);if (rc 0) {Log_e(Client Subscribe Topic Failed: %d, rc);return rc;}// when platform unbind this device. the callback function will runIOT_Unbind_Device_ByCloud(client, unbind_device_callback, NULL);// method: get_statusproperty_get_status(client);do {rc IOT_MQTT_Yield(client, 500);if (rc QCLOUD_ERR_MQTT_ATTEMPTING_RECONNECT) {HAL_SleepMs(1000);continue;} else if (rc ! QCLOUD_RET_SUCCESS rc ! QCLOUD_RET_MQTT_RECONNECTED) {if (rc QCLOUD_ERR_MQTT_RECONNECT_TIMEOUT) {Log_e(exit. mqtt reconnect timeout! Please check the network connection, or try to increase MAX_RECONNECT_WAIT_INTERVAL(%d),MAX_RECONNECT_WAIT_INTERVAL);} else {Log_e(exit with error: %d, rc);}break;}if (sg_loop_test)HAL_SleepMs(1000);// method: reportproperty_report(client);} while (sg_loop_test);rc IOT_Unbind_Device_Request(client, 5000);if (rc ! QCLOUD_RET_SUCCESS) {Log_e(unbind device request error.);}rc IOT_MQTT_Destroy(client);IOT_Log_Upload(true);#ifdef LOG_UPLOADIOT_Log_Fini_Uploader();
#endifreturn rc;
}
注意记得将HAL_Device_rtthread.c文件中的参数替换为自己的 对应参数在腾讯云设备管理中查看 SDK文章顶部下载。
