新しいmqttメッセージが到着するまで関数をループする方法はありますか？

Question

私はPahoでC++でmqttアプリケーションを書いています。私はhereであるPaho.mqtt Cライブラリを使用しています。

コールバック関数でメッセージを受け取ったときに、別の関数を呼び出してメッセージを出力します。私は新しいメッセージが到着するまでその機能をループすることができるようにしたい。

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

上記のコードは機能しません。私は1つのメッセージを受信し、loopMessage関数でwhileループを実行できます。その後、クライアントは切断されます。私はこれがブロッキング・モードにあり、ブローカが（MQTTClientを使用している）キープ・アライブ・インターバル後にクライアントを切断するためだと思います。切断する前にすばやく新しいメッセージを送信すると、クライアントはメッセージを受信しません。

私は非同期クライアント・バージョン（MQTTAsync）を使用しようとしましたが、同じ問題が発生しています。

これを行う方法に関するご提案はありますか？

Answer 1

Pahoクライアントは、ネットワークループを処理して新しいメッセージを収集するスレッドを開始するので、loopMessage関数を削除してmessageArrivedCallbackのメッセージを出力してください。

messageArrivedCallbackでは、クライアントがメッセージを引き続き受信できるようにする必要があるため、ブロッキングコール（この無限ループが行うことです）を行うべきではありません。

新しいメッセージが到着するまでメッセージの内容を何度も印刷する場合は、別のスレッドで行う必要があります。