怎样在MQTT客户端上去移植C语言呢

566

问答对人有帮助，内容完整，我也想知道答案 0 怎样在MQTT客户端上去移植C语言呢？如何去实现其代码呢？ 0
2022-2-25 07:16:10　　评论淘帖0 邀请回答您可以邀请以下用户，快速回答问题 × heks 该类别下有 20 个回答。邀请回答新星之火12138 该类别下有 18 个回答。邀请回答 wang21cj 该类别下有 17 个回答。邀请回答 hgimtk 该类别下有 16 个回答。邀请回答科源机电该类别下有 15 个回答。邀请回答 liutiefu 该类别下有 15 个回答。邀请回答 kghfh 该类别下有 14 个回答。邀请回答 723662364d 该类别下有 13 个回答。邀请回答一巷清苑该类别下有 13 个回答。邀请回答 chm5 该类别下有 13 个回答。邀请回答 dgfdf 该类别下有 13 个回答。邀请回答 hjhdf 该类别下有 12 个回答。邀请回答 efwedfd 该类别下有 12 个回答。邀请回答小华同学该类别下有 12 个回答。邀请回答 jsqueh 该类别下有 12 个回答。邀请回答红旧衫该类别下有 12 个回答。邀请回答早知该类别下有 12 个回答。邀请回答 Ehunt 该类别下有 12 个回答。邀请回答张峰9998 该类别下有 12 个回答。邀请回答 hy381 该类别下有 12 个回答。邀请回答举报 douyin8 相关推荐 • 怎样在RT-Thread Studio上去开启MQTT示例呢 1447 • MQTT连接的流程是怎样的？ 1148 • 如何使用ESP8266搭建MQTT客户端？ 350 • MQTT客户端栈大小分配过大而导致无法初始化怎么处理？ 172 • MQTT客户端发送消息出错是什么原因造成的呢？ 508 • 如何在rtos mqtt示例中获取客户端句柄？ 278 • 怎样将mqtt移植到单片机工程中呢 683 • 什么是MQTT？MQTT功能介绍 2356 • IDFv5中的MQTT - user_context在哪里？ 167 • 请教大神IDFv5中的MQTT-user_context在哪里呢？ 114 1个回答

答案对人有帮助，有参考价值 0 首先，下面的Demo是在linux上运行的，说明了嵌入的MQTT客户端使用的，其就是把一些数据流程片MQTT协议打包好，再通过socket发送，你也可以移植到机器上， WiFi模块能够连接到服务通信，比如sp86模块WiFi模块，内置了TCP/IP协议片机，直接可以通过AT指令发送数据，直接通过AT指令发送数据，WiFi可以把数据栈发送到服务器。 MQTT Subscribe Demo #include #include #include #include #include #include #include #include #include #include #include #include "src/MQTTPacket.h" int sock; pthread_t ping; void * ping_thread(void * arg); void TcpConnect(const char host, int port); int main(void) { //建立TCP连接 TcpConnect("127.0.0.1", 1883); //初始化连接参数，MQTTPacket_connectData_initializer定义在MQTTConnect.h unsigned char buf[256]; int bufsize = sizeof(buf); MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.clientID.cstring = "zhou001"; //客户端ID data.keepAliveInterval = 30; //存活时间，如果30秒内设备没有向服务器发送ping数据就会短线； data.cleansession = 1; //清除会话 data.username.cstring = "admin"; //用户名 data.password.cstring = "admin"; //密码 //打包和发送connect数据 int len = MQTTSerialize_connect(buf, bufsize, &data); send(sock, buf, len, 0); printf("Connecting...n"); recv(sock, buf, bufsize, 0); //等待连接 //创建ping线程, 25秒ping一次 pthread_create(&ping, NULL, ping_thread, NULL); //订阅主题 MQTTString topicString = MQTTString_initializer; int msgid = 1; //消息id int req_qos = 0; //消息质量 topicString.cstring = "topic1"; //主题名称 len = MQTTSerialize_subscribe(buf, bufsize, 0, msgid, 1, &topicString, &req_qos); //打包subscribe数据 send(sock, buf, len, 0); //发送subscribe数据 printf("Subcribing...n"); while(1) { len = recv(sock, buf, bufsize, 0); if(len > 0) { if(buf[0] == 0x30) //判断接收到的消息是否是publish { //解包publish数据 unsigned char dup; int qos; unsigned char retained; unsigned short msgid; int payloadlen_in; unsigned char payload_in; //指向payload int rc; MQTTString receivedTopic; MQTTDeserialize_publish(&dup, &qos, &retained, &msgid, &receivedTopic, &payload_in, &payloadlen_in, buf, bufsize); printf("message arrived %.sn", payloadlen_in, payload_in); } } } } void TcpConnect(const char host, int port) { //创建套接字 sock = socket(AF_INET, SOCK_STREAM, 0); //向服务器（特定IP和端口）发送请求 struct sockaddr_in serv_addr; memset(&serv_addr, 0, sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = inet_addr(host); serv_addr.sin_port = htons(port); int res = connect(sock, (struct sockaddr )&serv_addr, sizeof(serv_addr)); if(res == 0) printf("TCP Connectedn"); } void ping_thread(void arg) { (void)arg; uint8_t buf[10]; int bufsize = sizeof(buf); int len = 0; printf("Ping thread is runningn"); while(1) { sleep(20); //打包和发送ping数据 len = MQTTSerialize_pingreq(buf, bufsize); send(sock, buf, len, 0); printf("Ping...n"); } } MQTT Publish Demo #include #include #include #include #include #include #include #include #include #include #include #include "src/MQTTPacket.h" int sock; pthread_t ping; void ping_thread(void * arg); void TcpConnect(const char host, int port); int main(void) { //建立TCP连接 TcpConnect("127.0.0.1", 1883); //初始化连接参数，MQTTPacket_connectData_initializer定义在MQTTConnect.h unsigned char buf[256]; int bufsize = sizeof(buf); MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.clientID.cstring = "zhou002"; //客户端ID data.keepAliveInterval = 30; //存活时间，如果30秒内设备没有向服务器发送ping数据就会短线； data.cleansession = 1; //清除会话 data.username.cstring = "admin"; //用户名 data.password.cstring = "admin"; //密码 //打包和发送connect数据 int len = MQTTSerialize_connect(buf, bufsize, &data); send(sock, buf, len, 0); printf("Connecting...n"); recv(sock, buf, bufsize, 0); //等待连接 //创建ping线程，25秒ping一次 pthread_create(&ping, NULL, ping_thread, NULL); MQTTString topicString = MQTTString_initializer; topicString.cstring = "topic1"; unsigned char payload = "hello"; while(1) { sleep(2); len = MQTTSerialize_publish(buf, bufsize, 0, 0, 0, 0, topicString, payload, strlen(payload)); send(sock, buf, len, 0); printf("message sent hellon"); } } void TcpConnect(const char host, int port) { //创建套接字 sock = socket(AF_INET, SOCK_STREAM, 0); //向服务器（特定IP和端口）发送请求 struct sockaddr_in serv_addr; memset(&serv_addr, 0, sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = inet_addr(host); serv_addr.sin_port = htons(port); int res = connect(sock, (struct sockaddr )&serv_addr, sizeof(serv_addr)); if(res == 0) printf("TCP Connectedn"); } void * ping_thread(void *arg) { (void)arg; uint8_t buf[10]; int bufsize = sizeof(buf); int len = 0; printf("Ping thread is runningn"); while(1) { sleep(25); //打包和发送ping数据 len = MQTTSerialize_pingreq(buf, bufsize); send(sock, buf, len, 0); printf("Ping...n"); } }

2022-2-25 10:01:22 评论举报邢洋