[C++][ubuntu][原创]Mqtt通信在订阅信息收到的函数里面不能发送发布消息解决方法

Posted 2023-02-05 FL1623863129

关于Mqtt一篇文章写的非常好：

Paho -物联网 MQTT C Cient的实现和详解_宁静致远2021的博客-CSDN博客_mqttclient_create

下面我的问题是：

int msgarrvd(void *context, char *topicName, int topicLen, MQTTClient_message *message)

    int i;
    char* payloadptr;
 
    printf("Message arrived\\n");
    printf("     topic: %s\\n", topicName);
    printf("   message: ");
 
    payloadptr = message->payload;
    if(strcmp(payloadptr, DISCONNECT) == 0)
        printf(" \\n out!!");
        CONNECT = 0;
   
    
    for(i=0; i<message->payloadlen; i++)
   
        putchar(*payloadptr++);
   
    printf("\\n");
    //我想在这发布一个主题

  //send message code,这里我省略
    MQTTClient_freeMessage(&message);
    MQTTClient_free(topicName);
    return 1;

我想在收到消息后在发布一个消息，看上面的注释地方，但是调用这个发布主题就导致没法接收和发送主题了。经过测试发现，关键代码

    MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token);
    printf("Waiting for up to %d seconds for publication of %s\\n"
            "on topic %s for client with ClientID: %s\\n",
            (int)(TIMEOUT/1000), PAYLOAD, TOPIC, CLIENTID);
    rc = MQTTClient_waitForCompletion(client, token, TIMEOUT);
 

只要把MQTTClient_waitForCompletion这个函数注释掉后，在接受到消息后发布消息就不存在问题，而且双方都可以接收到消息。