纯Socket(BIO)长链接编程的常见的坑和填坑套路

/**开启一个ServerSocket并等待连接，联入后开启一个线程进行处理**/
class NiuxzServer{
    ServerSocket serverSocket;
    HashMap<NiuxzSocket> sockets = new HashMap<NiuxzSocket>();
    public static AtomicInteger workerCount = 0;
    public Object waitLock = new Object();
    int maxWorkerCount = 100;//允许100个连接进入
    int port;//配置一个端口号
    
    /**工作入口**/
    void work(){
        serverSocket = new ServerSocket(port);
        while(true){
            Socket socekt = serverSocket.accept();//阻塞等待连接
            NiuxzSocket niuxzSocket = new NiuxzSocket(socket);
            sockets.put(niuxzSocket ,1);//将连接放入map中
            Worker worker = new Worker(niuxzSocket );//创建一个工作线程
            worker.start();//开始线程
            while(true){
                if(workerCount.incrementAndGet()>=maxWorkerCount){//如果超过了规定的最大线程数，就进入等待，等待其他连接销毁
                    synchronized(waitLock){
                        if(workerCount.incrementAndGet()>=maxWorkerCount){//double check 确定进入等待前没有正在断开的socket
                            waitLock.wait();
                        }else{
                            break;
                        }
                    }
                }else{
                    break;
                }
            }
        }
    }
    
    /**销毁一个连接**/
    void destroy(NiuxzSocket socket){
        synchronized(waitLock){
            sockets.remove(socket);//从池子里删除
            workerCount.decrementAndGet();//当前连接数减一
            waitLock.notify();//通知work方法 可以继续接受请求了
        }
    }
    
    /**创建一个工作者线程类，处理连入的socket**/
    class Worker extends Thread{
        HashMap<Integer,SocketHandler> handlers;//针对每种行为标识做的消息处理器。
        NiuxzSocket socket;
        Worker(NiuxzSocketsocket){//构造函数
            this.socket = socket;
        }
        void run(){
            try{
                while(true){
                    SocketPackage sp = SocketPackage.parse(socket.getIn());//阻塞读，直到读完一个消息包未知，这样可以解决粘包或半包的问题
                    SocketHandler handler = handlers.get(sp.getAction());//根据行为标识获取响应的处理器
                    handler.handle(sp,socket);//处理结果和响应信息都在handler中回写
                }
            }cache(Exception e){
                LOG.error("连接异常中断",e);
                NiuxzServer.destroy(socket);
            }
        }
    }
}

/** 创建一个消息处理器 SocketHandler 接收所有内容后 回显 **/
class EchoSocketHandler implements SocketHandler {
    /** 处理socket请求 **/
    void handle(SocketPackage sp, NiuxzSocket socket) {
        sp.setAction(10);// 比如协议中的行为标识10是响应成功的意思
        socket.write(sp.toBytes());// 直接回写
    }
}