package org.springblade.modules.webscoket;
|
import io.netty.channel.Channel;
|
import io.netty.channel.ChannelId;
|
import io.netty.channel.group.ChannelGroup;
|
import io.netty.channel.group.DefaultChannelGroup;
|
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();
|
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);
|
}
|
|
}
|
