[问答]

使用paho-mqtt里例程连接服务器失败怎么解决？

问答对人有帮助，内容完整，我也想知道答案 0 【rt-thread】【paho-mqtt】最近由于学习需要，了解了关于rt-thread软件包paho-mqtt的使用，但是使用官方例程时，出现连接不上服务器的情况。具体报错如下： msh />matt start [D/mgtt. sample] inter matt connect callback! [D/mgtt] ipv4 address port:1883 \|[D/mqtt] HOST=iot.eclipse.org' [E/mgtt] getaddrinfo err:-1'iot.eclipse.org' [E/mgtt] resolve uri err [E/mqtt] Net connect error(-1). [D/mgtt. sample] inter matt offline callback! 其中服务器IP地址尝试用过：官方例程提供的 “tcp://iot.eclipse.org:1883”、用通信猫提供的服务器"tcp://mq.tongxinmao:18831"、以及用ActiveMQ建立的本地服务器“tcp://192.168.0.242:1883”，都是报同样的错误”getaddrinfo err:-1“。请问有大神做过类似的吗？有没有遇到这种问题，最后怎么解决的，望指点，多谢！！例程代码如下： #include #include #include #include #define DBG_ENABLE #define DBG_SECTION_NAME "mqtt.sample" #define DBG_LEVEL DBG_LOG #define DBG_COLOR #include #include "paho_mqtt.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://iot.eclipse.org:1883" // tcp://iot.eclipse.org:1883 tcp://mqtt.eclipse.org:1883 #define MQTT_SUBTOPIC "/mqtt/test" #define MQTT_PUBTOPIC "/mqtt/test" #define MQTT_WILLMSG "Goodbye!" / define MQTT client context / static MQTTClient client; static int is_started = 0; static void mqtt_sub_callback(MQTTClient c, MessageData msg_data) { ((char )msg_data->message->payload + msg_data->message->payloadlen) = '�'; LOG_D("mqtt sub callback: %.s %.s", msg_data->topicName->lenstring.len, msg_data->topicName->lenstring.data, msg_data->message->payloadlen, (char )msg_data->message->payload); } static void mqtt_sub_default_callback(MQTTClient c, MessageData msg_data) { ((char )msg_data->message->payload + msg_data->message->payloadlen) = '�'; LOG_D("mqtt sub default callback: %.s %.s", msg_data->topicName->lenstring.len, msg_data->topicName->lenstring.data, msg_data->message->payloadlen, (char )msg_data->message->payload); } static void mqtt_connect_callback(MQTTClient c) { LOG_D("inter mqtt_connect_callback!"); } static void mqtt_online_callback(MQTTClient c) { LOG_D("inter mqtt_online_callback!"); } static void mqtt_offline_callback(MQTTClient c) { LOG_D("inter mqtt_offline_callback!"); } static int mqtt_start(int argc, char *argv) { / init condata param by using MQTTPacket_connectData_initializer / MQTTPacket_connectData condata = MQTTPacket_connectData_initializer; static char cid[20] = { 0 }; if (argc != 1) { rt_kprintf("mqtt_start --start a mqtt worker thread. "); return -1; } if (is_started) { LOG_E("mqtt client is already connected."); return -1; } / config MQTT context param / { client.isconnected = 0; client.uri = MQTT_URI; / generate the random client ID / rt_snprintf(cid, sizeof(cid), "rtthread%d", rt_tick_get()); / config connect param / memcpy(&client.condata, &condata, sizeof(condata)); client.condata.clientID.cstring = cid; client.condata.keepAliveInterval = 30; client.condata.cleansession = 1; / config MQTT will param. / client.condata.willFlag = 1; client.condata.will.qos = 1; client.condata.will.retained = 0; client.condata.will.topicName.cstring = MQTT_PUBTOPIC; client.condata.will.message.cstring = MQTT_WILLMSG; / malloc buffer. / client.buf_size = client.readbuf_size = 1024; client.buf = rt_calloc(1, client.buf_size); client.readbuf = rt_calloc(1, client.readbuf_size); if (!(client.buf && client.readbuf)) { LOG_E("no memory for MQTT client buffer!"); return -1; } / set event callback function / client.connect_callback = mqtt_connect_callback; client.online_callback = mqtt_online_callback; client.offline_callback = mqtt_offline_callback; / set subscribe table and event callback / client.messageHandlers[0].topicFilter = rt_strdup(MQTT_SUBTOPIC); client.messageHandlers[0].callback = mqtt_sub_callback; client.messageHandlers[0].qos = QOS1; / set default subscribe event callback / client.defaultMessageHandler = mqtt_sub_default_callback; } / run mqtt client / paho_mqtt_start(&client); is_started = 1; return 0; } static int mqtt_stop(int argc, char argv) { if (argc != 1) { rt_kprintf("mqtt_stop --stop mqtt worker thread and free mqtt client object. "); } is_started = 0; return paho_mqtt_stop(&client); } static int mqtt_publish(int argc, char argv) { if (is_started == 0) { LOG_E("mqtt client is not connected."); return -1; } if (argc == 2) { paho_mqtt_publish(&client, QOS1, MQTT_PUBTOPIC, argv[1]); } else if (argc == 3) { paho_mqtt_publish(&client, QOS1, argv[1], argv[2]); } else { rt_kprintf("mqtt_publish [message] --mqtt publish message to specified topic. "); return -1; } return 0; } static void mqtt_new_sub_callback(MQTTClient client, MessageData msg_data) { ((char )msg_data->message->payload + msg_data->message->payloadlen) = '�'; LOG_D("mqtt new subscribe callback: %.s %.s", msg_data->topicName->lenstring.len, msg_data->topicName->lenstring.data, msg_data->message->payloadlen, (char )msg_data->message->payload); } static int mqtt_subscribe(int argc, char argv) { if (argc != 2) { rt_kprintf("mqtt_subscribe [topic] --send an mqtt subscribe packet and wait for suback before returning. "); return -1; } if (is_started == 0) { LOG_E("mqtt client is not connected."); return -1; } return paho_mqtt_subscribe(&client, QOS1, argv[1], mqtt_new_sub_callback); } static int mqtt_unsubscribe(int argc, char argv) { if (argc != 2) { rt_kprintf("mqtt_unsubscribe [topic] --send an mqtt unsubscribe packet and wait for suback before returning. "); return -1; } if (is_started == 0) { LOG_E("mqtt client is not connected."); return -1; } return paho_mqtt_unsubscribe(&client, argv[1]); } #ifdef FINSH_USING_MSH MSH_CMD_EXPORT(mqtt_start, startup mqtt client); MSH_CMD_EXPORT(mqtt_stop, stop mqtt client); MSH_CMD_EXPORT(mqtt_publish, mqtt publish message to specified topic); MSH_CMD_EXPORT(mqtt_subscribe, mqtt subscribe topic); MSH_CMD_EXPORT(mqtt_unsubscribe, mqtt unsubscribe topic); #endif /* FINSH_USING_MSH */ 参考链接：https://github.com/RT-Thread-packages/paho-mqtt/blob/master/docs/samples.md 0 本主题由 Harmony技术专家于 2025-9-18 17:45 审核通过
2025-9-18 06:38:01　　评论淘帖0 邀请回答您可以邀请以下用户，快速回答问题 × wang21cj 该类别下有 7 个回答。邀请回答暖暖暖该类别下有 7 个回答。邀请回答 lwddd2100 该类别下有 6 个回答。邀请回答 qi12345 该类别下有 6 个回答。邀请回答 fdhsfagd 该类别下有 6 个回答。邀请回答 kszdj113 该类别下有 6 个回答。邀请回答 hucc 该类别下有 6 个回答。邀请回答 riverdj 该类别下有 6 个回答。邀请回答 jerry181855 该类别下有 6 个回答。邀请回答 LL-LING宁该类别下有 6 个回答。邀请回答请叫我杰西卡该类别下有 6 个回答。邀请回答成长的小师弟该类别下有 6 个回答。邀请回答宜家该类别下有 6 个回答。邀请回答 vewwerwr 该类别下有 6 个回答。邀请回答 jackhui 该类别下有 6 个回答。邀请回答 lhhgff 该类别下有 6 个回答。邀请回答 jghgfdssas 该类别下有 6 个回答。邀请回答 meihuacg 该类别下有 5 个回答。邀请回答 billbian 该类别下有 5 个回答。邀请回答学生物的程序猿该类别下有 5 个回答。邀请回答举报哈哈哈相关推荐 • 如何使用paho-mqtt框架实现温湿度数据的实时显示？ 1779 • javascript 连接华为云MQTT，获取上报数问题 1766 • paho-mqtt重连后AT发送会报错是什么原因？ 767 • 怎么使用Paho来实现和MQTT服务器的基本通信？ 8632 • 如何利用RT-Thread开发的PahoMQTT软件包与MQTT服务器进行通信？ 4583 • 新手求助MQTT选择哪个软件包比较合适呢？ 811 • c语言连接华为MQTT服务器 2328 • Web服务器启动时MQTT (SSL) 断开连接如何解决？ 814 • 为什么kawaii-mqtt sim7600 mqtt服务器会切换失败呢 1643 • MQTT单向认证服务器域名证书到期重签后，设备无法连上服务器怎么处理？ 608