WSO2 ESB，如何在迭代器/聚合器中处理超时

Question

我在WSO2 Esb上工作了几个月，现在我需要使用迭代器中介器拆分传入的消息，将每个部分发送到一个endpoint，并使用聚合中介器收集答案。类似于这样：

  <iterate expression="//element" id="ELEMENTS">
    <target>
      <sequence>
        [send to endpoint using element data]
      </sequence>
    </target>
  </iterate>
  <property name="root" scope="default">
    <root xmlns=""/>
  </property>
  <aggregate id="ELEMENTS">
    <completeCondition timeout="12">
      <messageCount max="-1" min="-1"/>
    </completeCondition>
    <onComplete enclosingElementProperty="root" expression="//resultelement">
        [rest of the flow]
    </onComplete>
  </aggregate>

它工作正常，但是，正如您所看到的，我在聚合器上定义了一个超时，这样超时中的消息就不会被“聚合”，而是会被“重定向”到故障序列。一般来说，任何发送到故障序列的消息都会“错过”聚合器，所以问题是：有什么方法可以将答案和错误聚合在一个消息中？

“B计划”基于在故障序列中创建并使用响应中介器发回的单个错误消息，它可以工作，但如果出现多个错误，我会在ESB的日志中注意到一个空指针异常，我认为这是由于多个进程试图使用响应中介器造成的。

编辑：

我是ESB新手，所以我可能有错误的想法，所以我将试着用一个例子来解释我的情况。我试图创建一个REST API，它将接收如下所示的有效负载：

{
    "items" : [
        "ID_ITEM_1",
        "ID_ITEM_2",
        "ID_ITEM_3"
    ]
}

API配置：

<?xml version="1.0" encoding="UTF-8"?>
<api context="AAA/report" name="order-request" xmlns="http://ws.apache.org/ns/synapse">
  <resource methods="POST" protocol="http">
    <inSequence>

      <iterate expression="//items" id="ITEMS">
        <target>
          <sequence>
            <property expression="json-eval($.items)" name="item"/>
            <call-template description="Get status" target="gov:/calls/GetItemStatusTemplate.xml">
              <with-param name="itemId" value="{get-property('item')}"/>
            </call-template>

            <payloadFactory media-type="json">
                <format>
                {
                    "item" : "$1",
                    "status" : "$2"
                }
                </format>
                <args>
                    <arg expression="get-property('item')"/>
                    <arg evaluator="json" expression="$.status"/>
                </args>
            </payloadFactory>

          </sequence>
        </target>
      </iterate>
      <property name="report" scope="default">
        <report xmlns=""/>
      </property>
      <aggregate id="ITEMS">
        <completeCondition timeout="12">
          <messageCount max="-1" min="-1"/>
        </completeCondition>
        <onComplete enclosingElementProperty="report" expression="//jsonObject">
          <respond/>
        </onComplete>
      </aggregate>
    </inSequence>
    <outSequence/>
    <faultSequence>
      <log level="full">
        <property name="FAULT_SEQUENCE" value="IN"/>
      </log>
      <respond/>
    </faultSequence>
  </resource>
</api>

<call>
  <endpoint>
    <address trace="disable" uri="http://something">
      <timeout>
        <duration>10000</duration>
        <responseAction>fault</responseAction>
      </timeout>
      <suspendOnFailure>
        <errorCodes>-1</errorCodes>
        <initialDuration>0</initialDuration>
        <progressionFactor>1.0</progressionFactor>
        <maximumDuration>0</maximumDuration>
      </suspendOnFailure>
      <markForSuspension>
        <errorCodes>-1</errorCodes>
      </markForSuspension>
    </address>
  </endpoint>
</call>

{
    "status" : "OK"
}

{
    "report" : [
        {
            "item" : "ID_ITEM_1",
            "status" : "OK"
        },
        {
            "item" : "ID_ITEM_2",
            "status" : "NOT VALID"
        },
        {
            "item" : "ID_ITEM_3",
            "status" : "OK"
        }
    ]

}

{
    "report" : [
        {
            "item" : "ID_ITEM_1",
            "status" : "OK"
        },
        {
            "item" : "ID_ITEM_2",
            "status" : "NOT VALID"
        }
    ]

}

{
    "report" : [
        {
            "item" : "ID_ITEM_1",
            "status" : "OK"
        },
        {
            "item" : "ID_ITEM_2",
            "status" : "NOT VALID"
        },
        {
            "item" : "ID_ITEM_3",
            "status" : "request timeout"
        }
    ]

}

或者注意到客户机在ITEM_3上出现错误的方法

Answer 1

在您的问题中，您要求在聚合中介器中处理“超时”。

• 在完成条件下用于处理聚合进程的超时。如果响应不符合超时期限，它将停止聚合进程。

将出现如下警告：

WARN - Aggregate Aggregate Mediator Time out occured.

null