MQTT应用程序使用单个客户端应用程序/库与两个代理连接

Question

我正在使用MQTT Eclipse Paho Java库（JAR）连接到MQTT代理。

但我想使用相同的库连接两个代理。我已经实现了与两个代理连接的代码，它确实连接了，但问题在于某些时候连接随机断开连接（任一连接）。

那么使用一个MQTT客户端库连接两个MQTT代理的最佳方式是什么？

更新

我的连接代码看起来如下：

import org.eclipse.paho.client.mqttv3.MqttClient; 
Class com.test.A 
{ 
    MqttClient mMqttClient; 
    A() 
    { 
     mMqttClient = new MqttClient("broker_url_1", "Client1", persistence); 

     // Create MQTT connection options 
     MqttConnectOptions connOpts = new MqttConnectOptions(); 
     connOpts.setCleanSession(true); // Create new clear session 

     mMqttClient.connect(connOpts); 
    } 
} 

import org.eclipse.paho.client.mqttv3.MqttClient; 
Class com.test.B 
{ 
    MqttClient mMqttClient; 
    B() 
    { 
     mMqttClient = new MqttClient("broker_url_2", "Client2", persistence); 

     // Create MQTT connection options 
     MqttConnectOptions connOpts = new MqttConnectOptions(); 
     connOpts.setCleanSession(true); // Create new clear session 

     mMqttClient.connect(connOpts); 
    }  
} 

错误，我连接大量后得到connectionLost: cause: Connection lost

Answer 1

要解决失去连接尝试启用自动重新连接功能：

MqttConnectOptions connOpts = new MqttConnectOptions(); 
connOpts.setCleanSession(true); // Create new clear session 
connOpts.setAutomaticReconnect(true); // add this line 

要获得详细的错误信息创建jsr47min.properties文件：

mMqttClient = new MqttClient("broker_url_1", "Client1", persistence); 
Debug debug = mMqttClient.getDebug(); 
debug.dumpClientDebug(); // call at different points in your code?