병렬 발신 전화 걸기 방법

Question

나의 사용 사례는 smne 데이터로 입력을 풍부하게하고 아웃 바운드 엔드 포인트로 보내야합니다.

풍부한 데이터는 두 개의 웹 서비스를 호출 한 다음 응답에서 데이터를 추출하여 얻습니다. 이 추출 된 데이터는 입력 XML로 확장되어 아웃 바운드 엔드 포인트로 보내집니다.

내가해야하는 두 가지 웹 서비스 호출은 다른 것에 대한 종속성이 없으므로 병렬이어야합니다. 이렇게하면 처리 시간을 절약 할 수 있습니다.

이 병렬 처리를 Mule의 플로우에서 어떻게 구현할 수 있는지 제안 해주십시오.

참고 : 모든 흐름 제어를 사용해 보았지만 웹 서비스 (하위 흐름)를 순차적으로 호출하는 것 같습니다.

내 추상 흐름은 다음과 같습니다.

<flow name="mainFlow"> 
    <inbound-endpoint> ..... 

    <some validation> 

    <setting some flow variables> 

    <!-- Now make calls to the sub-flows which has some processing of the input and make some web-service calls --> 
    <all> 
     <flow-ref name="myFlow1" /> 
     <flow-ref name="myFlow2" /> 
     <flow-ref name="myFlow3" /> 
    </all> 

    <enrich the input with the data obtained from the output of the above three flows> 

    <outbound-endpoint> 
</flow> 



<flow name="myFlow1"> 
    <some transformer to transform the payload provided > 

    < the tran sformed payload is passed as input to the web-service call> 

    <http:outbound-endpoint ...> 

    <transform the reply from the web-service call> 
</flow> 



<flow name="myFlow2"> 
    <some transformer to transform the payload provided > 

    < the tran sformed payload is passed as input to the web-service call> 

    <http:outbound-endpoint ...> 

    <transform the reply from the web-service call> 
</flow> 



<flow name="myFlow3"> 
    <some transformer to transform the payload provided to it> 

    < the tran sformed payload is passed as input to the web-service call> 

    <http:outbound-endpoint ...> 

    <transform the reply from the web-service call> 
</flow> 

Answer 1

다음은 두 개의 HTTP 아웃 바운드 끝점을 사용하여 포크/조인을 만드는 한 가지 방법을 보여주는 간단한 구성입니다. 세 번째 끝점을 추가하려면 MULE_CORRELATION_GROUP_SIZE을 3으로 설정하고 MULE_CORRELATION_SEQUENCE을 세 번째 async flow-ref에서 3으로 설정하십시오.

<flow name="fork"> 
    <vm:inbound-endpoint path="fork.in" /> 
    <set-property propertyName="MULE_CORRELATION_GROUP_SIZE" 
     value="2" /> 
    <all enableCorrelation="IF_NOT_SET"> 
     <async> 
      <set-property propertyName="MULE_CORRELATION_SEQUENCE" 
       value="1" /> 
      <flow-ref name="parallel1" /> 
     </async> 
     <async> 
      <set-property propertyName="MULE_CORRELATION_SEQUENCE" 
       value="2" /> 
      <flow-ref name="parallel2" /> 
     </async> 
    </all> 
</flow> 

<sub-flow name="parallel1"> 
    <logger level="INFO" message="parallel1: processing started" /> 
    <http:outbound-endpoint address="..." 
     exchange-pattern="request-response" /> 
    <logger level="INFO" message="parallel1: processing finished" /> 
    <flow-ref name="join" /> 
</sub-flow> 

<sub-flow name="parallel2"> 
    <logger level="INFO" message="parallel2: processing started" /> 
    <http:outbound-endpoint address="..." 
     exchange-pattern="request-response" /> 
    <logger level="INFO" message="parallel2: processing finished" /> 
    <flow-ref name="join" /> 
</sub-flow> 

<sub-flow name="join"> 
    <collection-aggregator timeout="6000" 
     failOnTimeout="true" /> 
    <combine-collections-transformer /> 
    <logger level="INFO" 
     message="Continuing processing of: #[message.payloadAs(java.lang.String)]" /> 
</sub-flow> 

편집 : 위의 구성에서 수집기는 6 초 후에 시간 초과됩니다. 이는 실제 사용 사례에 비해 너무 짧을 수 있습니다. 또한 아웃 바운드 HTTP 엔드 포인트 상호 작용이 모두 성공하지 못했을 때 원하는 동작이 아닐 수 있으므로 타임 아웃이 실패로 설정됩니다. 사용 사례를 기반으로 결정하는 것은 사용자의 몫입니다.