修改bug

Pu Zhibing

2025-08-08 73963b4d040c1addd64193ed13ebd3795ff755f1

 MessagePushTravel/src/main/java/com/sinata/push/util/echo/NettyChannelMap.java

@@ -26,7 +26,7 @@
    */
   public static ChannelHandlerContext getData(String key) {
      if(map==null){
         map = new ConcurrentHashMap<String, ChannelHandlerContext>();
         map = new HashMap<String, ChannelHandlerContext>();
      }
      return map.get(key);
   }
@@ -78,6 +78,9 @@
    */
   @SuppressWarnings("rawtypes")
   public static synchronized void remove(ChannelHandlerContext value) {
      if(null == value){
         return;
      }
      Set<String> strings = map.keySet();
      for(String key : strings){
         ChannelHandlerContext channelHandlerContext = map.get(key);
@@ -91,6 +94,23 @@
   }


   public static synchronized void remove_(ChannelHandlerContext value) {
      Set<String> strings = ctxMap.keySet();
      for(String key : strings){
         ChannelHandlerContext channelHandlerContext = ctxMap.get(key);
         String s = channelHandlerContext.channel().remoteAddress().toString();
         String s1 = value.channel().remoteAddress().toString();
         if(s.equals(s1)){
            channelHandlerContext.close();//关闭通道
            ctxMap.remove(key);
         }
      }
   }


   public static synchronized void remove_(String key) {
      ctxMap.remove(key);
   }

   
   /**
@@ -113,4 +133,9 @@
      map.put(key, value);
   }



   public static synchronized void update_(String key, ChannelHandlerContext value) {
      ctxMap.put(key, value);
   }
}