SpringBoot 整合 Netty 实现 Tcp服务器

使用 SpringBoot 整合 Netty 实现 TCP 服务器可以让我们更方便地管理和部署我们的应用程序。下面是一些基本的步骤：

1. 创建一个 SpringBoot 项目，并添加 Netty 和相应的依赖。

2. 创建一个 Netty 服务类，实现 ChannelInboundHandlerAdapter 接口。在这个类中，你可以实现接收、处理和发送 TCP 消息的逻辑。

3. 通过 SpringBoot 的配置文件，配置 Netty 服务器的端口和其他参数。

4. 在 SpringBoot 的启动类中，使用 @Bean 注解将 Netty 服务类注册为 bean。

5. 启动 SpringBoot 应用程序，Netty 服务器将开始监听传入的连接。

下面是一个简单的示例：

// 服务类
@Component
public class MyNettyServer extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        // 处理接收到的消息
        ByteBuf buf = (ByteBuf) msg;
        String message = buf.toString(CharsetUtil.UTF_8);

        // 返回响应消息
        String response = "Hello, " + message;
        ctx.writeAndFlush(Unpooled.copiedBuffer(response.getBytes()));
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        // 处理异常
        cause.printStackTrace();
        ctx.close();
    }
}

// 启动类
@SpringBootApplication
public class MyApplication {

    @Autowired
    private MyNettyServer myNettyServer;

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

    @PostConstruct
    public void start() throws Exception {
        // 创建 EventLoopGroup
        EventLoopGroup group = new NioEventLoopGroup();

        try {
            // 创建 ServerBootstrap
            ServerBootstrap b = new ServerBootstrap();
            b.group(group)
                    .channel(NioServerSocketChannel.class)
                    .localAddress(new InetSocketAddress(port))
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch) throws Exception {
                            // 添加处理器
                            ch.pipeline().addLast(myNettyServer);
                        }
                    });

            // 启动服务器
            ChannelFuture f = b.bind().sync();
            f.channel().closeFuture().sync();
        } finally {
            // 关闭 EventLoopGroup
            group.shutdownGracefully().sync();
        }
    }

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

// 配置文件
netty.port=8080

在这个例子中，我们创建了一个名为 `MyNettyServer` 的服务类，并实现了 `ChannelInboundHandlerAdapter` 接口。在 `channelRead` 方法中，我们处理接收到的消息，并返回响应消息。在 `exceptionCaught` 方法中，我们处理异常。

在启动类中，我们使用 `@Autowired` 注解将 `MyNettyServer` 注入到启动类中，并使用 `@Value` 注解获取配置文件中的端口号。在 `start` 方法中，我们创建了一个 `EventLoopGroup`，并使用 `ServerBootstrap` 创建了一个 Netty 服务器。然后，我们将 `MyNettyServer` 添加到 `SocketChannel` 的处理器中。最后，我们启动服务器，并在关闭服务器之前等待连接。

这只是一个简单的示例，你可以根据你的需求修改和扩展它。