如何循环一个函数，直到新的mqtt消息到达？

Question

我正在用Paho在C++中编写一个mqtt应用程序。我正在使用Paho.mqtt C库，可以找到here。

当我在回调函数中收到消息时，它会调用另一个函数来打印消息。我希望能够循环该功能，直到有新消息到达。

bool start = false; 
void loopMessage(std::string message){ 
    start = true; 
    while(start){ 
     std::out << "message: " << message; 
    } 
} 
int messageArrivedCallback(mqtt message){ 
    start = false; 
    loopMessage(message); 
} 

上面的代码不工作;我可以收到一条消息并在loopMessage函数中运行while循环。之后，客户端断开连接。我认为这是因为它处于阻塞模式，并且代理在保持活动时间间隔（我正在使用MQTTClient）后断开客户端连接。如果我在断开连接之前快速发送新消息，则客户端不会收到它。

我试图使用asynchronus客户端版本（MQTTAsync），但它给我同样的问题。

有关如何做到这一点的任何建议？

Answer 1

泛美卫生组织的客户端将启动一个线程来处理网络环路，并收集新的消息，以便只是删除loopMessage功能和打印邮件中的messageArrivedCallback。

您不应该在messageArrivedCallback中进行阻塞呼叫（这是无限循环所做的），因为它必须返回以允许客户端继续接收消息。

如果您想要反复印刷邮件内容，直到收到新消息，则需要在单独的线程上完成。