使用paho的MQTT时遇到的重连导致订阅无法收到问题和解决

MqttClient client = new MqttClient(HOST, clientid, new MemoryPersistence());MqttConnectOptions options = new MqttConnectOptions();options.setCleanSession(true);options.setUserName(userName);options.setPassword(passWord.toCharArray());options.setConnectionTimeout(10);options.setKeepAliveInterval(20);//设置断开后重新连接		options.setAutomaticReconnect(true);try {               client.setCallback(new PushCallback());//设置各种情况的回调函数               client.connect(options);                        //订阅消息               int[] Qos  = {0};   		String[] topic1 = {TOPIC};   		client.subscribe(topic1, Qos);        } catch (Exception e) {               e.printStackTrace();        }    

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;import org.eclipse.paho.client.mqttv3.MqttCallback;import org.eclipse.paho.client.mqttv3.MqttMessage;import org.eclipse.paho.client.mqttv3.MqttTopic;public class PushCallback implements MqttCallback {	public void connectionLost(Throwable cause) {		// 连接丢失后，触发这个方法	}	@Override	public void deliveryComplete(IMqttDeliveryToken token) {		// publish后会执行到这里					}	@Override	public void messageArrived(String arg0, MqttMessage arg1) throws Exception {		System.out.println("接收消息主题:"+arg0);		System.out.println("接收消息Qos:"+arg1.getQos());		System.out.println("接收消息内容:"+new String(arg1.getPayload()));			}}

@Overridepublic void connectComplete(boolean reconnect, String serverURI) {		//连接成功后调用

　　　　　　client.subscribe(topics,Qos);//具体订阅代码

}