0

我有一个 Camel 应用程序，它使用 netty 组件通过 TCP 与远程服务器通信。服务器有挂起的趋势，所以我希望能够在请求上添加可配置的超时，这样如果在 X 时间内没有返回响应，我会得到一个异常。

mina 组件在参数中具有此功能timeout，但 netty 组件似乎没有相应的选项。

我试着用 aReadTimeoutHandler来完成这个，结果很接近......但不完全是。HashedWheelTimer它首先在初始化时创建CamelContext：

HashedWheelTimer timer = new HashedWheelTimer();
JndiRegistry jndi = new JndiRegistry();
jndi.bind("MyClientPipelineFactory", new MyClientPipelineFactory(timer));

然后将其添加到我的管道中：

public class MyClientPipelineFactory extends ClientPipelineFactory
{
  private final Timer timer;

  public MyClientPipelineFactory(Timer timer) {
    this.timer = timer;
  }

  public ChannelPipeline getPipeline(NettyProducer producer) throws Exception
  {
    ChannelPipeline p = pipeline();
    p.addLast("timeout", new ReadTimeoutHandler(timer, 30));
    // more stuff
    return p;
  }
}

最后，我在路由配置中发现了任何异常：

onException(ReadTimeoutException.class)
   .handled(true)
   .process(new Processor() {
      public void process(Exchange exchange) throws Exception {
         Exception exception = (Exception) exchange.getProperty(Exchange.EXCEPTION_CAUGHT);
         throw new ApplicationException("Connection timed out", exception);
      }
   });

这几乎可以工作。不幸的是，它是特定于渠道的，而不是特定于请求的。因此，只要我与服务器通信，我就没事。但是在我完成 30 秒后，我被ReadTimeoutException扔了。问题是它正在寻找网络上的任何活动，而不是我关心的请求/响应对。

我在这里错过了什么吗？是否有使用 Camel+Netty 进行请求超时的固有方法，或者有什么方法可以完成这项ReadTimeoutException工作？

（骆驼 2.9.2/Netty 3.3.1）

4

2 回答 2

1

我对 Camel 不熟悉，但快速浏览一下 Mina 和 Netty 组件表明所需的功能是 Mina 组件的功能，而不是 Mina，并且 Netty 组件中缺少它。在 camel trunk 中，Mina 生产者有一个同步为真时的代码路径，而 Netty 生产者似乎没有类似的功能。将问题带到骆驼邮件列表中可能是值得的。

一种可能的解决方法是创建一个可识别请求/响应的自定义 Netty 处理程序，因此您的管道中有一个处理程序，该处理程序在发送请求时启动计时器，并在收到响应时取消计时器。

于 2012-10-26T08:31:40.320 回答
0

我想知道我们是否可以为此添加某种支持。在给定的交换请求/回复对上触发超时。

我假设 ReadTimeoutHandler 来自 Netty？我想我们可以在代码中达到峰值，看看我们是否只能在有“进行中”交换的情况下让它触发。

一个技巧也是如何处理如果稍后回复，并且已经触发了超时。然后骆驼需要处理这个以取消处理回复。我不确定这是否那么容易做到。

于 2012-10-29T11:30:02.580 回答