Mule中如何在forEach外部访问内部变量并合并JSON payload

我来帮你拆解并解决这两个Mule开发里的常见问题：

问题1：在forEach外部访问内部声明的变量 #

Mule的forEach组件有自己的局部作用域，默认情况下，在forEach内部创建的flowVars（Mule 4+推荐用vars）只能在作用域内访问，外部是拿不到的。要突破这个限制，我们需要提前在forEach外部初始化一个集合，把每次迭代的结果存进去：

修改步骤： #

1. 在forEach执行前，先初始化一个用于收集数据的空集合：

   <set-variable variableName="collectedResults" value="#[[]]" doc:name="Initialize Result Collection"/>
   

2. 在forEach内部的Scatter-Gather之后，把当前迭代的ABC和DEF数据（可以先打包成一个对象）添加到这个外部集合中：

   <set-variable variableName="collectedResults" 
                value="#[flowVars.collectedResults ++ [{ abcData: flowVars.ABC, defData: flowVars.DEF }]]" 
                doc:name="Add Current Iteration Data to Collection"/>
   

等forEach执行完毕，flowVars.collectedResults就会包含所有迭代的结果，你可以在外部直接访问这个变量。

问题2：合并两个JSON Payload #

你现在用flowVars.ABC + flowVars.DEF是字符串拼接，这会破坏JSON的格式，导致最终的payload是无效的JSON。正确的做法是用DataWeave来处理JSON合并，根据你的需求有两种常见方式：

方式1：打包成包含两个属性的JSON对象 #

如果想把ABC和DEF作为独立属性放在同一个JSON里，用这个DataWeave表达式：

<set-payload value="#[output application/json --- { ABC: flowVars.ABC, DEF: flowVars.DEF }]" doc:name="Combine as JSON Properties"/>

方式2：深度合并两个JSON对象（处理重叠属性） #

如果ABC和DEF是结构相似的JSON，想要把它们的属性合并到一个对象中（重叠属性以后者的值为准），可以用DataWeave的merge函数：

<set-payload value="#[output application/json --- dw::core::Objects::merge(flowVars.ABC, flowVars.DEF)]" doc:name="Deep Merge JSON Objects"/>

完整修改后的示例代码 #

结合上面两点，你的Flow可以改成这样（假设你需要收集每次迭代的合并结果）：

<flow name="test">
    <!-- 初始化收集结果的空集合 -->
    <set-variable variableName="collectedResults" value="#[[]]" doc:name="Initialize Result Collection"/>
    
    <foreach doc:name="For Each">
        <scatter-gather doc:name="Scatter-Gather">
            <set-variable variableName="ABC" value="#[payload]" mimeType="application/json" doc:name="ABC"/>
            <set-variable variableName="DEF" value="#[payload]" mimeType="application/json" doc:name="DEF"/>
        </scatter-gather>
        
        <!-- 合并当前迭代的两个变量，并添加到外部集合 -->
        <set-variable variableName="collectedResults" 
                     value="#[flowVars.collectedResults ++ [{ mergedData: dw::core::Objects::merge(flowVars.ABC, flowVars.DEF) }]]" 
                     doc:name="Collect Merged Data"/>
    </foreach>
    
    <!-- 输出最终的合并结果集合 -->
    <set-payload value="#[output application/json --- flowVars.collectedResults]" doc:name="Final Payload"/>
</flow>

小提示 #

如果你使用的是Mule 4及以上版本，建议用vars代替flowVars，语法更简洁，作用域规则是完全一致的，比如vars.ABC就可以代替flowVars.ABC。

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