springboot中使用netty的demo

以下是一个简单的 Spring Boot 中使用 Netty 的示例：

1. 首先，添加以下依赖到 pom.xml 文件中：

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

2. 创建一个 Netty 服务器类，并实现 ChannelInboundHandlerAdapter 接口：

@Component
@ChannelHandler.Sharable
public class NettyServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        // 处理客户端请求
        ByteBuf byteBuf = (ByteBuf) msg;
        byte[] bytes = new byte[byteBuf.readableBytes()];
        byteBuf.readBytes(bytes);
        String request = new String(bytes, "UTF-8");
        System.out.println("收到客户端请求：" + request);

        // 响应客户端请求
        String response = "Hello, " + request;
        ByteBuf responseBuf = Unpooled.copiedBuffer(response.getBytes());
        ctx.write(responseBuf);
    }

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

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

3. 创建 Netty 服务器启动类，并使用 @PostConstruct 注解启动 Netty 服务器：

@Component
public class NettyServer {

    private final NettyServerHandler nettyServerHandler;

    @Autowired
    public NettyServer(NettyServerHandler nettyServerHandler) {
        this.nettyServerHandler = nettyServerHandler;
    }

    @PostConstruct
    public void start() throws InterruptedException {
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .option(ChannelOption.SO_BACKLOG, 128)
                .childOption(ChannelOption.SO_KEEPALIVE, true)
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {
                        ch.pipeline().addLast(nettyServerHandler);
                    }
                });
        ChannelFuture future = serverBootstrap.bind(8080).sync();
        if (future.isSuccess()) {
            System.out.println("Netty 服务器启动成功");
        }
    }
}

以上示例中，我们创建了一个 Netty 服务器，监听 8080 端口。当客户端连接到服务器时，服务器会收到客户端请求，并响应客户端请求。

注意：如果你的 Spring Boot 应用部署在 Tomcat 或者 Jetty 容器中，则需要在启动方法上添加 @Bean 注解，以确保正确启动 Netty 服务器。