Apache Camel REST服务并行调用结果混乱问题求助

你精准定位到了问题的核心——单例的availabilitiesBean在并行请求场景下被多线程共享，导致不同请求的响应数据互相覆盖，这是典型的线程不安全问题。下面给你几个实用的解决方案，按推荐度排序：

1. 使用请求作用域的Bean（最直接的修复） #

在Karaf环境中，你可以将availabilitiesBean的作用域配置为请求作用域，这样每个HTTP请求都会创建一个独立的Bean实例，彻底从根源上避免数据共享问题。

配置方式（分容器场景） #

如果你的Bean是基于Spring上下文定义的，直接添加scope="request"：

<bean id="availabilitiesBean" class="com.xxx.AvailabilitiesBean" scope="request"/>

如果用的是Karaf原生的Blueprint容器，配置请求作用域的方式类似：

<bean id="availabilitiesBean" class="com.xxx.AvailabilitiesBean" scope="request">
    <!-- 你的Bean属性配置 -->
</bean>

注意：要确保这个Bean没有被其他单例Bean持有强引用，否则会破坏请求作用域的隔离性。

2. 将状态存储在Camel Exchange属性中（无需修改Bean作用域） #

如果不想调整Bean的作用域，可以把响应列表这类请求级别的状态，直接存入当前Exchange的属性里——每个请求对应独立的Exchange，状态自然不会互相干扰。

路由调整 #

<route id="route.Availabilities">
    <from uri="direct:availabilities"/>
    <!-- 初始化空响应列表并存入Exchange属性 -->
    <setHeader headerName="RESPONSE_LIST">
        <bean ref="availabilitiesBean" method="createEmptyResponseList"/>
    </setHeader>
    <split parallelProcessing="true">
        <simple>${body.articles}</simple>
        <!-- 执行SQL查询单个物品库存 -->
        <bean ref="availabilitiesBean" method="querySingleItemInventory(${body})"/>
        <!-- 将单个结果加入Exchange中的响应列表 -->
        <bean ref="availabilitiesBean" method="addItemToResponseList(${header.RESPONSE_LIST}, ${body})"/>
    </split>
    <!-- 从Exchange属性中取出最终响应作为返回值 -->
    <setBody>
        <simple>${header.RESPONSE_LIST}</simple>
    </setBody>
</route>

Bean逻辑调整（改为无状态） #

把原来的实例变量全部移除，让Bean变成纯无状态的工具类：

public class AvailabilitiesBean {
    // 无任何实例变量
    public List<Availability> createEmptyResponseList() {
        return new ArrayList<>();
    }

    public Availability querySingleItemInventory(Article article) {
        // 执行SQL查询并返回单个物品的库存状态
        return inventoryDao.query(article.getId());
    }

    public void addItemToResponseList(List<Availability> responseList, Availability item) {
        responseList.add(item);
    }
}

这种方式更贴合Camel的设计理念：Exchange是请求的上下文载体，所有请求相关的状态都应该绑定在Exchange上，而非Bean实例中。

3. 使用Split的聚合策略（最优雅的并行处理方式） #

Camel的Split组件本身支持自定义聚合策略，你可以不用手动维护响应列表，让Split自动聚合每个子任务的结果，完全规避状态共享问题。

路由调整 #

<route id="route.Availabilities">
    <from uri="direct:availabilities"/>
    <!-- 指定自定义聚合策略，并行处理每个物品 -->
    <split parallelProcessing="true" strategyRef="availabilityAggregationStrategy">
        <simple>${body.articles}</simple>
        <!-- 每个子任务返回单个物品的库存状态 -->
        <bean ref="availabilitiesBean" method="querySingleItemInventory(${body})"/>
    </split>
    <!-- 聚合后的结果直接作为响应返回 -->
</route>

<!-- 定义聚合策略Bean -->
<bean id="availabilityAggregationStrategy" class="com.xxx.AvailabilityAggregationStrategy"/>

聚合策略实现 #

public class AvailabilityAggregationStrategy implements AggregationStrategy {
    @Override
    public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
        if (oldExchange == null) {
            // 处理第一个子任务，初始化结果列表
            List<Availability> resultList = new ArrayList<>();
            resultList.add(newExchange.getBody(Availability.class));
            newExchange.setBody(resultList);
            return newExchange;
        } else {
            // 处理后续子任务，将结果加入已有列表
            List<Availability> resultList = oldExchange.getBody(List.class);
            resultList.add(newExchange.getBody(Availability.class));
            return oldExchange;
        }
    }
}

这种方式最符合Camel的原生设计，代码简洁且不需要担心线程安全问题。

方案选择建议 #

• 若想最小改动现有代码，优先选请求作用域Bean；
• 若不想调整Bean作用域，选Exchange属性存储状态；
• 若想重构代码以贴合最佳实践，选Split聚合策略。

内容的提问来源于stack exchange，提问作者Themis Pyrgiotis