Netty for Java：完整指南及示例

什么是 Netty，为什么需要它？

Netty 是一个用于 Java 的异步网络库，它允许您创建高性能的服务器和客户端应用程序。它抽象了处理套接字、线程和 NIO（非阻塞 I/O）的复杂性，为开发人员提供了一个简单而强大的 API 来构建网络应用程序。

为什么需要 Netty？

\n
• 高性能： Netty 基于 Java NIO 构建，允许处理数千个并发连接，而无需为每个连接创建单独的线程。
\n
• 异步性： 所有输入/输出操作都不会阻塞执行线程，从而提高了应用程序的可扩展性。
\n
• 易于使用： 尽管底层技术复杂，Netty 提供了清晰简洁的 API。
\n
• 灵活性： Netty 的架构基于处理程序链（pipeline），可以轻松添加、删除或修改数据处理逻辑。
\n
• 支持多种协议： Netty 内置支持 HTTP、WebSocket、SSL/TLS、UDP 以及许多其他协议。
\n

Netty 被广泛应用于 Apache Cassandra、Apache Spark、Elasticsearch、Twitter Finagle 等项目。

安装 Netty

Netty 是一个 Java 库，因此通过依赖管理系统（如 Maven 或 Gradle）安装。与 Python 或 JavaScript 不同，这里没有 pip install 或 npm install 命令。

通过 Maven 安装

将以下依赖项添加到 pom.xml 文件中：

<dependency>\n    <groupId>io.netty</groupId>\n    <artifactId>netty-all</artifactId>\n    <version>4.1.109.Final</version>\n</dependency>

通过 Gradle 安装

添加到 build.gradle 文件中：

implementation 'io.netty:netty-all:4.1.109.Final'

通过 Gradle (Kotlin DSL) 安装

implementation("io.netty:netty-all:4.1.109.Final")

添加依赖项后，您的 IDE（例如 IntelliJ IDEA 或 Eclipse）将自动下载该库。

快速入门：简单的 HTTP 服务器

让我们创建一个简单的 HTTP 服务器，它对任何请求都响应 "Hello, World!"。

import io.netty.bootstrap.ServerBootstrap;\nimport io.netty.channel.ChannelFuture;\nimport io.netty.channel.ChannelInitializer;\nimport io.netty.channel.ChannelPipeline;\nimport io.netty.channel.EventLoopGroup;\nimport io.netty.channel.nio.NioEventLoopGroup;\nimport io.netty.channel.socket.SocketChannel;\nimport io.netty.channel.socket.nio.NioServerSocketChannel;\nimport io.netty.handler.codec.http.HttpServerCodec;\nimport io.netty.handler.codec.http.HttpObjectAggregator;\nimport io.netty.handler.codec.http.HttpResponseStatus;\nimport io.netty.handler.codec.http.DefaultFullHttpResponse;\nimport io.netty.handler.codec.http.FullHttpResponse;\nimport io.netty.handler.codec.http.HttpRequest;\nimport io.netty.handler.codec.http.HttpResponse;\nimport io.netty.handler.codec.http.HttpVersion;\nimport io.netty.buffer.Unpooled;\nimport io.netty.util.CharsetUtil;\nimport io.netty.channel.ChannelHandlerContext;\nimport io.netty.channel.SimpleChannelInboundHandler;\n\npublic class SimpleHttpServer {\n\n    public static void main(String[] args) throws Exception {\n        EventLoopGroup bossGroup = new NioEventLoopGroup(1);\n        EventLoopGroup workerGroup = new NioEventLoopGroup();\n\n        try {\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n             .channel(NioServerSocketChannel.class)\n             .childHandler(new ChannelInitializer<SocketChannel>() {\n