springboot整合netty 使用依赖注入

在Spring Boot中整合Netty，可以使用Spring的依赖注入来管理Netty的组件，这样可以更方便地管理Netty的资源。具体步骤如下：

1. 在pom.xml中添加netty和spring-boot-starter-web依赖：

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.51.Final</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

2. 创建Netty的ChannelInitializer，并使用Spring注入需要的对象：

@Component
public class NettyServerInitializer extends ChannelInitializer<SocketChannel> {

    @Autowired
    private NettyServerHandler nettyServerHandler;

    @Override
    protected void initChannel(SocketChannel channel) throws Exception {
        ChannelPipeline pipeline = channel.pipeline();
        pipeline.addLast(new StringDecoder());
        pipeline.addLast(new StringEncoder());
        pipeline.addLast(nettyServerHandler);
    }
}

3. 创建Netty的ServerBootstrap，使用Spring注入需要的对象：

@Configuration
public class NettyServerConfig {

    @Autowired
    private NettyServerInitializer nettyServerInitializer;

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

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

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

    @Bean(initMethod = "bind", destroyMethod = "shutdownGracefully")
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(bossGroup(), workerGroup())
                .channel(NioServerSocketChannel.class)
                .option(ChannelOption.SO_BACKLOG, 128)
                .childOption(ChannelOption.SO_KEEPALIVE, true)
                .childHandler(nettyServerInitializer);
        return serverBootstrap;
    }

    @Bean
    public InetSocketAddress inetSocketAddress() {
        return new InetSocketAddress(port);
    }
}

4. 在Controller中使用Netty的组件：

@RestController
public class NettyController {

    @Autowired
    private ServerBootstrap serverBootstrap;

    @Autowired
    private InetSocketAddress inetSocketAddress;

    @GetMapping("/start")
    public void start() throws InterruptedException {
        ChannelFuture channelFuture = serverBootstrap.bind(inetSocketAddress).sync();
        channelFuture.channel().closeFuture().sync();
    }
}

这样就完成了Netty和Spring Boot的整合，并且使用了Spring的依赖注入来管理Netty的组件。