使用Spring Boot + Netty 打造聊天服务（一）

随着即时通讯的广泛应用，搭建一个高效的聊天服务逐渐成为开发者的热门课题。Spring Boot 作为一款快速开发展的框架，结合 Netty 的异步事件驱动特性，可以轻松构建一个高性能的聊天服务。本系列文章将为大家介绍如何使用 Spring Boot 和 Netty 搭建一个简单的聊天服务。

一、项目环境准备

在开始之前，请确保你有以下环境准备：

• JDK 1.8 或更高版本
• Maven 或 Gradle
• IDE (如 IntelliJ IDEA 或 Eclipse)
• 对 Spring Boot 和 Netty 有基本了解

二、创建 Spring Boot 项目

使用 Spring Initializr 创建一个新的 Spring Boot 项目，选择以下依赖：

• Spring Web
• Spring Boot DevTools

创建完成后，导入到你的 IDE 中。

三、引入 Netty 依赖

在 pom.xml 中添加 Netty 相关依赖：

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

四、实现 Netty 服务端

在项目中创建一个包，例如 com.example.nettychat.server，并创建一个 Netty 服务端类 ChatServer：

package com.example.nettychat.server;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
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.channel.ChannelInitializer;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

@Component
public class ChatServer {

    private static final Logger logger = LoggerFactory.getLogger(ChatServer.class);
    private final int port = 8080; // 聊天服务端口

    public void start() throws InterruptedException {
        // 初始化 EventLoopGroup
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) {
                            ch.pipeline().addLast(new ChatServerHandler());
                        }
                    });

            ChannelFuture f = b.bind(port).sync(); // 绑定服务端口
            logger.info("Chat server started on port: {}", port);
            f.channel().closeFuture().sync(); // 等待服务端口关闭
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }

    public static class ChatServerHandler extends SimpleChannelInboundHandler<String> {
        @Override
        protected void channelRead0(ChannelHandlerContext ctx, String msg) {
            // 处理客户端消息
            logger.info("Received message: {}", msg);
            ctx.writeAndFlush("Server response: " + msg + "\n"); // 回应客户端
        }

        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
            logger.error("Unexpected exception from downstream: " + cause.getMessage());
            ctx.close();
        }
    }
}

五、启动服务

在 Application 主类中启动 Netty 服务：

package com.example.nettychat;

import com.example.nettychat.server.ChatServer;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class NettyChatApplication {

    public static void main(String[] args) {
        SpringApplication.run(NettyChatApplication.class, args);
    }

    @Bean
    CommandLineRunner run(ChatServer chatServer) {
        return args -> {
            try {
                chatServer.start();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        };
    }
}

六、测试聊天服务

可以使用工具（如 telnet 或 Postman）连接到 localhost:8080 进行测试。输入消息，你会收到服务端的响应。

七、总结

本文主要讲解了如何使用 Spring Boot 和 Netty 搭建一个简单的聊天服务端。在下篇文章中，我们将继续扩展这个功能，包括消息广播、用户管理和前端交互等更多内容。希望大家能够通过本系列的学习，掌握使用 Netty 构建高性能网络应用的基础。