保安员新增同步编号问题

Administrator

2022-06-16 2ebca060a47784db76369a4aa84f63293da9be33

 src/main/java/org/springblade/modules/nettyServer/ChannelMap.java

@@ -1,36 +1,36 @@
package org.springblade.modules.nettyServer;

import io.netty.channel.Channel;

import java.util.concurrent.ConcurrentHashMap;

public class ChannelMap {
   public static int channelNum=0;
   private static ConcurrentHashMap<String, Channel> channelHashMap=null;//concurrentHashmap以解决多线程冲突

   public static ConcurrentHashMap<String, Channel> getChannelHashMap() {
      return channelHashMap;
   }

   public static Channel getChannelByName(String name){
      if(channelHashMap==null||channelHashMap.isEmpty()){
         return null;
      }
      return channelHashMap.get(name);
   }
   public static void addChannel(String name, Channel channel){
      if(channelHashMap==null){
         channelHashMap=new ConcurrentHashMap<String, Channel>(10);
      }
      channelHashMap.put(name,channel);
      channelNum++;
   }
   public static int removeChannelByName(String name){
      if(channelHashMap.containsKey(name)){
         channelHashMap.remove(name);
         return 0;
      }else{
         return 1;
      }
   }
}
//package org.springblade.modules.nettyServer;
//
//import io.netty.channel.Channel;
//
//import java.util.concurrent.ConcurrentHashMap;
//
//public class ChannelMap {
//   public static int channelNum=0;
//   private static ConcurrentHashMap<String, Channel> channelHashMap=null;//concurrentHashmap以解决多线程冲突
//
//   public static ConcurrentHashMap<String, Channel> getChannelHashMap() {
//      return channelHashMap;
//   }
//
//   public static Channel getChannelByName(String name){
//      if(channelHashMap==null||channelHashMap.isEmpty()){
//         return null;
//      }
//      return channelHashMap.get(name);
//   }
//   public static void addChannel(String name, Channel channel){
//      if(channelHashMap==null){
//         channelHashMap=new ConcurrentHashMap<String, Channel>(10);
//      }
//      channelHashMap.put(name,channel);
//      channelNum++;
//   }
//   public static int removeChannelByName(String name){
//      if(channelHashMap.containsKey(name)){
//         channelHashMap.remove(name);
//         return 0;
//      }else{
//         return 1;
//      }
//   }
//}