【Netty】给萌新入门系列一记强心针：Netty Hello World！

2024-01-20 05:20:13

Netty 初学者指南：打造你的第一个“你好，世界！”程序

作为一名 Java 开发人员，在学习之旅中，我们经常会遇到难以捉摸的网络编程问题。但随着 Netty 的出现，我们有了揭开网络编程殿堂之谜的钥匙。Netty 作为 Java 程序员解决网络编程难题的利器，为我们指明了道路。本系列入门博文将从基础开始，帮助各位快速入门 Netty，让您对网络编程的奥秘有了更深入的了解。

构建你的第一个 Netty 程序——“你好，世界！”

在计算机科学中，“你好，世界！”程序通常是程序员编写的第一段代码，它被视为学习新编程语言或框架的入门例程。因此，我们将从构建一个简单的“你好，世界！”程序开始 Netty 的学习之旅。

1. 创建 Netty 项目

首先，我们需要创建一个 Netty 项目。您可以使用您喜欢的 IDE，如 Eclipse 或 IntelliJ IDEA，创建一个 Java 项目。在项目中添加所需的 Netty 库依赖，例如 netty-all。

2. 编写服务器端代码

接下来，我们将编写服务器端代码。服务器端代码负责监听客户端的连接请求，并在收到请求后发送响应。在 Netty 中，我们可以使用 ServerBootstrap 类来启动一个服务器。

ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup)
        .channel(NioServerSocketChannel.class)
        .childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            public void initChannel(SocketChannel ch) throws Exception {
                ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                        ctx.writeAndFlush(Unpooled.copiedBuffer("你好，世界！", CharsetUtil.UTF_8));
                    }
                });
            }
        });
bootstrap.bind(8080).sync();

3. 编写客户端代码

然后，我们将编写客户端代码。客户端代码负责向服务器发送请求并接收响应。在 Netty 中，我们可以使用 Bootstrap 类来启动一个客户端。

Bootstrap bootstrap = new Bootstrap();
bootstrap.group(workerGroup)
        .channel(NioSocketChannel.class)
        .handler(new ChannelInitializer<SocketChannel>() {
            @Override
            public void initChannel(SocketChannel ch) throws Exception {
                ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                        ByteBuf buf = (ByteBuf) msg;
                        byte[] data = new byte[buf.readableBytes()];
                        buf.readBytes(data);
                        String message = new String(data, CharsetUtil.UTF_8);
                        System.out.println("接收到服务器的消息：" + message);
                    }
                });
            }
        });
ChannelFuture future = bootstrap.connect(new InetSocketAddress("localhost", 8080));
future.sync();