Netty 通过Map管理用户Channel

有时候我们需要绑定用户id,让他们可以通过id与对方进行通信

通过Map实现一个简单的连接池

import io.netty.channel.socket.SocketChannel;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class GatewayService{
    private static Map map = new ConcurrentHashMap();

    public static void addGatewayChannel(String id, SocketChannel gateway_channel){
    map.put(id,gateway_channel);
    }

    public static Map getChannels(){
        return map;
    }

    public static SocketChannel getGatewayChannel(String id){
        return (SocketChannel)map.get(id);
    }

    public static void removeGatewayChannel(String id){
        map.remove(id);
    }
}

 

发表评论

电子邮件地址不会被公开。 必填项已用*标注