点对点websocket实现

zengh

2021-04-07 f3d3ab1267f35a6d4b22b7a34f5f94bb733cd513

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyServer/NettyConfig.java

@@ -1,7 +1,10 @@
package org.springblade.jfpt.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 {
@@ -9,4 +12,34 @@
    * 存储每一个客户端接入进来时的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;
   }
}