骆驼豆方法在另一个线程上运行

Question

我有一个问题，我希望它很简单.. 我有一条骆驼路线，它会采取一些行动，有一个处理器，这个处理器用一个相关 id 填充一个 threadLocal 变量。 在此之后，它运行一个 .bean(mybean, "mymethod")，在这个方法中我尝试从 threadLocal 变量中获取我的值，但它是 null。

我理解的一件事是骆驼在另一个线程上运行 bean 方法？这是真的吗？

我添加了另一个bean方法调用.bean(myBean, "myMethodForCorrelationId(correlationId)")，这个方法设置了threadLocal变量，之后.bean(mybean, "mymethod")可以访问到threadLocal的正确值。

代码：

private void getRoute() {

    from(RouteConstant.INTERNAL)
    // id
    .routeId("myroute")
    .setHeader(ElkKeys.EVENT_TYPE.getElkKey(), constant(EventType.EXCHANGE_REQUEST_REPLAY))
    // extract header from query uri
    .process(filtersListProcessor).choice()
    // caching predicate
    .when(cachePrediate)
    // get from cache
    .to(RouteConstant.GET_FROM_CACHE_ROUTE).otherwise()

    .bean(mybean,"myMethodForCorrelationId(${header.correlationId})") // first call fill the threadLocal

    // second call, the method use the previous threadLocal variable and it works
    .bean(mybean,
            "myMethod( ${header."
                    + ElkKeys.QUERY_PARAMETERS.getElkKey() + "})") 

    .multicast()
    // put in cache
    .to(ExchangePattern.InOnly, RouteConstant.PUT_INTO_CACHE_ROUTE).endChoice()

    .setHeader(ElkKeys.REPONSE_TIMESTAMP.getElkKey(), simple(RESPONSE_DATE_TIME))

    // send trace
    .to(ExchangePattern.InOnly, RouteConstant.SEND_SUCCESS_TRACE_TO_ELK);
}

我在谷歌上搜索，但我找不到任何关于此的信息，第一个 bean 方法使用的线程是否与第二个方法相同（每次在任何情况下）？

如果有人知道答案，我希望你能帮助我..

谢谢大家，

Answer 1

您在问题中描述了一个奇怪的情况。事实上我在你的路由中没有看到任何会强制执行多线程的东西。

Bean 调用不在其他线程中处理。

默认情况下，Camel 路由由 1 个线程处理。这意味着您的 from 端点通常使用线程池来并行处理多个请求（例如 HTTP 或 JMS 端点），但是每个单独的请求都由一个线程完成。该线程通过完整路由路由消息。

我很快创建了这条路线，并给它发了一条消息：

from("direct:input")
    .log("Camel Route: " + Thread.currentThread().getName())
    .process(new TestProcessor()) // writes Thread.currentThread().getName() to System.out
    .bean(new BeanThread()); // writes Thread.currentThread().getName() to System.out

控制台输出如预期：

Camel Route: main
Processor: main
Bean: main

但是，有几个“有状态”组件，例如聚合器。一旦您使用其中之一，路线上的线程视图就会变得更加复杂。

但是，正如我在开头所写的，我在您的路线中看不到其中之一。

然而，最大的问题是：为什么要使用ThreadLocal 变量？ Camel 为以后保存值的方法是将它们放入消息头中。像这样，您可以保证与给定消息相关的值稍后仍会出现在路由中。