最近开发时,碰到需要修改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重连之前的消息也能收到。