Apache Camel使用HTTP from定义路线

Question

如何使用HTTP为“from”endpoint定义骆驼路由？

我的目标是定义一个路由，当有HTTP请求时，消息将在ActiveMQ队列上排队。

我尝试了以下路由定义:

<route>
  <from uri="http://localhost:8181/cxf/crm/customerservice/customers" />
  <to uri="activemq:queue:LOG.ME" />
</route>

从浏览器中，我访问 URL：

http://localhost:8181/cxf/crm/customerservice/customers/123

我已经验证了HTTP请求已经到达web服务“customerservice ”,因为我收到了来自web服务的XML响应。但是，没有消息在ActiveMQ队列中排队。

下面是处理ActiveMQ队列中消息的路由定义。

<route>
  <from uri="activemq:queue:LOG.ME" />
  <multicast>
    <pipeline>
      <bean ref="processor1" method="handle" />
      <to uri="mock:result" />
    </pipeline>
    <pipeline>
      <bean ref="processor2" method="handle" />
      <to uri="mock:result" />
    </pipeline>
  </multicast>
</route>

我验证了没有任何东西排队到 ActiveMQ，因为我的 bean “processor1”和“processor2”的“句柄”方法没有执行。

如何使用HTTP为“from”endpoint定义骆驼路由？

谢谢。

Answer 1

要侦听传入的超文本传输协议请求，可以使用jetty或cxf组件设置代理，然后调用Web服务并将消息记录到Activemq。

举个例子，

from("jetty:http://localhost:8282/xxx").
     to("http://localhost:8181/cxf/crm/customerservice/customers").
          to("activemq:queue:LOG.ME");

现在，要访问web服务，代理可以作为调用http://localhost:8282/xxx，而不是直接调用web服务。也可以使用cxf组件设置代理，这是很好的记录。

Answer 2

如果您想侦听HTTP请求，那么如果您在Web应用程序中运行，则需要使用servlet组件，或者使用嵌入简单超文本传输协议服务器的jetty组件。

两者都有很好的文档和示例。

http和http4组件仅适用于生产者(< code >