上一遍大致讲了Netty的基础：JAVA NIO，和最早的BIO
这一回开始着手聊一下Netty的特性及实现流程
Netty 是一款异步的事件驱动的网络应用程序框架，支持快速地开发可维护的高性能的面向协议的服务器
和客户端。
Netty的特性
以下内容摘自《Netty 实战》
| 分类 | Netty 的特性 |
|---|---|
| 设计 | 统一的 API，支持多种传输类型，阻塞的和非阻塞的；简单而强大的线程模型；真正的无连接数据报套接字支持；链接逻辑组件以支持复用 |
| 易于使用 | - |
| 性能 | 拥有比 Java 的核心 API 更高的吞吐量以及更低的延迟；得益于池化和复用，拥有更低的资源消耗；最少的内存复制 |
| 健壮性 | 不会因为慢速、快速或者超载的连接而导致 OutOfMemoryError；消除在高速网络中 NIO 应用程序常见的不公平读/写比率 |
| 安全性 | 完整的 SSL/TLS 以及 StartTLS 支持；可用于受限环境下，如 Applet 和 OSGI |
Netty服务端实现流程
实现自定义的handler
每个服务都会有自己内部的处理逻辑，Netty内置了handler处理I/O事件。
我们先尝试实现一个handler，逻辑是接受入站数据并返回
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.ChannelHandler.Sharable;
import io.netty.util.CharsetUtil;
public class HttpChannelInboundHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
ByteBuf in = (ByteBuf) msg;
System.out.println("Server received:" + in.toString(CharsetUtil.UTF_8));
// 将消息写入缓冲区，并调用flush强行输出到远端节点
ctx.writeAndFlush(in);
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
// 出现异常则关闭连接
cause.printStackTrace();
ctx.channel().close();
}
}
可以看到，我们的处理器HttpChannelInboundHandler继承了ChannelInboundHandlerAdapter，而ChannelInboundHandlerAdapter是Netty 提供的ChannelInboundHandler的实现类之一。所以我们可以通过覆盖它们的方法来实现自己的业务逻辑处理。关于Handler这块具体的内容我们后面再细讲
channelRead
客户端发送数据包过来时，在收到该数据包时，该方法会被调用。当前我们定义的接收数据类型为ByteBuf
ChannelHandlerContext对象提供了许多操作。我们这里是将接收到的数据写入到缓冲区，再调用flush()将其冲刷到通道
exceptionCaught
当服务出现异常时，会调用该方法。通常我们会在这里记录异常信息，并关闭对应的通道。
启动服务
public void start(int port) {
EventLoopGroup boss = new NioEventLoopGroup();
EventLoopGroup worker = new NioEventLoopGroup();
try {
ServerBootstrap bootstrap = new ServerBootstrap();// 1.
bootstrap.group(boss, worker) // 2.
.channel(NioServerSocketChannel.class) // 3.
.childHandler(new ChannelInitializer<SocketChannel>() {// 4.
@Override
protected void initChannel(SocketChannel channel) {// 5.
new HttpChannelInboundHandler(); //
}
})
.option(ChannelOption.SO_BACKLOG, 1024) // 6.
.childOption(ChannelOption.SO_KEEPALIVE, true);// 7
ChannelFuture future = bootstrap.bind(port).sync();// 8.
// future.channel().closeFuture(); // 9.
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
boss.shutdownGracefully();
worker.shutdownGracefully();
}
}
ServerBootstrap
启动引导类，Netty 需要实例化一个ServerBootstrap来启动服务并配置相关参数
group()
分配组，服务端的启动服务需要两个组协同工作来<font color=#35b998>处理IO</font>，一个boss组用于accept（接受）连接，一个worker组用于handle（处理）连接
channel()
这里我们使用NioServerSocketChannel的实例化对象来设置ServerBootstrap实例
childHandler()
添加处理器
initChannel()
对channel进行初始化配置，而这里我们没有自定义ChannelInitializer的实现类来添加具体的配置项到channel的pipeline上。因为我仅添加了一个处理器，没有太复杂的逻辑。这个处理器用于处理channel上的事件
option()
指定要应用到新创建的 ServerChannel 的 ChannelConfig 的 ChannelOption。这些选项将会通过 bind()方法设置到 Channel。在 bind()方法被调用之后，设置或者改变 ChannelOption 都不会有任何的效果
SO_BAKCLOG:设置排队的连接数。
childOption()
指定当子 Channel 被接受时，应用到子 Channel 的 ChannelConfig 的ChannelOption。所支持的 ChannelOption 取决于所使用的 Channel 的类型。
bind()
绑定端口并返回一个ChannelFuture，将在绑定完成后收到回调通知
closeFuture()
优雅地关停服务，按需用。
下一篇会开始分析Netty的核心API
网友评论