骆驼路线 - 提交作业，轮询响应

Question

我正在寻找一些关于如何使用骆驼路线实现以下模式的想法：

1. 客户端通过HTTP restendpoint调用web服务（originalService）
2. 服务接受服务的主体，并将其作为作业提交给另一个web服务（jobService）。此辅助服务返回作业id。
3. 使用作业id，originalService轮询jobService的时间不超过x秒。Originalservice将把提交的服务的结果返回给调用者。如果作业耗时超过x秒（jobService没有响应），则originalService将向客户端发送“超时”响应

关于如何使用骆驼路线实现“原始服务”的任何想法？我不想在探测作业服务以获取作业状态时阻塞线程 x 秒。

Answer 1

我突然想到两种方法。

1：程序上

在路线中放置一个具有延迟和固定迭代次数的循环。Psuedo骆驼：

from(myEndpoint)
  to(submitRequest)
  loop(5 times)
    enrich(pollJob, myAggregator)
    choice.when(complete)
      stop
    otherwise
      delay(1000ms)
  endloop

myAggregator需要查看轮询操作的结果以确定作业是否完成，提取结果并设置一个exchange属性以指示成功。如果你从循环的底部掉出来，你已经超过了超时时间。

这里的路线相当明显地说明了发生了什么，但有点做作。

2：定制骆驼组件

您可以构建自己的Camel组件来表示您的服务，这将支持生产者提交作业和完成轮询。您可以在组件内部进行轮询，这样路由会大大简化，例如:

from(myEndpoint)
  to(myComponent:doRequest?interval=1000ms&attempts=5)

如果您想使用其他Camel组件进行REST/SOAP/任何调用，则组件中的生产者可以利用它们，或者如果您愿意，您可以直接使用CXF/任何东西。

当你用尽所有的尝试时，如何实现失败场景取决于你。一个异常是合适的，然后Camel错误处理程序就会介入。

构建自己的组件很简单，也是实现复杂行为的有效方法，而路由有时并不擅长。