在WSO2 MI的<iterate>循环中调用端点应使用哪种中介器？

我正在使用WSO2 Micro Integrator（WSO2 MI），需要在<iterate>循环内调用多个端点，目标是向从JSON负载中提取的不同API端点动态发送请求。我已配置<iterate>中介器遍历JSON数据，提取tokenEndpoint、client_id和client_secret，需要在循环内请求每个端点。现有配置代码如下：

<iterate expression="json-eval($)">
<target>
<sequence>
<log level="custom">
<property expression="json-eval($.tokenEndpoint)" name="tokenEndpoint"/>
</log>
<!-- Set Headers & Body for Token Request -->
<property name="Content-Type" scope="transport" type="STRING" value="application/x-www-form-urlencoded"/>
<property name="Accept" scope="transport" type="STRING" value="application/json"/>
<!-- Extract API Credentials -->
<property expression="json-eval($.tokenEndpoint)" name="TokenEndpoint" scope="default" type="STRING"/>
<property expression="json-eval($.client_id)" name="client_id" scope="default" type="STRING"/>
<property expression="json-eval($.client_secret)" name="client_secret" scope="default" type="STRING"/>
<payloadFactory media-type="json">
<format>{"client_id":"$1","client_secret":"$2"}</format>
<args>
<arg evaluator="json" expression="$.client_id"/>
<arg evaluator="json" expression="$.client_secret"/>
</args>
</payloadFactory>
<log level="full">
<property expression="json-eval($.body)" name="Token Request Payload"/>
</log>
<!-- Call API - Which Mediator to Use Here? -->
<call>
<endpoint>
<address uri="{TokenEndpoint}"/>
</endpoint>
</call>
</sequence>
</target>
</iterate>

请问应使用call中介器还是其他中介器？是否有更推荐的实现方案？是否需要显式定义端点，或是有更优的从JSON动态设置URL的方式？如何确保循环内每个API调用独立执行，无需等待前一个调用完成？

1. 中介器选择 #

用<call>中介器完全可行，它是WSO2 MI中同步调用外部服务的标准组件。如果不需要处理返回结果，也可以用<send>中介器——<send>本身是异步的，不会等待响应；但<call>的配置灵活性更高，后续要扩展处理响应的话更方便。

2. 优化后的实现方案 #

你的核心思路没问题，可针对细节优化：

• 减少重复提取：不用重复提取tokenEndpoint，一次提取后复用上下文属性即可；
• 修正Payload与Content-Type匹配：你设置的Content-Type是application/x-www-form-urlencoded，但当前Payload是JSON格式，会导致目标端点解析失败，需改成表单格式的Payload；
• 添加错误处理：建议在调用后加入错误捕获逻辑，避免单个调用失败阻塞整个流程。

优化后的核心代码片段：

<!-- 一次性提取所需属性 -->
<property expression="json-eval($.tokenEndpoint)" name="TokenEndpoint" scope="default" type="STRING"/>
<property expression="json-eval($.client_id)" name="client_id" scope="default" type="STRING"/>
<property expression="json-eval($.client_secret)" name="client_secret" scope="default" type="STRING"/>

<!-- 生成符合x-www-form-urlencoded格式的Payload -->
<payloadFactory media-type="xml">
<format><![CDATA[client_id=$1&client_secret=$2]]></format>
<args>
<arg evaluator="xml" expression="$ctx:client_id"/>
<arg evaluator="xml" expression="$ctx:client_secret"/>
</args>
</payloadFactory>

<!-- 动态调用端点 -->
<call>
<endpoint>
<address uri="$ctx:TokenEndpoint"/>
</endpoint>
</call>

<!-- 示例错误捕获 -->
<catch faultName="mediator:ERROR">
<log level="custom">
<property name="Error" value="Token endpoint call failed"/>
</log>
</catch>

3. 动态URL设置 #

不需要提前显式定义端点，直接在<address>中引用上下文属性即可，标准写法是$ctx:TokenEndpoint，比{TokenEndpoint}可读性更强，这是动态设置URL的最优方式。

4. 实现异步独立调用 #

默认<iterate>是同步执行的，要让每个调用独立执行不等待前一个完成：

• 在<iterate>中添加sequential="false"属性，开启并行分支；
• 搭配异步调用方式：
  • 用<send>中介器：本身就是异步，无需等待响应；
  • 用<call>的话，添加blocking="false"属性启用异步模式，但后续无法直接处理响应，若需处理响应要配合<aggregate>或回调机制。

修改后的<iterate>配置示例（用<send>实现异步）：

<iterate expression="json-eval($)" sequential="false">
<target>
<sequence>
<!-- 提取属性、生成Payload等逻辑 -->
<send>
<endpoint>
<address uri="$ctx:TokenEndpoint"/>
</endpoint>
</send>
</sequence>
</target>
</iterate>

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