返回过后清除查询session，否则会不能查询

sxz-core/src/main/java/com/fdkk/sxz/other/mq/TopicRabbitConfig.java

@@ -23,25 +23,25 @@ public class TopicRabbitConfig {
 //
 //    public final static String TOPICE = "topicExchangeCopy";
 
-    public final static String CHANGE = "topic.chang";
+    public final static String CHANGE = "topic.chang.dev";
     //灯光预览
-    public final static String LIGHT = "topic.light";
+    public final static String LIGHT = "topic.light.dev";
 
-    public final static String MODEL = "topic.model";
+    public final static String MODEL = "topic.model.dev";
 
-    public final static String MODEL_BIZ = "topic.modelBiz";
+    public final static String MODEL_BIZ = "topic.modelBiz.dev";
 
     //"更新模型库，syncmodel
-    public final static String SYNCMODEL = "topic.syncmodel";
+    public final static String SYNCMODEL = "topic.syncmodel.dev";
 
     //处理
-    public final static String MVIEW = "delay.mview";
+    public final static String MVIEW = "delay.mview.dev";
 
-    public final static String TOPICE = "topicExchange";
+    public final static String TOPICE = "topicExchange.dev";
     /**
      * 延迟消息交换机
      */
-    public final static String DELAY_EXCHANGE = "delay.exchange";
+    public final static String DELAY_EXCHANGE = "delay.exchange.dev";
 
     @Bean
     public CustomExchange delayMessageExchange() {

sxz-core/src/main/java/com/fdkk/sxz/webApi/socket/actionSocket.java

@@ -68,9 +68,7 @@ public class actionSocket {
         actionSocket.log.info("new connection, sessionId-{},Host-{}", session.id(), headers.get("Host"));
     }
 
-    @OnClose
-    public void onClose(Session session) throws IOException, InterruptedException {
-        actionSocket.log.info("one connection closed");
+    public void handleSessionMap(Session session) {
         actionSocket.socketSessionBizMap.keySet().stream().forEach(
                 key -> {
                     if (key.contains(session.id().toString())) {
@@ -82,18 +80,17 @@ public class actionSocket {
         );
     }
 
+
+    @OnClose
+    public void onClose(Session session) throws IOException, InterruptedException {
+        actionSocket.log.info("one connection closed");
+        handleSessionMap(session);
+    }
+
     @OnError
     public void onError(Session session, Throwable throwable) throws InterruptedException {
         throwable.printStackTrace();
-        actionSocket.socketSessionBizMap.keySet().stream().forEach(
-                key -> {
-                    if (key.contains(session.id().toString())) {
-                        actionSocket.socketSessionBizMap.get(key).interrupt();
-                        actionSocket.socketSessionBizMap.remove(key);
-                    }
-                }
-
-        );
+        handleSessionMap(session);
     }
 
     @OnMessage
@@ -166,6 +163,8 @@ public class actionSocket {
         String msg = paramContext.get("msg");
         Session session = paramContext1.get("session");
         session.sendText(msg.toString());
+        //返回过后清除查询session，否则会不能查询
+        handleSessionMap(session);
 
     }