mymqtt 报错连接失败

发布于 2021-05-23 10:38:59 浏览：1467 订阅该版

Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...
[E/mqtt] mqtt_connect wait resp fail, res:0 errno:0
[E/mqtt] MQTT connect error(-1): UNKNOWN_ERROR.
Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...

连接部分代码如下
static void mq_start(void)
{
    /* init condata param by using MQTTPacket_connectData_initializer */
    MQTTPacket_connectData condata = MQTTPacket_connectData_initializer;

rt_memset(&client, 0, sizeof(mqtt_client));

/* config MQTT context param */
    {
        client.uri = MQTT_TEST_SERVER_URI;

/* config connect param */
        memcpy(&client.condata, &condata, sizeof(condata));
        client.condata.clientID.cstring = MQTT_CLIENTID;
        client.condata.keepAliveInterval = 60;
        client.condata.cleansession = 1;
        client.condata.username.cstring = MQTT_USERNAME;
        client.condata.password.cstring = MQTT_PASSWORD;

/* config MQTT will param. */
        client.condata.willFlag = 1;
        client.condata.will.qos = MQTT_TEST_QOS;
        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 = MQTT_PUB_SUB_BUF_SIZE;
        client.buf = rt_malloc(client.buf_size);
        client.readbuf = rt_malloc(client.readbuf_size);
        if (!(client.buf && client.readbuf))
        {
            rt_kprintf("no memory for MQTT client buffer!\n");
            goto _exit;
        }

/* 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.message_handlers[0].topicFilter = rt_strdup(MQTT_SUBTOPIC);
        client.message_handlers[0].callback = mqtt_sub_callback;
        client.message_handlers[0].qos = QOS1;

/* set default subscribe event callback */
        client.default_message_handlers = mqtt_sub_callback;
    }
    {
          int value;
          uint16_t u16Value;
          value = 5;
          paho_mqtt_control(&client, MQTT_CTRL_SET_CONN_TIMEO, &value);
          value = 5;
          paho_mqtt_control(&client, MQTT_CTRL_SET_MSG_TIMEO, &value);
          value = 5;
          paho_mqtt_control(&client, MQTT_CTRL_SET_RECONN_INTERVAL, &value);
          value = 30;
          paho_mqtt_control(&client, MQTT_CTRL_SET_KEEPALIVE_INTERVAL, &value);
          u16Value = 3;
          paho_mqtt_control(&client, MQTT_CTRL_SET_KEEPALIVE_COUNT, &u16Value);
        }

/* run mqtt client */
    paho_mqtt_start(&client, 8196, 20);

return;

连接mqtt 的时候报这个错误，  
mqtt服务器 都是正常的  偶尔能连接上一次

3 个回答

liyanlong55 2021-05-23

这家伙很懒，什么也没写！

flashman2002 2021-05-23

这家伙很懒，什么也没写！

mii 2021-05-24

这家伙很懒，什么也没写！

liyanlong55 2021-05-24

这家伙很懒，什么也没写！

Lrain 2023-06-21

这家伙很懒，什么也没写！

我用Paho软件包也是这样提示

```c
msh />mqtt_test start
[48682] D/mqtt: ipv4 address port: 1883
[48686] D/mqtt: HOST = '192.168.1.80'
Waiting for mqtt co[48698] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[48705] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
nnection...
Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...
[53714] D/mqtt: restart!
[53716] D/mqtt: ipv4 address port: 1883
[53720] D/mqtt: HOST = '192.168.1.80'
Waiting for mqtt co[53732] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[53739] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
nnection...
Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...
Waiting for mqtt connection...
[58748] D/mqtt: restart!
[58750] D/mqtt: ipv4 address port: 1883
[58754] D/mqtt: HOST = '192.168.1.80'
Waiting for mqtt co[58766] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[58773] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
nnection...
Waiting for mqtt connection...
Waiting for mqtt connection...

```