java - 如何编写并发处理请求的 Camel 路由

Question

我正在尝试编写一个 Camel 路由，该路由消耗来自 JMS 队列的传入消息并在不同的线程中同时处理它们。我得到的 Camel 路线是这样的:

<camel:endpoint id="requestQueue" uri="jms:queue.request" camelContextId="camel"/>
<camel:endpoint id="responseQueue" uri="jms:queue.response" camelContextId="camel"/>

<camel:camelContext id="camel">
    <camel:threadPool id="serviceThreadPool" poolSize="10" threadName="workerThread" maxPoolSize="20"/>

    <camel:route id="requestServingRoute">
        <camel:from ref="requestQueue"/>

        <camel:threads executorServiceRef="serviceThreadPool">
            <camel:to uri="bean:doSomething"/>
            <camel:to ref="responseQueue"/>
        </camel:threads>
    </camel:route>
</camel:camelContext>

但是，我可以观察到传入的消息确实是由单独的线程处理的，但它们是按顺序处理的。

我试图实现的是，camel 在单独的线程中为每个传入请求处理 doSomething bean 中的每个请求。

我怎样才能实现这个目标？

非常感谢。

Answer 1

您需要指定 JMS 请求队列的并发使用者数量。请参阅http://camel.apache.org/jms.html 。您不需要向线程池发送消息。例如，在 Java DSL 语法中，您可以编写如下内容:

from("jms:queue.request?concurrentConsumers=10")
.beanRef("bean", "doSomething")
.to("jms:queue.response)