public class Server {  //定义一个循环接收客户端的Socket连接请求。初始化一个线程池对象  private static ExecutorService poolHandler = new ThreadPoolExecutor(5, 5,                120, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10));    public static void main(String[] args) {        try {            // 注册端口            ServerSocket ss = new ServerSocket(9999);            while (true) {                Socket socket = ss.accept();                // 把Socket封装成一个任务对象交给线程池处理                Runnable target = new ServerRunnable(socket);                poolHandler.execute(target);            }        } catch (IOException e) {            e.printStackTrace();        }    }
    public static class ServerRunnable implements Runnable {      private Socket socket;      public ServerRunnable(Socket socket) {          this.socket = socket;      }      @Override      public void run() {          // 处理接收的客户端Socket通信需求          try {              InputStream is = socket.getInputStream();              BufferedReader br = new BufferedReader(new InputStreamReader(is));              String msg;              while ((msg = br.readLine()) != null) {
                //处理数据的粘包拆包                //对完整的数据包进行解码操作                //得到客户端消息                //触发各种统计类事件如心跳检测 信息统计                 //处理客户端的消息                //得到响应消息                //对响应消息进行编码              }          } catch (IOException e) {              e.printStackTrace();            //处理网络断开事件            //处理其他异常事件          }      }  }}

public class Server {    public static void main(String[] args) throws IOException {        //获取ServerSocketChannel        ServerSocketChannel ssChannel = ServerSocketChannel.open();        //设置非阻塞模式        ssChannel.configureBlocking(false);        //绑定端口        ssChannel.bind(new InetSocketAddress(9999));        //获取选择器        Selector selector = Selector.open();        //将ServerSocketChannel注册到选择器上，并且监听建立连接事件        ssChannel.register(selector, SelectionKey.OP_ACCEPT);        // 使用Selector选择器轮询已经就绪好的事件        while (selector.select() > 0) {            // 获取选择器就绪事件            Iterator<SelectionKey> it = selector.selectedKeys().iterator();            //遍历事件            while (it.hasNext()) {                SelectionKey sk = it.next();                //判断事件类型                if (sk.isAcceptable()) {                    // 获取客户端channel                    SocketChannel channel = ssChannel.accept();                    //切换非阻塞模式                    channel.configureBlocking(false);                    //将该channel注册到选择器上                    channel.register(selector, SelectionKey.OP_READ);                } else if (sk.isReadable()) {                    //获取channel                    SocketChannel sChannel = (SocketChannel) sk.channel();                    //读取网络数据                    ByteBuffer buf = ByteBuffer.allocate(1024);                    int len = 0;                    while ((len = sChannel.read(buf)) > 0) {                        //处理数据的粘包拆包                        //对完整的数据包进行解码操作                        //得到客户端消息                        //触发各种统计类事件如心跳检测 信息统计                     }                }else if(sk.isWritable()){                        //得到响应消息                        //对响应消息进行编码                }                // 15.取消选择键SelectionKey                it.remove();            }        }    }}

public class NettyServer {    public static void main(String[] args) throws Exception{        //设置接受网络连接线程池        NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);        //设置处理网络除连接外所有事件线程的线程池        NioEventLoopGroup workerGroup = new NioEventLoopGroup();        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(bossGroup,workerGroup)                .channel(NioServerSocketChannel.class)//设置Channel类型                .option(ChannelOption.SO_BACKLOG,1024)                .handler(new ChannelInitializer<ServerSocketChannel>() {                    @Override                    protected void initChannel(ServerSocketChannel ch) throws Exception {                      //设置处理网络连接的Handler                        ch.pipeline().addLast("serverBindHandler",                         new NettyBindHandler(NettyTcpServer.this,serverStreamLifecycleListeners));                    }                })                .childHandler(new ChannelInitializer<NioSocketChannel>() {                    @Override                    protected void initChannel(NioSocketChannel ch) throws Exception {                        ch.pipeline()                                .addLast("protocolHandler", new NettyProtocolHandler())//设置编解码器                                .addLast("serverIdleHandler",                                        new IdleStateHandler(0, 0, serverIdleTimeInSeconds))//设置心跳检测                                .addLast("serverHandler",new NettyServerStreamHandler(NettyTcpServer.this, false,                                        serverStreamLifecycleListeners,                                          serverStreamMessageListeners));//设置业务处理逻辑                    }                });
        ChannelFuture channelFuture = serverBootstrap.bind(9000).sync();        channelFuture.channel().closeFuture().sync();    }}