springboot netty server 失败重连

// 1. 在SpringBoot中整合Netty实现失败重连的示例代码如下：
// 首先需要在pom文件中引入netty的依赖
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.42.Final</version>
</dependency>

// 然后创建Netty的ChannelInitializer，用于初始化ChannelPipeline
public class NettyClientInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel ch) {
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast(new NettyClientHandler());
    }
}

// 创建Netty的ChannelHandler，处理连接事件和重连逻辑
public class NettyClientHandler extends ChannelInboundHandlerAdapter {
    private EventLoopGroup group = new NioEventLoopGroup();
    private Bootstrap bootstrap = new Bootstrap();

    @Override
    public void channelInactive(ChannelHandlerContext ctx) {
        // 连接断开时发起重连
        ctx.channel().eventLoop().schedule(() -> {
            try {
                connect(bootstrap, group);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }, 3, TimeUnit.SECONDS);
    }

    public void connect(Bootstrap bootstrap, EventLoopGroup group) throws Exception {
        bootstrap.group(group)
                .channel(NioSocketChannel.class)
                .handler(new NettyClientInitializer());
        ChannelFuture future = bootstrap.connect("serverHost", serverPort).sync();
        future.channel().closeFuture().sync();
    }
}

// 在SpringBoot中启动Netty客户端
@SpringBootApplication
public class NettyClientApplication {
    public static void main(String[] args) {
        SpringApplication.run(NettyClientApplication.class, args);
        new NettyClientHandler().connect(new Bootstrap(), new NioEventLoopGroup());
    }
}