Netty 入门指南：一步一步构建 IM 聊天室，看不懂就锤爆哪吒的狗头~（上）

见解分享

2024-01-29 17:00:59

嘿，各位码农精英们！

准备好了吗？ 我们即将开启一场激动人心的 Netty 冒险之旅，打造一个即时通讯（IM）聊天室。我敢保证，这个过程会妙趣横生，不过前提是你得做好心理准备，因为任何一丝小差错，哪吒的小狗头都可能被你锤爆哦~

让我们先来个项目概览：

在 lab-67-netty-demo-server 项目中，我们搭建了一个 Netty 服务端，它将负责处理所有传入的连接和消息。同时，我们还准备了一个 Netty 客户端，它将连接到服务端，并发送和接收消息。

咱们的聊天室将支持以下功能：

用户认证
单聊
群聊
断开重连
心跳机制
空闲检测

好了，现在让我们深入了解一下 Netty 的奥秘吧！

Netty 是啥玩意儿？

Netty 是一个 Java NIO 框架，它可以帮助我们轻松地编写高性能、可扩展的网络应用程序。它提供了各种开箱即用的功能，例如：

非阻塞 I/O
线程池管理
协议编解码
流控制

第一步：构建 Netty 服务端和客户端

首先，我们需要构建一个 Netty 服务端，它将负责侦听来自客户端的连接。我们还需要创建一个客户端，它将连接到服务端并发送和接收消息。

服务端代码：

public class NettyServer {

    private ServerBootstrap serverBootstrap;

    public static void main(String[] args) {
        new NettyServer().start();
    }

    public void start() {
        // 创建 ServerBootstrap 对象
        serverBootstrap = new ServerBootstrap();

        // 设置 I/O 事件处理类
        serverBootstrap.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) {
                        // 设置管道处理器
                        ch.pipeline().addLast(new NettyServerHandler());
                    }
                });

        // 绑定端口
        serverBootstrap.bind(8080);
    }
}

客户端代码：

public class NettyClient {

    private EventLoopGroup group;

    public static void main(String[] args) {
        new NettyClient().start();
    }

    public void start() {
        // 创建 EventLoopGroup 对象
        group = new NioEventLoopGroup();

        // 创建 Bootstrap 对象
        Bootstrap bootstrap = new Bootstrap();

        // 设置 I/O 事件处理类
        bootstrap.group(group)
                .channel(NioSocketChannel.class)
                .handler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) {
                        // 设置管道处理器
                        ch.pipeline().addLast(new NettyClientHandler());
                    }
                });

        // 连接到服务端
        bootstrap.connect("localhost", 8080);
    }
}