鸿蒙硬件HI3861-MQTT

鸿蒙硬件HI3861-MQTT鸿蒙其他教程请看https://blog.csdn.net/qq_33259323/category_10520249.html
在使用MQTT前，请看我上一篇文章：鸿蒙硬件HI3861-连接WIFI
https://blog.csdn.net/qq_33259323/article/details/109511005
需要连接WIFI成功之后才能使用MQTT
参考文档：https://bbs.elecfans.com/jishu_2004598_1_1.html
1.移植MQTT移植前请确保你的项目是编译成功的
点击这个链接下载移植好的PahoMqtt(不要积分免费)：链接：https://pan.baidu.com/s/1ohH-kCYjiIOa-PkOxzuyEQ 提取码：gddy
点击这个链接下载移植好的PahoMqtt(不要积分免费)：https://download.csdn.net/download/qq_33259323/13092141，然后把pahomqtt文件夹放到third_party目录下面
打开vendor\hisi\hi3861\hi3861\BUILD.gn 文件，在lite_component("sdk") 中增加      "//third_party/pahomqtt:pahomqtt_static"
之后就编译一下看看是否成功
2.编写测试代码BUILD.gn

1. static_library("mqtt_test_at") {
   
2.     sources = [
   
3.         "mqtt_test.c",
   
4.         "at_entry.c"
   
5.     ]
   
6. 
   
7.     include_dirs = [
   
8.         "//utils/native/lite/include",
   
9.         "//kernel/liteos_m/components/cmsis/2.0",
   
10.         "//base/iot_hardware/inteRFaces/kits/wifiiot_lite",
    
11.         "//vendor/hisi/hi3861/hi3861/third_party/lwip_sack/include",
    
12.         "//foundation/communication/interfaces/kits/wifi_lite/wifiservice",
    
13.         "//third_party/pahomqtt/MQTTPacket/src",
    
14.         "//third_party/pahomqtt/MQTTPacket/samples",
    
15.         "//vendor/hisi/hi3861/hi3861/components/at/src"
    
16.     ]
    
17. }

复制代码

mqtt_test.c

1. #include <stdio.h>
   
2. 
   
3. #include <unistd.h>
   
4. 
   
5. #include "ohos_init.h"
   
6. #include "cmsis_os2.h"
   
7. 
   
8. #include <unistd.h>
   
9. #include "hi_wifi_api.h"
   
10. //#include "wifi_sta.h"
    
11. #include "lwip/ip_addr.h"
    
12. #include "lwip/netifapi.h"
    
13. 
    
14. #include "lwip/sockets.h"
    
15. 
    
16. #include "MQTTPacket.h"
    
17. #include "transport.h"
    
18. 
    
19. int mqtt_rc = 0;
    
20. int mqtt_sock = 0;
    
21. int mqtt_len = 0;
    
22. unsigned char mqtt_buf[200];
    
23. int mqtt_buflen = sizeof(mqtt_buf);
    
24. int mqtt_req_qos = 0;
    
25. int mqtt_msgid = 1;
    
26. int toStop = 0;
    
27. MQTTString topicString = MQTTString_initializer;
    
28. 
    
29. void mqtt_exit(void){
    
30.         transport_close(mqtt_sock);
    
31.         mqtt_rc = mqtt_rc;
    
32.         printf("[MQTT] ERROR EXIT\n");
    
33. }
    
34. 
    
35. void mqtt_task(void){
    
36.         while (!toStop){
    
37.                 char* payload = "hello HarmonyOS 1122321321";
    
38.                 int payloadlen = strlen(payload);
    
39. 
    
40.                 if (MQTTPacket_read(mqtt_buf, mqtt_buflen, transport_getdata) == PUBLISH){
    
41.                         unsigned char dup;
    
42.                         int qos;
    
43.                         unsigned char retained;
    
44.                         unsigned short msgid;
    
45.                         int payloadlen_in;
    
46.                         unsigned char* payload_in;
    
47.                         int rc;
    
48.                         MQTTString receivedTopic;
    
49.                         rc = MQTTDeserialize_publish(&dup, &qos, &retained, &msgid, &receivedTopic,
    
50.                                         &payload_in, &payloadlen_in, mqtt_buf, mqtt_buflen);                                                                // 发送数据
    
51.                         printf("message arrived %.*s\n", payloadlen_in, payload_in);
    
52. 
    
53.             mqtt_rc = rc;
    
54.         }
    
55. 
    
56.                 printf("publishing reading\n");
    
57.                 mqtt_len = MQTTSerialize_publish(mqtt_buf, mqtt_buflen, 0, 0, 0, 0, topicString, (unsigned char*)payload, payloadlen);
    
58.         mqtt_rc = transport_sendPacketBuffer(mqtt_sock, mqtt_buf, mqtt_len);
    
59. 
    
60.                 osDelay(1000);
    
61.         }
    
62. }
    
63. 
    
64. int mqtt_subscribe(char * topic){        // MQTT订阅
    
65.         /* subscribe */
    
66.         topicString.cstring = topic;
    
67.         mqtt_len = MQTTSerialize_subscribe(mqtt_buf, mqtt_buflen, 0, mqtt_msgid, 1, &topicString, &mqtt_req_qos);        // MQTT订阅
    
68.         mqtt_rc = transport_sendPacketBuffer(mqtt_sock, mqtt_buf, mqtt_len);                                                                        // 传输发送缓冲区
    
69.         if (MQTTPacket_read(mqtt_buf, mqtt_buflen, transport_getdata) == SUBACK)         /* wait for suback */        // 等待订阅返回
    
70.         {
    
71.                 unsigned short submsgid;
    
72.                 int subcount;
    
73.                 int granted_qos;
    
74. 
    
75.                 mqtt_rc = MQTTDeserialize_suback(&submsgid, 1, &subcount, &granted_qos, mqtt_buf, mqtt_buflen);
    
76.                 if (granted_qos != 0){
    
77.                         printf("granted qos != 0, %d\n", granted_qos);
    
78.                         mqtt_exit();
    
79.                         return 0;
    
80.                 }
    
81. 
    
82.                 return 1;
    
83.         }else{
    
84.                 mqtt_exit();
    
85.                 return 0;
    
86.         }
    
87. }
    
88. 
    
89. int mqtt_init(void){                // MQTT初始化开始连接
    
90.         MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
    
91.         char *host = "106.13.62.194";                // 地址
    
92.         int port = 1883;                                        // 端口
    
93. 
    
94.        
    
95.         mqtt_sock = transport_open(host, port);
    
96.         if(mqtt_sock < 0){
    
97.                 return mqtt_sock;
    
98.         }
    
99. 
    
100.         data.clientID.cstring = "me";                        // ClientID
     
101.         data.keepAliveInterval = 20;
     
102.         data.cleansession = 1;
     
103.         data.username.cstring = "testuser";                // 用户名
     
104.         data.password.cstring = "testpassword";        // 密码
     
105. 
     
106.         printf("[MQTT]Sending to hostname %s port %d\n", host, port);
     
107. 
     
108.         mqtt_len = MQTTSerialize_connect(mqtt_buf, mqtt_buflen, &data);                // 开始连接
     
109.         mqtt_rc = transport_sendPacketBuffer(mqtt_sock, mqtt_buf, mqtt_len);                // 发送缓冲区
     
110. 
     
111.         if (MQTTPacket_read(mqtt_buf, mqtt_buflen, transport_getdata) == CONNACK){        // 等待链接返回
     
112.                 unsigned char sessionPresent, connack_rc;
     
113. 
     
114.                 if (MQTTDeserialize_connack(&sessionPresent, &connack_rc, mqtt_buf, mqtt_buflen) != 1 || connack_rc != 0){
     
115.                         printf("Unable to connect, return code %d\n", connack_rc);
     
116.                         mqtt_exit();
     
117.                         return 0;
     
118.                 }
     
119.         }else{
     
120.                 mqtt_exit();
     
121.                 return 0;
     
122.         }
     
123. 
     
124.         return 1;
     
125. }
     
126. 
     
127. 
     
128. void mqtt_test(void){
     
129.         printf("[MQTT]Start MQTT\r\n");
     
130.     if(mqtt_init() == 1){
     
131.                 printf("[MQTT]MQTT Connect\r\n");
     
132.                 mqtt_subscribe("substopic");                //设置订阅
     
133.                 mqtt_task();
     
134.         }
     
135. }

复制代码

mqtt_test.h

1. #ifndef __MQTT_TEST_H__
   
2. #define __MQTT_TEST_H__
   
3. 
   
4. void mqtt_test(void);
   
5. 
   
6. #endif /* __MQTT_TEST_H__ */

复制代码

3.开始测试只要在主函数中调用mqtt_test.c中的mqtt_test()函数就可以开始测试了


如果有什么问题可以来B站问我

https://space.bilibili.com/309103931