Netty基础教程之服务器端创建

共计 4250 个字符，预计需要花费 11 分钟才能阅读完成。

阅读目录

一、服务器端开发时序图
二、Netty 服务器端开发步骤
三、Netty 服务器开发示例代码
四、参考资料

Netty 基础教程之服务器端创建

图片来源:Netty 权威指南 (第 2 版)

使用 Netty 进行服务器端开发主要有以下几个步骤：

ServerBootstrap b=new ServerBootstrap();

ServerBootstrap 是 Netty 服务器端的启动辅助类，提供了一系列的方法用于设置服务器端启动相关的参数。

EventLoopGroup bossGruop=new NioEventLoopGroup();// 用于服务器端接受客户端的连接 
EventLoopGroup workGroup=new NioEventLoopGroup();// 用于网络事件的处理

Netty 的线程池是 EventLoopGroup，它实际上是 EventLoop 的数组，EventLoop 职责是处理所有注册到本线程多路复用器 Selector 上的 Channel，Selector 的轮询操作是由绑定的 EventLoop 线程 run 方法驱动。

b.group(bossGruop, workGroup).channel(NioServerSocketChannel.class)

Netty 对原生的 NIO 类库进行封装，作为 NIO 服务端，需要创建 ServerSocketChannel，对应的实现是 NioServerSocketChannel。

b.group(bossGruop, workGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>()

ChannelPipeline 的本质是一个负责处理网络事件的职责链，负责管理和执行 ChannelHandler。网络事件以事件流的形式在 ChannelPipeline 中流转，由 ChannelPipeline 根据 Channel|Handler 的执行策略调度 ChannelHandler 的执行。典型的网络事件有：

链路注册
链路激活
链路断开
接收到请求信息
请求信息接收并处理完毕
发送应答消息
链路发生异常
用户自定义事件

b.group(bossGruop, workGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>()
 {
   @Override
   protected void initChannel(SocketChannel arg0) throws Exception
   {arg0.pipeline().addLast(new HelloServerHandler());
                    
   }
 }).option(ChannelOption.SO_BACKLOG, 1024);

ChannelHandler 是 Netty 提供给用户定制和扩展的接口，例如消息编解码、心跳、安全认证、TSL/SSL 认证

ChannelFuture f=b.bind(port).sync();

经过一系列初始化和检测工作后，会启动监听端口，并将 ServerSocketChannel 注册到 Selector 上监听客户端连接

由 Reactor 线程 NioEventLoop 负责调度和执行 Selector 轮询操作，选择准备就绪的 Channel 集合

public class HelloServerHandler extends ChannelHandlerAdapter

需求：服务器端实现，每连接一个客户端，在服务器控制台打印客户端输入的字符。(注：本代码使用的 netty 是 netty-all-5.0.0.Alpha1-sources.jar 版本)

服务器端代码如下：

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
//Netty 服务器端 
public class HelloServer
{private int port;
    
    public HelloServer(int port)
    {super();
        this.port = port;
    }
    private void bind() throws InterruptedException
    {EventLoopGroup bossGruop=new NioEventLoopGroup();// 用于服务器端接受客户端的连接 
        EventLoopGroup workGroup=new NioEventLoopGroup();// 用于网络事件的处理 
        try
        {ServerBootstrap b=new ServerBootstrap();
            b.group(bossGruop, workGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>()
            {
                @Override
                protected void initChannel(SocketChannel arg0) throws Exception
                {arg0.pipeline().addLast(new HelloServerHandler());
                    
                }
            }).option(ChannelOption.SO_BACKLOG, 1024);// 指定此套接口排队的最大连接个数 
            ChannelFuture f=b.bind(port).sync();
            f.channel().closeFuture().sync();}
        finally
        {bossGruop.shutdownGracefully();
            workGroup.shutdownGracefully();}
    }
    public static void main(String[] args) throws InterruptedException
    {new HelloServer(8080).bind();}
}

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;

// 自定义的 ChannelHandler
public class HelloServerHandler extends ChannelHandlerAdapter
{
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception
    {System.out.println("客户端连上了...");
    }
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
    {ByteBuf buf=(ByteBuf) msg;
        byte[] req=new byte[buf.readableBytes()];
        buf.readBytes(req);
        System.out.println("服务器端接收的消息："+new String(req));
    }
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception
    {ctx.flush();
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception
    {ctx.close();
    }
}