C语言MQTT发布数据报错-1（MQTTCLIENT_FAILURE）求助

我来帮你一步步排查这个错误码-1的问题，结合你用ActiveMQ broker和Paho异步发布示例的场景，咱们从几个关键方向入手：

• 核对连接参数与MQTTbox的一致性
  首先要确保代码里的连接配置和你用MQTTbox测试时完全匹配：

  • Broker地址：确认是tcp://localhost:1883（ActiveMQ默认的MQTT端口），别误写成ssl://（除非你配置了SSL加密）或者写错端口号；
  • 客户端ID：ActiveMQ默认如果有相同ID的客户端连接，会踢掉旧连接。如果你的测试代码和MQTTbox用了同一个ID，可能导致连接失败，建议给代码里的客户端ID设个唯一值（比如加上当前时间戳）；
  • 用户名密码：如果ActiveMQ开启了认证，代码里一定要在MQTTClient_connectOptions中正确设置username和password字段，和MQTTbox测试时的认证信息保持一致。

• 查看ActiveMQ日志找具体原因
  别只盯着客户端的错误码-1，直接去ActiveMQ的日志目录（一般是activemq/data/log/下的activemq.log）看看，日志里会详细记录客户端连接/发布失败的原因——比如认证失败、协议版本不兼容、主题权限不足等，这是定位问题最快的方式。

• 让Paho客户端输出更详细的错误描述
  你可以在关键调用（比如MQTTClient_connect、MQTTClient_publish）失败后，用MQTTClient_strerror函数获取具体的错误信息，而不是只看-1：

  int rc = MQTTClient_connect(client, &conn_opts);
  if (rc != MQTTCLIENT_SUCCESS) {
      printf("连接失败，错误码%d: %s\n", rc, MQTTClient_strerror(rc));
  }
  

  这样能得到更精准的提示，比如是连接超时、无法解析broker地址，还是其他底层问题。

• 排查异步发布逻辑的潜在问题
  你用的是异步发布的示例代码，要注意两个点：

  • 程序是否提前退出了？异步操作需要程序保持运行状态（比如用while循环等待回调触发，或者处理信号），如果发布还没完成程序就结束了，会直接返回失败；
  • 客户端资源是否正确初始化？先确认MQTTClient_create调用是否成功，如果客户端创建失败，后续所有操作都会返回-1。

• 用最小化代码测试复现
  把代码简化到最核心的同步发布逻辑，排除异步回调的干扰，看看是否能成功：

  #include <stdio.h>
  #include <stdlib.h>
  #include <string.h>
  #include "MQTTClient.h"
  
  #define ADDRESS     "tcp://localhost:1883"
  #define CLIENTID    "TestPubClient"
  #define TOPIC       "test/topic"
  #define PAYLOAD     "Hello from Paho C"
  #define QOS         1
  #define TIMEOUT     10000L
  
  int main(int argc, char* argv[]) {
      MQTTClient client;
      MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
      MQTTClient_message pubmsg = MQTTClient_message_initializer;
      MQTTClient_deliveryToken token;
      int rc;
  
      // 创建客户端
      if ((rc = MQTTClient_create(&client, ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL)) != MQTTCLIENT_SUCCESS) {
          printf("创建客户端失败，错误码%d: %s\n", rc, MQTTClient_strerror(rc));
          exit(EXIT_FAILURE);
      }
  
      // 配置连接参数
      conn_opts.keepAliveInterval = 20;
      conn_opts.cleansession = 1;
  
      // 连接broker
      if ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
          printf("连接失败，错误码%d: %s\n", rc, MQTTClient_strerror(rc));
          MQTTClient_destroy(&client);
          exit(EXIT_FAILURE);
      }
  
      // 配置发布消息
      pubmsg.payload = PAYLOAD;
      pubmsg.payloadlen = strlen(PAYLOAD);
      pubmsg.qos = QOS;
      pubmsg.retained = 0;
  
      // 同步发布消息
      if ((rc = MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token)) != MQTTCLIENT_SUCCESS) {
          printf("发布消息失败，错误码%d: %s\n", rc, MQTTClient_strerror(rc));
      } else {
          printf("等待消息发布完成...\n");
          rc = MQTTClient_waitForCompletion(client, token, TIMEOUT);
          printf("消息已发布，交付令牌: %d\n", token);
      }
  
      // 断开连接并销毁客户端
      MQTTClient_disconnect(client, 10000);
      MQTTClient_destroy(&client);
      return rc;
  }
  

  如果这个最小代码能成功发布，说明问题出在你原来的异步代码逻辑里；如果还是失败，就重点排查broker配置和网络连接问题。

内容的提问来源于stack exchange，提问作者Shekhar_S_20