Camel Multicast路由调用顺序异常 批处理状态保存反向问题咨询

问题根因 #

1. save调用顺序反向：当前路由为嵌套同步调用链路，multicast默认会等待所有目标节点执行完成再返回，因此内层路由的save逻辑会先执行完成，外层路由的save后执行，天然呈现栈式反向调用顺序。
2. 加parallelProcessing后save无消息：存在两个问题：
   • 并行处理默认不会等待异步子线程执行完成，主线程结束后子线程直接被销毁，消息还未发送到MQ就被中断；
   • 配置的JmsComponent bean名称为jmsComponent，对应Camel组件前缀是jms:，但路由中使用的是activemq:前缀，组件匹配错误，异步场景下异常被吞导致无报错。

修复方案 #

1. 修复JMS组件配置

将JmsComponent的bean名称修改为activemq，和路由中的组件前缀匹配，同时配置持久化投递保证消息可靠性：

@Bean(name = "activemq")
public JmsComponent activemqComponent() throws JmsException { 
    ActiveMQConnectionFactory activeMQCF = Utilities.getActiveMQFactory(); 
    JmsComponent jms = new JmsComponent(); 
    jms.setConnectionFactory(activeMQCF);
    jms.setDeliveryPersistent(true);
    return jms; 
}

2. 调整路由逻辑

无需使用multicast，直接按业务顺序调整调用链路，保证save在当前节点业务执行完成后、下一个节点执行前发送，完全满足串行顺序要求：

@Override
public void configure() throws Exception {
    ExceptionHandlerBuilder.retry(this);

    from(a)
        // 此处放置a节点的业务处理逻辑
        .to(save)
        .to(b);

    from(b)
        // 此处放置b节点的业务处理逻辑
        .to(save)
        .to(c);

    from(c)
        // 此处放置c节点的业务处理逻辑
        .to(save)
        .to(d);

    from(d)
        // 此处放置d节点的业务处理逻辑
        .to(save)
        .to("mock:end");
                
    from(save)
        .process(new ModifyText())
        .to(toFile + "?fileExist=Append&charset=utf-8");
}

如果必须保留multicast组件，去掉parallelProcessing配置（串行执行不需要该参数），调整to的顺序保证save先执行：

from(a)
    .multicast()
    .to(save, b);

特殊场景：需保留parallelProcessing的情况

配置multicast等待所有子任务执行完成再返回：

from(a)
    .multicast()
    .parallelProcessing()
    .waitForTaskToComplete(WaitForTaskToComplete.Always)
    .to(save, b);

调整完成后即可满足需求：

• 业务路由严格按a → b → c → d的顺序串行执行
• save消息按a → b → c → d的顺序发送到ActiveMQ，结合FIFO队列特性，消费顺序与业务执行顺序完全一致。

内容的提问来源于stack exchange，提问作者Szilágyi István