保安员新增同步编号问题

Administrator

2022-06-16 2ebca060a47784db76369a4aa84f63293da9be33

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

@@ -1,45 +1,45 @@
package org.springblade.modules.nettyServer;
import io.netty.channel.Channel;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.util.concurrent.GlobalEventExecutor;

import java.util.concurrent.ConcurrentHashMap;


public class NettyConfig {
   /**
    * 存储每一个客户端接入进来时的channel对象
    */
   public static ChannelGroup group = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

   /**
    * 定义一个channel组，管理所有channel
    * GlobalEventExecutor.INSTANCE 是全局的事件执行器，是一个单例
    */
   private static ChannelGroup channelGroup = new DefaultChannelGroup("用户管理组", GlobalEventExecutor.INSTANCE);

   /**
    * 存放用户与chanel 的对应的信息，用于给指定用户发送信息
    */
   private static ConcurrentHashMap<String, Channel> userChannelMap = new ConcurrentHashMap<>();

   public NettyConfig() {
   }

   /**
    * 获取用户channel 组
    * @return
    */
   public static ChannelGroup getChannelGroup() {
      return channelGroup;
   }

   /**
    * 获取用户channel map
    * @return
    */
   public static ConcurrentHashMap<String, Channel> getUserChannelMap() {
      return userChannelMap;
   }
}
//package org.springblade.modules.nettyServer;
//import io.netty.channel.Channel;
//import io.netty.channel.group.ChannelGroup;
//import io.netty.channel.group.DefaultChannelGroup;
//import io.netty.util.concurrent.GlobalEventExecutor;
//
//import java.util.concurrent.ConcurrentHashMap;
//
//
//public class NettyConfig {
//   /**
//    * 存储每一个客户端接入进来时的channel对象
//    */
//   public static ChannelGroup group = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
//
//   /**
//    * 定义一个channel组，管理所有channel
//    * GlobalEventExecutor.INSTANCE 是全局的事件执行器，是一个单例
//    */
//   private static ChannelGroup channelGroup = new DefaultChannelGroup("用户管理组", GlobalEventExecutor.INSTANCE);
//
//   /**
//    * 存放用户与chanel 的对应的信息，用于给指定用户发送信息
//    */
//   private static ConcurrentHashMap<String, Channel> userChannelMap = new ConcurrentHashMap<>();
//
//   public NettyConfig() {
//   }
//
//   /**
//    * 获取用户channel 组
//    * @return
//    */
//   public static ChannelGroup getChannelGroup() {
//      return channelGroup;
//   }
//
//   /**
//    * 获取用户channel map
//    * @return
//    */
//   public static ConcurrentHashMap<String, Channel> getUserChannelMap() {
//      return userChannelMap;
//   }
//}