Spring Boot 整合 Netty 现实TCP通信

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
@Component
public class NettyTcpServer {
 
    private final EventLoopGroup bossGroup = new NioEventLoopGroup();
    private final EventLoopGroup workerGroup = new NioEventLoopGroup();
    private Channel channel;
 
    @Autowired
    private ChannelInitializer<SocketChannel> channelInitializer;
 
    public void start(int port) throws InterruptedException {
        ServerBootstrap b = new ServerBootstrap();
        b.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(channelInitializer);
 
        channel = b.bind(port).sync().channel();
        System.out.println("TCP服务器启动完成，监听端口：" + port);
    }
 
    public void stop() {
        if (channel != null) {
            channel.close();
        }
        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
    }
}
 
@Component
public class ChannelInitializerImpl extends ChannelInitializer<SocketChannel> {
 
    @Autowired
    private ChannelInboundHandlerAdapter handlerAdapter;
 
    @Override
    protected void initChannel(SocketChannel ch) {
        ch.pipeline().addLast(handlerAdapter);
    }
}
 
@Component
public class ServerHandler extends ChannelInboundHandlerAdapter {
 
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        // 接收到消息的处理逻辑
    }
 
    @Override
    public void channelActive(ChannelHandlerContext ctx) {
        // 客户端连接时的处理逻辑
    }
 
    // 其他必要的方法实现
}

这个代码示例展示了如何在Spring Boot应用程序中整合Netty来实现TCP通信服务器。NettyTcpServer类负责启动和停止服务器，ChannelInitializerImpl类配置了Netty的ChannelPipeline，而ServerHandler类处理实际的通信逻辑。这个示例提供了基础框架，开发者可以根据自己的需求添加具体的业务逻辑。