最近开发时,碰到需要修改mqttClient客户端的订阅主题。实际测试时发现一个问题,修改订阅了新的主题,重连后,之前订阅的主题还是存在,还能继续收到之前订阅主题的消息。
解决办法,配置 mOptions.setCleanSession(true); ,清空session,如果配置设置为false,表示服务器会保留客户端的连接记录,这里设置为true表示每次连接到服务器都以新的身份连接。
private MqttClient mMqttClient;private MqttConnectOptions mOptions;//host为主机名,test为clientid即连接MQTT的客户端ID,一般以客户端唯一标识符表示,MemoryPersistence设置clientid的保存形式,默认为以内存保存mMqttClient = new MqttClient(mHost, mqttClientId, new MemoryPersistence());// MQTT的连接配置mOptions = new MqttConnectOptions();// 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录,这里设置为true表示每次连接到服务器都以新的身份连接mOptions.setCleanSession(true);// 设置连接的用户名mOptions.setUserName(mUserName);// 设置连接的密码mOptions.setPassword(mPassWord.toCharArray());// 设置连接超时的时间,单位为秒mOptions.setConnectionTimeout(10);// 设置会话心跳时间,单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线,但这个方法并没有重连的机制mOptions.setKeepAliveInterval(20);// 设置回调mMqttClient.setCallback(new MqttConnectCallBack());
如果你的客户端不需要在使用过程中修改新的订阅主题,那么可以配置为true。这样在QoS 等级大于0时,client重连之前的消息也能收到。