邵洋 1 жил өмнө
parent
commit
079c21000b

+ 0 - 1
pole-service/src/main/java/com/zksy/pole/MQTTServer/handler/MQTTMessageHandler.java

@@ -66,7 +66,6 @@ public class MQTTMessageHandler extends ChannelInboundHandlerAdapter {
                 case PUBLISH:		//	客户端发布消息
                     //	PUBACK报文是对QoS 1等级的PUBLISH报文的响应
                     BootNettyMqttMsgBack.puback(channel, mqttMessage);
-                    MQTTServer.subscribeMap.clear();
                     break;
                 // PUBREL	Qos2级别消息,客户端返回
                 case PUBREL: