Netty 框架入门：从NIO到Netty

2024-01-06 19:52:20

Netty：一个打造高性能网络应用程序的利器

什么是 NIO？

非阻塞 I/O (NIO) 是一种 I/O 模型，它允许应用程序在不等待 I/O 操作完成的情况下继续执行。NIO 通过事件驱动的方式处理 I/O 操作。当 I/O 操作准备就绪时，应用程序会收到一个事件通知，然后应用程序再对该事件进行处理。

Netty 框架

Netty 是一个基于 NIO 的网络应用框架，它提供了一套简洁易用的 API，帮助开发人员快速构建高性能、可扩展的网络应用程序。Netty 框架的特点包括：

高性能： Netty 使用 NIO 作为底层 I/O 模型，因此具有很高的性能。
异步事件驱动： Netty 采用异步事件驱动的编程模型，可以充分利用多核 CPU 的优势，提高应用程序的并发性能。
可扩展性强： Netty 框架提供了丰富的扩展功能，使应用程序可以轻松地扩展到更大的规模。

使用 Netty 框架

使用 Netty 框架非常简单，它提供了丰富的 API 来帮助开发人员快速构建网络应用程序。下面是一个简单的 Netty 服务器端程序：

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;

public class NettyServer {

    public static void main(String[] args) throws Exception {
        // 创建 EventLoopGroup
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            // 创建 ServerBootstrap
            ServerBootstrap serverBootstrap = new ServerBootstrap();

            // 设置 ServerBootstrap
            serverBootstrap.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            // 添加 ChannelHandler
                            ch.pipeline().addLast(new NettyServerHandler());
                        }
                    })
                    .option(ChannelOption.SO_BACKLOG, 128)
                    .childOption(ChannelOption.SO_KEEPALIVE, true);

            // 绑定端口，启动服务端
            ChannelFuture channelFuture = serverBootstrap.bind(8888).sync();

            // 等待服务端关闭
            channelFuture.channel().closeFuture().sync();
        } finally {
            // 关闭 EventLoopGroup
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}