在鴻蒙系統上使用MQTT編程

想了解更多內容，請訪問：

51CTO和華為官方戰略合作共建的鴻蒙技術社區

https://harmonyos.51cto.com/#zz

我們使用的是paho mqtt軟體包，這裡介紹一下怎麼使用mqtt協議編程。關於鴻蒙系統的mqtt移植好的軟體包，相關github連結如下：

https://gitee.com/qidiyun/harmony_mqtt

這裡提供一個簡單的編程示例：

這裡我們使用MQTTClient編程模型，他支持多任務多線程，非常適合用在鴻蒙系統上。

1. 網絡初始化

這裡定義一個 Network 結構體，然後指定我們的MQTT伺服器的IP和埠號。

1. Network n; 
2.    //初始化結構體 
3.  NetworkInit(&n); 
4.  //連接到指定的MQTT伺服器IP、埠號 
5.  NetworkConnect(&n, 「XXX.XXX.XXX.XXX」, XXXX); 

2. 設置MQTT緩存和啟動MQTT線程

我們這裡使用的是MQTT線程功能。

1. MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100); 
2.  MQTTStartTask(&c); 

3. 設置MQTT相關參數

接下來我們設置MQTT的相關參數，包括版本號、客戶端ID、帳戶密碼等

1. MQTTPacket_connectData data = MQTTPacket_connectData_initializer;  
2.  data.willFlag = 0; 
3.  //MQTT版本為 v3 
4.  data.MQTTVersion = 3; 
5.  //設置客戶端ID 
6.  data.clientID.cstring = opts.clientid; 
7.  //設置客戶端帳戶 
8.  data.username.cstring = opts.username; 
9.  //設置客戶端密碼 
10.  data.password.cstring = opts.password; 
11.  data.keepAliveInterval = 10; 
12.  data.cleansession = 1; 
13.  
14.  //連接到MQTT伺服器 
15.  rc = MQTTConnect(&c, &data); 

4. 訂閱主題和接收消息

訂閱主題可以使用如下函數

1. MQTTSubscribe(&c, topic, opts.qos, messageArrived); 

它的函數原型如下：

1. DLLExport int MQTTSubscribe(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler); 

其中：

1. void messageArrived(MessageData* md) 
2. { 
3.  MQTTMessage* message = md->message; 
4.  //列印接收到的消息的長度、和消息內容 
5.  printf("%.*s", (int)message->payloadlen, (char*)message->payload); 
6. } 

 5. 發送消息

發送消息也比較簡單，我們只需要設置好我們的主題和消息內容即可

1. memset(&pubmsg, '\0', sizeof(pubmsg)); 
2.  //消息內容為 hello harmonyOS ! 
3.    pubmsg.payload = (void*)"hello harmonyOS !"; 
4.  //消息長度 
5.    pubmsg.payloadlen = strlen((char*)pubmsg.payload); 
6.    pubmsg.qos = QOS0; 
7.    pubmsg.retained = 0; 
8.    pubmsg.dup = 0; 
9.  
10.  //推送消息，主題為 pubtest 
11.  MQTTPublish(&c, "pubtest", &pubmsg); 

完整源碼如下：

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 "MQTTClient.h" 
17.  
18. /** 
19.  * MQTT URI farmat: 
20.  * domain mode 
21.  * tcp://iot.eclipse.org:1883 
22.  * 
23.  * ipv4 mode 
24.  * tcp://192.168.10.1:1883 
25.  * ssl://192.168.10.1:1884 
26.  * 
27.  * ipv6 mode 
28.  * tcp://[fe80::20c:29ff:fe9a:a07e]:1883 
29.  * ssl://[fe80::20c:29ff:fe9a:a07e]:1884 
30.  */ 
31. #define MQTT_URI                "tcp://106.13.62.194:1883" 
32.  
33. struct opts_struct 
34. { 
35.     char* clientid; 
36.     int nodelimiter; 
37.     char* delimiter; 
38.     enum QoS qos; 
39.     char* username; 
40.     char* password; 
41.     char* host; 
42.     int port; 
43.     int showtopics; 
44. } opts = 
45. { 
46.     (char*)"stdout-subscriber", 0, (char*)"\n", QOS2, NULL, NULL, (char*)"106.13.62.194", 1883, 1 
47. }; 
48.  
49.  
50. void messageArrived(MessageData* md) 
51. { 
52.     MQTTMessage* message = md->message; 
53.  
54.     if (opts.showtopics) 
55.         printf("%.*s\t", md->topicName->lenstring.len, md->topicName->lenstring.data); 
56.     if (opts.nodelimiter) 
57.         printf("%.*s", (int)message->payloadlen, (char*)message->payload); 
58.     else 
59.         printf("%.*s%s", (int)message->payloadlen, (char*)message->payload, opts.delimiter); 
60.     //fflush(stdout); 
61. } 
62.  
63.  
64. unsigned char buf[100]; 
65. unsigned char readbuf[100]; 
66.  
67. int mqtt_test(void) 
68. { 
69.     int rc = 0; 
70.      
71.     MQTTMessage pubmsg; 
72.  
73.      
74.     char* topic = "test"; 
75.  
76.     if (strchr(topic, '#') || strchr(topic, '+')) 
77.         opts.showtopics = 1; 
78.     if (opts.showtopics) 
79.         printf("topic is %s\n", topic); 
80.  
81.     Network n; 
82.     MQTTClient c; 
83.  
84.     NetworkInit(&n); 
85.     NetworkConnect(&n, opts.host, opts.port); 
86.      
87.     MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100); 
88.     MQTTStartTask(&c); 
89.  
90.     MQTTPacket_connectData data = MQTTPacket_connectData_initializer;        
91.     data.willFlag = 0; 
92.     data.MQTTVersion = 3; 
93.     data.clientID.cstring = opts.clientid; 
94.     data.username.cstring = opts.username; 
95.     data.password.cstring = opts.password; 
96.  
97.     data.keepAliveInterval = 10; 
98.     data.cleansession = 1; 
99.     printf("Connecting to %s %d\n", opts.host, opts.port); 
100.      
101.     rc = MQTTConnect(&c, &data); 
102.     printf("Connected %d\n", rc); 
103.      
104.      
105.  
106.     printf("Subscribing to %s\n", topic); 
107.     rc = MQTTSubscribe(&c, topic, opts.qos, messageArrived); 
108.     printf("Subscribed %d\n", rc); 
109.  
110.     memset(&pubmsg, '\0', sizeof(pubmsg)); 
111.     pubmsg.payload = (void*)"hello harmonyOS !"; 
112.     pubmsg.payloadlen = strlen((char*)pubmsg.payload); 
113.     pubmsg.qos = QOS0; 
114.     pubmsg.retained = 0; 
115.     pubmsg.dup = 0; 
116.  
117.      
118.  
119.     while (1) 
120.     { 
121.         MQTTPublish(&c, "pubtest", &pubmsg); 
122.         sleep(1);    
123.     } 
124.      
125.     printf("Stopping\n"); 
126.  
127.     MQTTDisconnect(&c); 
128.     NetworkDisconnect(&n); 
129.  
130.     return 0; 
131. } 

想了解更多內容，請訪問：

51CTO和華為官方戰略合作共建的鴻蒙技術社區

https://harmonyos.51cto.com/#zz

【編輯推薦】

點讚 0