1. 首页
  2. 文章中心
  3. 鸿蒙

在鸿蒙系统上使用MQTT编程

87 阅读 0 评论
我是靠谱客的博主 柔弱电灯胆，这篇文章主要介绍在鸿蒙系统上使用MQTT编程，现在分享给大家，希望可以做个参考。

我们使用的是paho mqtt软件包，这里介绍一下怎么使用mqtt协议编程。关于鸿蒙系统的mqtt移植好的软件包，相关github链接如下：

https://gitee.com/qidiyun/harmony_mqtt 

这里提供一个简单的编程示例：

这里我们使用MQTTClient编程模型，他支持多任务多线程，非常适合用在鸿蒙系统上。

 

1. 网络初始化

这里定义一个 Network 结构体，然后指定我们的MQTT服务器的IP和端口号。

复制代码
1
2
3
4
5
Network n;
   //初始化结构体
 NetworkInit(&n);
 //连接到指定的MQTT服务器IP、端口号
 NetworkConnect(&n, “XXX.XXX.XXX.XXX”, XXXX);

 

2. 设置MQTT缓存和启动MQTT线程

我们这里使用的是MQTT线程功能。

复制代码
1
2
 MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100);
 MQTTStartTask(&c);

 

3. 设置MQTT相关参数

接下来我们设置MQTT的相关参数，包括版本号、客户端ID、账户密码等

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
MQTTPacket_connectData data = MQTTPacket_connectData_initializer; 
 data.willFlag = 0;
 //MQTT版本为 v3
 data.MQTTVersion = 3;
 //设置客户端ID
 data.clientID.cstring = opts.clientid;
 //设置客户端账户
 data.username.cstring = opts.username;
 //设置客户端密码
 data.password.cstring = opts.password;
 data.keepAliveInterval = 10;
 data.cleansession = 1;

 //连接到MQTT服务器
 rc = MQTTConnect(&c, &data);

 

4. 订阅主题和接收消息

订阅主题可以使用如下函数

复制代码
1
MQTTSubscribe(&c, topic, opts.qos, messageArrived);

它的函数原型如下：

复制代码
1
DLLExport int MQTTSubscribe(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler);

其中：

MQTTClient* c ：我们前面定义的MQTTClient结构体

const char* topicFilter：订阅的主题

messageHandler messageHandler ：接收到主题信息后的回调处理函数。

例如上面我们的回调函数是  messageArrived ，它的原型如下：

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

 

5. 发送消息

发送消息也比较简单，我们只需要设置好我们的主题和消息内容即可

复制代码
1
2
3
4
5
6
7
8
9
10
11
memset(&pubmsg, '', sizeof(pubmsg));
 //消息内容为 hello harmonyOS !
   pubmsg.payload = (void*)"hello harmonyOS !";
 //消息长度
   pubmsg.payloadlen = strlen((char*)pubmsg.payload);
   pubmsg.qos = QOS0;
   pubmsg.retained = 0;
   pubmsg.dup = 0;

 //推送消息，主题为 pubtest
 MQTTPublish(&c, "pubtest", &pubmsg);

 

完整源码如下：

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
#include <stdio.h>

#include <unistd.h>

#include "ohos_init.h"
#include "cmsis_os2.h"

#include <unistd.h>
#include "hi_wifi_api.h"
//#include "wifi_sta.h"
#include "lwip/ip_addr.h"
#include "lwip/netifapi.h"

#include "lwip/sockets.h"

#include "MQTTClient.h"

/**
 * MQTT URI farmat:
 * domain mode
 * tcp://iot.eclipse.org:1883
 *
 * ipv4 mode
 * tcp://192.168.10.1:1883
 * ssl://192.168.10.1:1884
 *
 * ipv6 mode
 * tcp://[fe80::20c:29ff:fe9a:a07e]:1883
 * ssl://[fe80::20c:29ff:fe9a:a07e]:1884
 */
#define MQTT_URI                "tcp://106.13.62.194:1883"

struct opts_struct
{
	char* clientid;
	int nodelimiter;
	char* delimiter;
	enum QoS qos;
	char* username;
	char* password;
	char* host;
	int port;
	int showtopics;
} opts =
{
	(char*)"stdout-subscriber", 0, (char*)"n", QOS2, NULL, NULL, (char*)"106.13.62.194", 1883, 1
};


void messageArrived(MessageData* md)
{
	MQTTMessage* message = md->message;

	if (opts.showtopics)
		printf("%.*st", md->topicName->lenstring.len, md->topicName->lenstring.data);
	if (opts.nodelimiter)
		printf("%.*s", (int)message->payloadlen, (char*)message->payload);
	else
		printf("%.*s%s", (int)message->payloadlen, (char*)message->payload, opts.delimiter);
	//fflush(stdout);
}


unsigned char buf[100];
unsigned char readbuf[100];

int mqtt_test(void)
{
	int rc = 0;
	
	MQTTMessage pubmsg;

	
	char* topic = "test";

	if (strchr(topic, '#') || strchr(topic, '+'))
		opts.showtopics = 1;
	if (opts.showtopics)
		printf("topic is %sn", topic);

	Network n;
	MQTTClient c;

	NetworkInit(&n);
	NetworkConnect(&n, opts.host, opts.port);
	
	MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100);
	MQTTStartTask(&c);

	MQTTPacket_connectData data = MQTTPacket_connectData_initializer;       
	data.willFlag = 0;
	data.MQTTVersion = 3;
	data.clientID.cstring = opts.clientid;
	data.username.cstring = opts.username;
	data.password.cstring = opts.password;

	data.keepAliveInterval = 10;
	data.cleansession = 1;
	printf("Connecting to %s %dn", opts.host, opts.port);
	
	rc = MQTTConnect(&c, &data);
	printf("Connected %dn", rc);
    
	

    printf("Subscribing to %sn", topic);
	rc = MQTTSubscribe(&c, topic, opts.qos, messageArrived);
	printf("Subscribed %dn", rc);

	memset(&pubmsg, '', sizeof(pubmsg));
  	pubmsg.payload = (void*)"hello harmonyOS !";
  	pubmsg.payloadlen = strlen((char*)pubmsg.payload);
  	pubmsg.qos = QOS0;
  	pubmsg.retained = 0;
  	pubmsg.dup = 0;

	

	while (1)
	{
		MQTTPublish(&c, "pubtest", &pubmsg);
		sleep(1);	
	}
	
	printf("Stoppingn");

	MQTTDisconnect(&c);
	NetworkDisconnect(&n);

	return 0;
}

最后

以上就是柔弱电灯胆最近收集整理的关于在鸿蒙系统上使用MQTT编程的全部内容，更多相关在鸿蒙系统上使用MQTT编程内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(58)

相关文章

不用MQTT C库就能实现MQTT连接、订阅和发布先了解需要用到mqtt协议的哪些部分1、MQTT报文格式2、实现服务器连接3、订阅服务器Topic4、消息发布
不用MQTT C库就能实现MQTT连接、订阅和发布先了解需要用到mqtt协议的哪些部分1、MQTT报文格式2、实现服务器连接3、订阅服务器Topic4、消息发布
杰理之MQTT接口说明【篇】
杰理之MQTT接口说明【篇】
MQTT AT命令
MQTT AT命令
STM32 MQTT协议 连接中国移动OneNet服务器 上传接收数据（三）STM32部分STM32 MQTT协议 连接中国移动OneNet服务器 上传接收数据（三）STM32部分
STM32 MQTT协议 连接中国移动OneNet服务器 上传接收数据（三）STM32部分STM32 MQTT协议 连接中国移动OneNet服务器 上传接收数据（三）STM32部分
在鸿蒙系统上使用MQTT编程
在鸿蒙系统上使用MQTT编程
MQTT协议_连接
MQTT协议_连接
mqtt c语言 单片机,MQTT--单片机实现即时通讯
mqtt c语言 单片机,MQTT--单片机实现即时通讯
【.NET+MQTT】.NET6 环境下实现MQTT通信，以及服务端、客户端的双边消息订阅与发布的代码演示...
【.NET+MQTT】.NET6 环境下实现MQTT通信，以及服务端、客户端的双边消息订阅与发布的代码演示...

评论列表共有 0 条评论

立即
投稿
返回
顶部