C++関数の中でMQTTクライアント・ポインターを使用

Question

私はPaho C++ MQTTライブラリーを使用してブローカーに接続しています。

私はすでに接続するために管理さ

connect(); 
sendMessage(data); 
disconnect(); 

、メッセージや切断を送信するだけであるためMQTTクライアントのスコープの同じ関数内：

void sendMessage(){ 
    // Connect 
    mqtt::itoken_ptr conntok = client.connect(); 
    conntok->wait_for_completion(); 

    // Sending message 
    pubtok = client.publish(topic, char_json, data, qos, false); 
    pubtok->wait_for_completion(timeout); 

    // Disconnect 
    conntok = client.disconnect(); 
    conntok->wait_for_completion(); 
} 

私は私のコードは次のように整理することにしたいです私は（私はいくつかのデータを送信するたびに切断/再接続を避けるために）3つの別々の関数内のコードのそれらの作品を持っていると思いますが

私はMQTTを使用する必要があることを推測:: itoken_ptrはclient.connect（）から返されをconntokが、このオブジェクトはget_client（）機能を持っていない、唯一のMQTT：トークンはありません。

ドキュメントでは、async_clientクラスのポインタがあることを示していますstd :: shared_ptr ptr_tしかし、私はC++をかなり新しく使っているので、どのように使用するのかは分かりません。実際のクライアントオブジェクトはprivate（C++ラッパーの下）です。

さまざまな機能で同じクライアントオブジェクトを使用すると、次のようなことができますか？

connect(){ 
    mqtt::itoken_ptr conntok = client.connect(); 
} 
sendMessage(){ 
    pubtok = client.publish(topic, char_json, data, qos, false); 
    pubtok->wait_for_completion(timeout); 
} 
disconnect(){ 
    conntok = client.disconnect(); 
    conntok->wait_for_completion(); 
} 

Answer 1

これをテストしていませんが、なぜできないあなたの擬似コードで：ここで

void disconnect(mqtt::iasync_client &client); 
void connect(mqtt::iasync_client &client); 
void sendMessage(mqtt::iasync_client &client); 

controller() 
{ 
    mqtt::async_client client(ADDRESS, CLIENTID); 
    connect(client); 
    sendMessage(client); 
    disconnect(client); 
} 

connect(&client){ 
    callback cb; 
    client.set_callback(cb); // necessary to avoid segmentation fault 
    token = client.connect(); 
    token->wait_for_completion(timeout); 
} 

sendMessage(&client){ 
    callback cb; 
    client.set_callback(cb); // necessary to avoid segmentation fault 
    pubtok = client.publish(topic, char_json, data, qos, false); 
    pubtok->wait_for_completion(timeout); 
} 

disconnect(&client){ 
    callback cb; 
    client.set_callback(cb); 
    conntok = client.disconnect(); 
    conntok->wait_for_completion(); 
}