版本合并

zengh

2021-06-01 cd2cfd37366002f790a2ed1435962d4eff7d5cec

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/webscoket/ChannelSupervise.java

@@ -6,22 +6,30 @@
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.util.concurrent.GlobalEventExecutor;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
public class ChannelSupervise {
   private   static ChannelGroup GlobalGroup=new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
   private  static ConcurrentMap<String, ChannelId> ChannelMap=new ConcurrentHashMap();
   public  static void addChannel(Channel channel){
   private  static Map<String, String> map = new HashMap<String, String>();;
   public  static void addChannel(Channel channel,String name){
      GlobalGroup.add(channel);
      ChannelMap.put(channel.id().asShortText(),channel.id());
      map.put(channel.id().asShortText(),name);
   }
   public static void removeChannel(Channel channel){
      GlobalGroup.remove(channel);
      ChannelMap.remove(channel.id().asShortText());
      map.remove(channel.id().asShortText());
   }
   public static  Channel findChannel(String id){
      return GlobalGroup.find(ChannelMap.get(id));
   }
   public static String findName(String id){
   return map.get(id);
   }
   public static void send2All(TextWebSocketFrame tws){
      GlobalGroup.writeAndFlush(tws);
   }