WSO2 EI 6.4.0/6.5.0中Iterator外部代码重复执行问题求助

问题原因 #

WSO2的Iterator mediator 默认会在同一个主消息上下文中启动迭代流程，但如果迭代内部使用了Send/Call这类会触发完整消息流转（包括In/OutSequence切换）的组件，会导致主上下文的后续逻辑（比如Iterator外的日志、全局OutSequence）被重复触发。

本质是：每次迭代时，内部的Send/Call会让消息上下文的流转路径被重置，连带触发主流程中Iterator之后的所有步骤，而不是仅执行迭代内的逻辑。你设置的sequential=true/continueParent=true只是控制迭代的执行顺序，无法隔离主上下文和迭代子上下文的流转。

解决办法 #

1. 用Clone Mediator 隔离主流程与迭代流程 #

把Iterator放在Clone mediator的Target中，通过continueParent=false让主流程和迭代子流程完全隔离，主流程的后续逻辑（比如日志）只会在Clone执行完成后跑一次，迭代的子流程单独处理每条数据，不会干扰主流程。

示例配置：

<!-- 主流程：拉取BigQuery数据后，用Clone包裹Iterator -->
<Clone continueParent="false" sequential="true">
    <Target>
        <!-- 遍历BigQuery返回的元素 -->
        <Iterate expression="//your-bigquery-result-row" sequential="true" preservePayload="false">
            <Target>
                <!-- 迭代内逻辑：修改负载 -->
                <PayloadFactory media-type="json">
                    <Format>{"data": "$1"}</Format>
                    <Args>
                        <Arg evaluator="xml" expression="//row/data"/>
                    </Args>
                </PayloadFactory>
                <!-- 发送到目标端点，阻塞式调用避免上下文泄漏 -->
                <Send blocking="true">
                    <Endpoint key="target-endpoint"/>
                </Send>
                <!-- 终止子上下文，防止触发主流程OutSequence -->
                <Drop/>
            </Target>
        </Iterate>
    </Target>
</Clone>

<!-- 这里的日志只会执行一次，不会随迭代重复 -->
<Log level="custom">
    <property name="MAIN_FLOW" value="所有迭代任务已完成"/>
</Log>

2. 迭代内使用Drop Mediator 终止子上下文 #

如果不想用Clone，就在Iterator的Target流程最后添加Drop mediator，强制终止当前迭代的子消息上下文，避免它流转回主流程触发OutSequence或后续逻辑。同时给Send设置blocking="true"，确保同步完成后再终止上下文。

3. 调整主流程逻辑位置 #

确保Iterator（或包裹它的Clone）放在主流程所有一次性逻辑（比如日志）的前面，这样主流程的一次性逻辑会在所有迭代完成后才执行，不会被迭代流程重复触发。

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