这篇文章我们正式开始学习 Netty，在入门之前我们还是需要了解什么是 Netty。
什么是 Netty
为什么很多人都推崇 Java boy 去研究 Netty？Netty 这么高大上，它到底是何方神圣？
用官方的话说：Netty 是一款异步的、基于事件驱动的网络应用程序框架，用以快速开发高性能、高可靠性的网络 IO 程序。
为什么要使用 Netty 呢？因为使用原生的 Java NIO 非常不爽，它存在一系列的问题，比如：
- 使用 Java NIO 需要了解很多概念，而且 API 非常繁琐。
- 使用 Java NIO 编程复杂，一不小心就会 Bug 横飞。
- 开发工作量和难度也很大，例如我们要处理断开重连、网络闪断、半包读写、网络拥塞、异常处理，等等异常情况，处理起来难度比较大。需要非常熟悉 Java 多线程和网络相关知识点，才能编写一个高质量的 Java NIO 程序。
- JDK NIO 的 Bug：例如臭名昭著的 Epoll Bug，它会导致 Selector 空轮询，最终导致 CPU 100%。
使用 Netty，都解决了上面的问题，它具备如下几个优点：
- 容易上手：Netty 是 Java NIO 进行了封装，API 使用简单，开发门槛相对较低。
- 功能强大：预置多种编解码功能，支持多种主流协议，底层 IO 模型随意切换等等。
- 高性能：精心设计的 Reactor 线程模型支持高并发，优秀的内存模型，减少了资源的消耗。
- 设计优雅：灵活且可扩展的事件模型，可以清晰地分离关注点；高度可定制化的线程模型；粘包/粘包、异常检测等机制将我们从繁重的细节中解脱，只需关注业务逻辑。
- 社区活跃：Netty 是目前最为活跃的开源项目之一，版本迭代周期短，bug 修复速度快。
- 安全：完整的 SSL/TLS 和 StartTLS 支持。
- 质量有保障：经过大规模的商业应用考验，质量得到了充分的验证，健壮性无比强大，放心使用吧。
Hello World
接下来我们用 Netty 来实现我们的第一个应用程序：Hello World。该 Hello World 程序大明哥做到尽可能简单，理解不了没有关系，能跑起来就行，毕竟是第一个 demo。
注：大明哥写这篇文章时， Netty 最新版本为：4.1.77，所以后面所有文章 Netty 版本都是基于 4.1.77，包括源码解析。
引入 Netty
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.77.Final</version>
</dependency>
服务端
服务端的逻辑非常简单，监听 8081 端口，当有客户端连接进来时打印：“**，已连接”，同时打印客户端发送过来的消息。
public class HelloWorldServer {
public static void main(String[] args) {
// 创建服务端启动引导器
ServerBootstrap bootstrap = new ServerBootstrap();
// 配置线程模型
bootstrap.group(new NioEventLoopGroup());
// 指定服务端的 IO 模型
bootstrap.channel(NioServerSocketChannel.class);
// 定义处理器 Handler
bootstrap.childHandler(new ChannelInitializer<NioSocketChannel>() {
@Override
protected void initChannel(NioSocketChannel ch) throws Exception {
// 解码
ch.pipeline().addLast(new StringDecoder());
ch.pipeline().addLast(new ChannelInboundHandlerAdapter(){
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println(ctx.channel() + ",hello world");
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println(new Date() + "：" + msg);
}
});
}
});
// 绑定 8081 端口
bootstrap.bind(8081);
}
}
大明哥依次解释上面代码
ServerBootstrap bootstrap = new ServerBootstrap();：创建服务端启动引导器，ServerBootstrap将用于引导服务端的启动工作。bootstrap.group(new NioEventLoopGroup());：给引导器配置一个线程组，也就是 Netty 的线程模型，我们知道 Netty 是基于 Reactor 的线程模型，这里使用的单线程模型，即接受连接和业务处理都是使用同一个线程。bootstrap.channel(NioServerSocketChannel.class);：指定服务端的 IO 模型，这里我们定义的是 NIO，当然你也可以使用 BIO（OioServerSocketChannel.class），但是一般都不推荐，因为 Netty 的优势就在于 NIO。bootstrap.childHandler()：这里是定义业务逻辑处理器，简单来说就是客户端向服务端做的操作（连接、读、写），服务端都是在这里进行处理的。bootstrap.bind(8081)：绑定 8081 端口
一个最简单的 Netty 服务单程序就写完了。
客户端
客户端就做一件事，连接服务端，然后不停地往服务端发送 “hello world”。
public class HelloWorldClient {
public static void main(String[] args) throws InterruptedException {
// 客户端引导器
Bootstrap bootstrap = new Bootstrap();
// 配置线程组
bootstrap.group(new NioEventLoopGroup());
// 指定 IO 类型为 NIO
bootstrap.channel(NioSocketChannel.class);
// 配置 IO 处理器
bootstrap.handler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new StringEncoder());
}
});
// 建立连接
Channel channel = bootstrap.connect("127.0.0.1",8081).channel();
// 发送消息
while (true) {
channel.writeAndFlush("hello world..");
TimeUnit.SECONDS.sleep(5);
}
}
}
客户端与服务端的逻辑差不多，只不过它使用的是 Bootstrap，Bootstrap 为客户端启动的引导器，它负责启动客户端和连接服务端。创建引导器后，就和服务端一样了，需要配置线程模型，指定 IO 类型，配置 IO 处理器，最后与服务端建立连接。
bootstrap.connect("127.0.0.1",8081)：connect()方法与服务端进行连接，这里需要注意connect()方法是一个异步方法，它返回的是 ChannelFuture，调用channel()方法可以获取到对应的 channel（代码里面这种方式处理不是很优雅，我们后续再来讲）。channel.writeAndFlush()：向服务端发送消息。
到这里一个简单的 Netty 应用就完成了，是不是比使用 NIO 简便很多，也非常清晰。
运行结果
从服务端打印的日志可以看出，当客户端连接服务端后，打印日志：[id: 0xee05e542, L:/127.0.0.1:8081 - R:/127.0.0.1:53354],hello world，然后每隔 5 秒钟输出 hell world，这和我们开始的预期一样。
可能小伙伴们对上面的代码还不是很理解，对上面的 ServerBootstrap、group() 、channel() 等方法都不明白什么意思，没有关系，因为这篇文章仅仅只是让你对 Netty 有一个简单的认识，后面文章大明哥会将这些概念全部都讲的明明白白的。
【注】：上面两段代码有些瑕疵，但是为了小伙伴更加容易接受，大明哥就尽可能地简单演示，后面会基于它来优化
