Netty构建HTTP服务器实例解析：开发人员福音！

后端

2023-12-12 03:21:37

使用 Netty 构建高效的 HTTP 服务器

前言

Netty 是一款备受推崇的异步事件驱动网络应用程序框架，用于开发高效、可维护的协议服务器和客户端。本文将深入探讨如何使用 Netty 构建一个简单的 HTTP 服务器实例，让您亲身体验其强大功能。

创建 Netty HTTP 服务器

1. 创建项目

首先，使用您的首选集成开发环境（如 IntelliJ IDEA）创建一个新的 Netty 项目。

2. 添加 Netty 依赖

在项目中添加以下依赖项以使用 Netty：

<dependency>
  <groupId>io.netty</groupId>
  <artifactId>netty-all</artifactId>
  <version>4.1.72.Final</version>
</dependency>

3. 编写 Netty HTTP 服务器代码

创建一个新的 Java 类，并输入以下代码以实现 Netty HTTP 服务器：

// 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.ChannelPipeline;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.HttpServerExpectContinueHandler;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;

public class NettyHttpServer {

    public static void main(String[] args) throws Exception {
        // 创建 EventLoopGroup，负责事件处理
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            // 创建 ServerBootstrap，用于配置和启动服务器
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .option(ChannelOption.SO_BACKLOG, 128)
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) {
                            ChannelPipeline pipeline = ch.pipeline();

                            // HttpServerCodec：编码和解码 HTTP 消息
                            pipeline.addLast(new HttpServerCodec());

                            // HttpServerExpectContinueHandler：处理 "Expect: 100-continue" 头
                            pipeline.addLast(new HttpServerExpectContinueHandler());

                            // 添加自定义业务处理程序
                            pipeline.addLast(new HttpServerHandler());
                        }
                    });

            // 绑定端口并启动服务器
            ChannelFuture channelFuture = bootstrap.bind(8080).sync();

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