拒.绝 2020-02-19 11:32 采纳率: 0%
浏览 2021

netty 如何设置客户端连接超时时间?希望路过的大神留下宝贵的意见!

1:netty 客户端设置连接超时时间,在规定的时间内如果没有连接到服务端视为网络异常,进行跳过处理。
2:我曾试过bootstrap.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000);
可是这段代码没有起作用,代码如下:

工作线程池组

    EventLoopGroup eventLoopGroup = new NioEventLoopGroup();

    Bootstrap bootstrap = new Bootstrap();
    bootstrap.group(eventLoopGroup)// //设置线程池
            .channel(NioSocketChannel.class)// 设置socket工厂
            // .option(ChannelOption.TCP_NODELAY, true)
            .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 9000)// 设置超时时间
            .handler(new ChannelInitializer<SocketChannel>() {

                @Override
                protected void initChannel(SocketChannel socketChannel) throws Exception {

                    ChannelPipeline pipeline = socketChannel.pipeline();
                    // 处理类
                    pipeline.addLast(new EchoClientHandler());
                }
            });

    try {
        // 发起连接操作
        ChannelFuture future = bootstrap.connect(host, port);

        // 连接若异常发起3次重新连接
        i++;
        if (i <= 3) {
            // 启动时连接超时重试
            future.addListener(new ConnectionListener(i));
        }

        // 等待客户端链路关闭
        future.channel().closeFuture().sync();
    } catch (InterruptedException e) {

    } finally {
        // 优雅退出,释放线程池资源
        eventLoopGroup.shutdownGracefully();
    }


    对于这个问题该如何解决呢?
  • 写回答

1条回答 默认 最新

  • 前段后端我都会 2021-04-13 16:52
    关注
    .addLast(new IdleStateHandler(30,0,0, TimeUnit.SECONDS))
    评论

报告相同问题?

悬赏问题

  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog
  • ¥15 Excel发现不可读取的内容
  • ¥15 关于#stm32#的问题:CANOpen的PDO同步传输问题
  • ¥20 yolov5自定义Prune报错,如何解决?