模拟外部 REST API 调用时 MUnit 测试失败

MUnit test fails when mocking external REST API call

我有以下 Mule 流,它被构建为从外部 API 检索一些细节,然后将其映射到一些有效载荷,再到 return 到调用客户端:

<flow name="get:/clients/{clientId}:api-config">
<http:request config-ref="HTTPS_Request_Configuration" path="/api/clients/{clientId}" method="GET" host="host.com" port="443" doc:name="Find Client by ID">
    <http:request-builder>
        <http:uri-param paramName="clientId" value="#[flowVars['clientId']]"/>
    </http:request-builder>
    <http:success-status-code-validator values="0..599"/>
</http:request>
<logger message="#[payload]" level="INFO" doc:name="Logger"/>
...

我创建了以下单元测试,其中我使用 MUnit mock 处理器模拟 HTTP 请求:

<munit:test name="get:/clients/{clientId}:api-config-200-application/json-FlowTest" description="Verifying functionality of [get:/clients/{clientId}:api-config-200-application/json]">
<mock:when messageProcessor=".*:.*" doc:name="Mock">
    <mock:with-attributes>
        <mock:with-attribute name="doc:name" whereValue="#['Find Client by ID']"/>
    </mock:with-attributes>
    <mock:then-return payload="#[getResource('sample-client.json').asStream()]" mimeType="application/json"/>
</mock:when>
<set-variable variableName="clientId" value="#['null']" doc:name="clientId"/>
<http:request config-ref="HTTP_Request_Configuration" path="/clients/#[flowVars['clientId']]" method="GET" doc:name="HTTP"/>
<object-to-string-transformer doc:name="http response to string"/>
<munit:assert-true message="The HTTP Status code is not correct!" condition="#[messageInboundProperty('http.status').is(eq(200))]" doc:name="assert that - http.status eq 200"/>
<munit:assert-on-equals message="The response payload is not correct!" expectedValue="..."/>

我在尝试 运行 此测试时遇到异常错误。似乎测试由于 HTTP 超时而失败。我不明白当 HTTP 请求处理器被模拟时这怎么可能,因此不应该进行外部调用?

我看到的错误信息如下:

ERROR 2016-02-19 12:25:59,359 [main] org.mule.exception.DefaultMessagingExceptionStrategy: 
********************************************************************************
Message               : Error sending HTTP request. Message payload is of type: String
Code                  : MULE_ERROR--2
--------------------------------------------------------------------------------
Exception stack is:
1. Timeout exceeded (java.util.concurrent.TimeoutException)
  com.ning.http.client.providers.grizzly.GrizzlyAsyncHttpProvider:426 (null)
2. Error sending HTTP request. Message payload is of type: String (org.mule.api.MessagingException)
  org.mule.module.http.internal.request.DefaultHttpRequester:287 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html)
--------------------------------------------------------------------------------
Root Exception stack trace:
java.util.concurrent.TimeoutException: Timeout exceeded
    at com.ning.http.client.providers.grizzly.GrizzlyAsyncHttpProvider.timeout(GrizzlyAsyncHttpProvider.java:426)
    at com.ning.http.client.providers.grizzly.GrizzlyAsyncHttpProvider.onTimeout(GrizzlyAsyncHttpProvider.java:274)
    at org.glassfish.grizzly.utils.IdleTimeoutFilter$DefaultWorker.doWork(IdleTimeoutFilter.java:398)
    + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************

在你的测试中,你为什么要在这里调用 http:endpoint <http:request config-ref="HTTP_Request_Configuration" path="/clients/#[flowVars['clientId']]" method="GET" doc:name="HTTP"/>

此外,我没有看到 <flow-ref...> 调用来调用您正在测试的实际流程。

编辑:

基本测试结构可能遵循以下框架:

     <munit:config name="munit" doc:name="MUnit configuration"/>
        <spring:beans>
            <spring:import resource="classpath:munit-test.xml"/>
        </spring:beans>
        <munit:test name="new-test-suite-get:/clients/{clientId}:api-configTest" description="Test">

         <mock:when messageProcessor=".*:.*" doc:name="Mock">
                <mock:with-attributes>
                    <mock:with-attribute name="doc:name"
                        whereValue="#['Find Client by ID']" />
                </mock:with-attributes>
                <mock:then-return payload="#[getResource('sample-client.json').asStream()]"
                    mimeType="application/json" />
            </mock:when> 
            <set-variable variableName="clientId" value="#['null']"
                doc:name="clientId" />
<!-- Below will make an actual call to the flow -->
            <flow-ref name="get:/clients/{clientId}:api-config" doc:name="Flow-ref to get:/clients/{clientId}:api-config"/>
        </munit:test>