当前位置：首页 > news >正文

【星闪技术】WS63E模块连接华为IoT云

news 2024/10/22 9:43:36

引言

WS63E对MQTT的支持

程序修改

测试结果

结语

引言

在上一篇博文中已经介绍了WiFi的使用。今天介绍一下如何使用MQTT协议连接到华为云上。

WS63E对MQTT的支持

WS63E的代码参考直接提供了MQTT的支持，文档介绍见docs/board/WS63V100 MQTT 开发指南.pdf。MQTT 基于开源组件paho.mqtt.c-1.3.12 实现，详细说明请参考官方说明： https://www.eclipse.org/paho/files/mqttdoc/MQTTClient/html/index.html

在网上也找到一位网友的MQTT例子，值得大家参考：GitHub - chenyunbovo/nearlink_ws63_demo: 用于展示WS63的使用示例。

程序修改

华为云平台的设置可以参考我以前的博文：MQTTX连接华为云IoTDA_华为iot mqtt-CSDN博客。在云平台方面，我们仍然使用的是以前配置过的温湿度计。

我在前面的WiFi实例基础上进行修改。主要增加了以下内容：

#include "MQTTClient.h" 
#include "MQTTClientPersistence.h" 
#include "osal_debug.h" 
#include "MQTTClient.h" 
#include "los_memory.h" 
#include "los_task.h" #define QOS 0 
#define TIMEOUT 10000L 
#define KEEPALIVEINTERVAL 20 
#define CLEANSESSION 1 #define USE_SSL 0#define ADDRESS "tcp://xxxx.iotda-device.cn-north-4.myhuaweicloud.com:1883"
#define USERNAME    "xxxxxxx_test1"
#define PASSWORD    "xxxxxxxxxxxxxxx"
#define CLIENTID    "xxxxxxx_test1_0_0_2024102012"static MQTTClient client;
void publish(MQTTClient client, char *topic, char *payload) ;static td_u8 g_wifi_state = WIFI_STA_SAMPLE_INIT;// Define the on_message callback function to print the content of the messages received by the subscribed topic
static int on_message(void *context, char *topicName, int topicLen, MQTTClient_message *message) 
{UNUSED(context);UNUSED(topicLen);char *payload = message->payload;printf("Received `%s` from `%s` topic \n", payload, topicName);MQTTClient_freeMessage(&message);MQTTClient_free(topicName);return 1;
}int mqtt_init(void) 
{int rc;MQTTResponse ret;MQTTClient_init_options ops;ops.do_openssl_init = 0;MQTTClient_global_init(&ops);MQTTClient_createOptions create_opts = { {'M', 'Q', 'C', 'O'}, 0, MQTTVERSION_5 };rc = MQTTClient_createWithOptions(&client, ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_DEFAULT, NULL, &create_opts);if (rc != MQTTCLIENT_SUCCESS) {printf("Failed to create mqtt client, return code %d\n", rc);return -1;}// 设置MQTT消息接受回调函数MQTTClient_setCallbacks(client, NULL, NULL, on_message, NULL);MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer5;conn_opts.username = USERNAME;conn_opts.password = PASSWORD;MQTTProperties props = MQTTProperties_initializer;MQTTProperties willProps = MQTTProperties_initializer;ret = MQTTClient_connect5(client, &conn_opts, &props, &willProps);if (ret.reasonCode == MQTTREASONCODE_SUCCESS) {printf("Connected to MQTT Broker!\n");} else {printf("failed to connect to MQTT Broker, return code %d\n", (int8_t)ret.reasonCode);MQTTResponse_free(ret);return -1;}MQTTResponse_free(ret);char msg[500];sprintf_s(msg, 499, "{ \\"services\": [  \{  \\"serviceId\": \"温湿度\",  \\"properties\": {  \\"温度\": %d,  \\"湿度\": %d  \}  \}  \]  \}", 12, 76);for (int i = 0; i < 5; i++) {publish(client, "$oc/devices/XXXX_test1/sys/properties/report", msg);(void)osDelay(1000);}MQTTResponse_free(ret);    return 0;
}void publish(MQTTClient client, char *topic, char *payload) 
{MQTTClient_message message = MQTTClient_message_initializer;message.payload = payload;message.payloadlen = strlen(payload);message.qos = QOS;message.retained = 0;MQTTClient_deliveryToken token;MQTTClient_publishMessage5(client, topic, &message, &token);MQTTClient_waitForCompletion(client, token, TIMEOUT);printf("Send `%s` to topic `%s` \n", payload, topic);
}td_s32 example_sta_function(td_void)
{td_char ifname[WIFI_IFNAME_MAX_SIZE + 1] = "wlan0"; /* 创建的STA接口名 */wifi_sta_config_stru expected_bss = {0}; /* 连接请求信息 */struct netif *netif_p = TD_NULL;td_u32 wait_count = 0;/* 创建STA接口 */if (wifi_sta_enable() != 0) {return -1;}PRINT("%s::STA enable succ.\r\n", WIFI_STA_SAMPLE_LOG);do {(void)osDelay(1); /* 1: 等待10ms后判断状态 */if (g_wifi_state == WIFI_STA_SAMPLE_INIT) {
…………} else if (g_wifi_state == WIFI_STA_SAMPLE_GET_IP) {if (example_check_dhcp_status(netif_p, &wait_count) == 0) {mqtt_init();break;}wait_count++;}} while (1);return 0;
}

我在WiFi连上路由器并获得IP后启动了MQTT客户端。客户端连接到华为IoT云，然后定时发布了温湿度信息。绝大多数内容在前面的博文中都已经介绍了，这里就不再赘述了。

测试结果

程序烧写之后，登录华为云的控制台，就可以看到上传的温湿度信息。

设备侧的部分日志如下：

+NOTICE:CONNECTED
drv_soc_ioctl ioctl_cmd->cmd=6.
Srv:548:recive event = 2
APP|[WIFI_STA_SAMPLE]::Connect succ!.
APP|[WIFI_STA_SAMPLE]::DHCP start.
xo update temp:4,diff:0,xo:0x3083c
APP|[WIFI_STA_SAMPLE]::STA DHCP success.
Connecting to serverURI bde4cbe7aa.st1.iotda-device.cn-north-4.myhuaweicloud.com:1883 with MQTT verNew socket 0 for bde4cbe7aa.st1.iotda-device.cn-north-4.myhuaweicloud.com:1883, port 18830 66991e97a559ef622669048e_test1_0_0_2024102012 -> CONNECT version 5 clean: 0 (0)Posting connack semaphore for client 66991e97a559ef622669048e_test1_0_0_20241020120 66991e97a559ef622669048e_test1_0_0_2024102012 <- CONNACK rc: 0Connected to MQTT Broker!0 66991e97a559ef622669048e_test1_0_0_2024102012 -> PUBLISH rc: 0Send `{                 "services": [                      {                          "serviceId": "温湿度",                          "properties": {                              "温度": 12,                              "湿度": 76                          }                      }                  ]              }` to topic `$oc/devices/66991e97a559ef622669048e_test1/sys/properties/report`APP|[SYS INFO] mem: used:138600, free:223804; log: drop/all[0/0], at_recv 0.
0 66991e97a559ef622669048e_test1_0_0_2024102012 -> PUBLISH rc: 0Send `{                 "services": [                      {                          "serviceId": "温湿度",                          "properties": {                              "温度": 12,                              "湿度": 76                          }                      }                  ]              }` to topic `$oc/devices/66991e97a559ef622669048e_test1/sys/properties/report`APP|[SYS INFO] mem: used:138600, free:223804; log: drop/all[0/0], at_recv 0.
0 66991e97a559ef622669048e_test1_0_0_2024102012 -> PUBLISH rc: 0Send `{                 "services": [                      {                          "serviceId": "温湿度",                          "properties": {                              "温度": 12,                              "湿度": 76                          }                      }                  ]              }` to topic `$oc/devices/66991e97a559ef622669048e_test1/sys/properties/report`APP|[SYS INFO] mem: used:138600, free:223804; log: drop/all[0/0], at_recv 0.
0 66991e97a559ef622669048e_test1_0_0_2024102012 -> PUBLISH rc: 0Send `{                 "services": [                      {                          "serviceId": "温湿度",                          "properties": {                              "温度": 12,                              "湿度": 76                          }                      }                  ]              }` to topic `$oc/devices/66991e97a559ef622669048e_test1/sys/properties/report`APP|[SYS INFO] mem: used:138600, free:223804; log: drop/all[0/0], at_recv 0.

结语

WS63E在WiFi和MQTT的编程和OpenHarmony差不多，所以遇到的问题并不多。WS63E采用的是CMake系统，比OpenHarmony的GN要更熟悉一些。但是它也有个问题，就是有时候稍微修改一下C语言文件，即使不涉及头文件的修改，系统也会从头编译700多个文件，时间偏长，估计是系统在计算文件依赖方面有一些问题。

查看全文

http://www.mrgr.cn/news/55062.html