Spring Boot 整合 Netty 实现 TCP 通讯

要在 Spring Boot 中整合 Netty 实现 TCP 通讯，可以按照以下步骤进行：

首先，需要在 pom.xml 文件中添加 Netty 的依赖。可以通过以下方式添加依赖：

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

创建一个 TCP 服务器类，继承自ChannelInboundHandlerAdapter，重写相关方法处理接收到的消息。例如：

@ChannelHandler.Sharable
public class TcpServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        // 处理接收到的消息
        ByteBuf byteBuf = (ByteBuf) msg;
        String message = byteBuf.toString(CharsetUtil.UTF_8);
        System.out.println('接收到消息：' + message);

        // 回复消息
        String replyMessage = '服务器已收到消息';
        ByteBuf replyByteBuf = Unpooled.copiedBuffer(replyMessage, CharsetUtil.UTF_8);
        ctx.write(replyByteBuf);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

创建一个 Spring Boot 的配置类，用于配置 Netty 服务器。例如：

@Configuration
public class NettyConfig {

    @Value('${netty.port}')
    private int port;

    @Autowired
    private TcpServerHandler tcpServerHandler;

    @Bean
    public EventLoopGroup bossGroup() {
        return new NioEventLoopGroup();
    }

    @Bean
    public EventLoopGroup workerGroup() {
        return new NioEventLoopGroup();
    }

    @Bean
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(bossGroup(), workerGroup())
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) {
                        ChannelPipeline pipeline = ch.pipeline();
                        pipeline.addLast(new StringDecoder(CharsetUtil.UTF_8));
                        pipeline.addLast(new StringEncoder(CharsetUtil.UTF_8));
                        pipeline.addLast(tcpServerHandler);
                    }
                });
        return serverBootstrap;
    }

    @Bean
    public ChannelFuture serverChannelFuture() throws InterruptedException {
        return serverBootstrap().bind(port).sync();
    }

    @PreDestroy
    public void destroy() {
        bossGroup().shutdownGracefully();
        workerGroup().shutdownGracefully();
    }
}

在 application.properties 文件中添加 Netty 服务器的端口配置，例如：

netty.port=8888

创建一个 Spring Boot 的启动类，启动 Netty 服务器。例如：

@SpringBootApplication
public class Application {

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

通过以上步骤，就可以在 Spring Boot 中整合 Netty 实现 TCP 通讯了。当有客户端连接到服务器并发送消息时，服务器将接收到消息并回复一个固定的消息。