简单的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);
    }

    
}

结果：