Netty服务端和客户端开发实例

一、Netty服务端开发

在开始使用 Netty 开发 TimeServer 之前，先回顾一下使用 NIO 进行服务端开发的步骤。

(1)创建ServerSocketChannel，配置它为非阻塞模式;

(2)绑定监听，配置TCP 参数，例如 backlog 大小;

(3)创建一个独立的I/O线程，用于轮询多路复用器 Selector;

(4)创建 Selector，将之前创建的 ServerSocketChannel 注册到 Selector 上，监听SelectionKey.ACCEPT;

(5)启动I/0线程，在循环体中执行 Selectorselect0)方法，轮询就绪的 Channel;

(6)当轮询到了处于就绪状态的 Channel 时，需要对其进行判断，如果是OP ACCEPT状态，说明是新的客户端接入，则调用 ServerSocketChannel.accept()方法接受新的客户端:(7)设置新接入的客户端链路 SocketChannel 为非阻塞模式,配置其他的一些TCP 参数(8)将SocketChannel注册到 Selector，监听 OP READ 操作位;

(9)如果轮询的Channel为OP READ，则说明 SocketChannel 中有新的就绪的数据包需要读取，则构造ByteBuffer 对象，读取数据包;

(10)如果轮询的Channel为OP WRITE，说明还有数据没有发送完成，需要继续发送。

import io.netty.bootstrap.ServerBootstrap;import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.netty.buffer.CompositeByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.timeout.IdleStateHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;public class nettyServer {Logger logger = LoggerFactory.getLogger(nettyServer.class);@Value("${netty.port}")int port;@PostConstructpublic void bind() {EventLoopGroup bossrGroup = new NioEventLoopGroup();//接收客户端传过来的请求EventLoopGroup wokerGroup = new NioEventLoopGroup();//接收到请求后将后续操作try {ServerBootstrap b = new ServerBootstrap();b.group(bossrGroup, wokerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 1024)//.childOption(ChannelOption.SO_KEEPALIVE, true).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(new serverHandlerAdapter());ch.pipeline().addLast(new StringDecoder());ch.pipeline().addLast(new HeartbeatHandler());ch.pipeline().addLast(new IdleStateHandler(10, 1, 1));}});ChannelFuture f = b.bind(port).sync();} catch (Exception e) {}}

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;public class serverHandlerAdapter extends ChannelInboundHandlerAdapter {@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {super.channelActive(ctx);}@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {super.channelRead(ctx, msg);}@Overridepublic void channelReadComplete(ChannelHandlerContext ctx) throws Exception {super.channelReadComplete(ctx);}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {super.exceptionCaught(ctx, cause);}

二、Netty客户端开发

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;public class nettyClient {clientHandlerAdapter clientHandlerAdapter = new clientHandlerAdapter();public void conect(String ip, int port) {EventLoopGroup group = new NioEventLoopGroup();try {Bootstrap b = new Bootstrap();b.group(group).channel(NioSocketChannel.class).remoteAddress("", port).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(clientHandlerAdapter);}});b.bind(ip, port).sync();} catch (Exception e) {}}public boolean sendFile() {return clientHandlerAdapter.sendFile();}}

我们从 connect 方法讲起，在第 13 行首先创建客户端处理 I/0 读写的 NioEventLoopGroup 线程组，然后继续创建客户端辅助启动类 Bootstrap，随后需要对其进行配置。与服务端不同的是，它的 Channel 需要设置为 NioSocketChannel，然后为其添加 handler，此处为了简单直接创建匿名内部类，实现 initChannel 方法，其作用是当创建 NioSocketChannel成功之后，在初始化它的时候将它的 ChannelHandler 设置到 ChannelPipeline 中，用于处理网络I/O事件。

客户端启动辅助类设置完成之后，调用 connect 方法发起异步连接，然后调用同步方法等待连接成功。

最后，当客户端连接关闭之后，客户端主函数退出，在退出之前，释放 NIO 线程组的资源。

下面我们继续看下TimeClientHandler 的代码如何实现