簡單的NettyDemo-服務端

public class Server {
    public static void main(String[] args) {
        //設置Server客戶端
        ServerBootstrap bootstrap = new ServerBootstrap();
        
        //設置線程池
        ExecutorService boss = Executors.newCachedThreadPool();
        ExecutorService worker = Executors.newCachedThreadPool();
        
        //設置nioSocket工廠
        bootstrap.setFactory(new NioServerSocketChannelFactory(boss, worker));
        
        //設置管道
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            //在管道里添加攔截器
            @Override
            public ChannelPipeline getPipeline() throws Exception {
                ChannelPipeline pipeline = Channels.pipeline();
                pipeline.addLast("decoder", new StringDecoder());
                pipeline.addLast("encoder", new StringEncoder());
                pipeline.addLast("helloHandler", new HelloHandler());
                return pipeline;
            }
        });
        //監聽10010端口
        bootstrap.bind(new InetSocketAddress(10010));
        
        System.out.println("服務端啟動");
        
    }
}

Hellohandler

public class HelloHandler extends SimpleChannelHandler {
    
    /**
     * 接收消息
     */
    @Override
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
        System.out.println("messageReceived" +e);
        System.out.println("客戶端發來消息:" + e.getMessage());
        //回寫數據
        Channel channel = e.getChannel();
        channel.write("hi");
        super.messageReceived(ctx, e);
        
        
    }
    /**
     * 關閉鏈接
     */
    @Override
    public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelClosed" +e);
        super.channelClosed(ctx, e);
    }
    
    /**
     * 建立連接
     */
    @Override
    public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelConnected" +e);
        super.channelConnected(ctx, e);
    }
    /**
     * 關閉連接 清除緩存
     */
    @Override
    public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelDisconnected" +e);
        super.channelDisconnected(ctx, e);
    }
    /**
     * 捕獲異常
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
        System.out.println("exceptionCaught" +e);
        super.exceptionCaught(ctx, e);
    }

    
}

結果：