柑橘httpserver＆amp; httpclient测试

Question

我正在根据HTTP请求使用柑橘进行集成测试。 该测试应执行以下步骤：

1. 将http后请求发送给外部服务，以回调URL作为身体属性 前任： {...“回调”：“ http：// url-to-be-be-be-call'...}
2. 等待

我使用柑橘httpclient的外部服务的3个顺序HTTP请求发送邮政请求，柑橘httpserver为了解释该服务将使用回调URL调用的端点。 因此，

• httpclient-＆gt;发送邮寄到Ext Service
• ＆lt; - Ext Service响应确定
• （几分钟后）
• ＆lt; - Ext Service调用HTTPSERVER API
• HTTPCLEINT - ＆GT;响应确定
• （几分钟后）
• ＆lt; - Ext Service调用httpserver api
• httpclient-＆gt;响应确定
• （几分钟后）
• ＆lt; - Ext Service调用httpserver api
• httpclient-＆gt;响应好的，

我的测试代码是

parallel().actions(
        sequential().actions(
                // wait for callback
                http(httpActionBuilder -> httpActionBuilder
                        .server(httpServer)
                        .receive()
                        .post("/api/callback")
                        .contentType("application/json;charset=UTF-8")
                        .accept("text/plain,application/json,application/*+json,*/*")
                ),
                // callback response
                http(httpActionBuilder -> httpActionBuilder
                        .server(httpServer)
                        .send()
                        .response(HttpStatus.OK)
                        .contentType("application/json")
                )),
                sequential().actions(
                        
                        http(httpActionBuilder -> httpActionBuilder
                                .client(httpClient)
                                .send()
                                .post("/externalapi)
                                .payload("{" +
                                        "\"ret\": \"OK\"" +
                                        "}")
                                .messageType(MessageType.JSON)
                                .contentType(ContentType.APPLICATION_JSON.getMimeType())
                        ),
                        
                        http(httpActionBuilder -> httpActionBuilder
                                .client(httpClient)
                                .receive()
                                .response(HttpStatus.OK)
                                .messageType(MessageType.JSON)
                                        .payload("{" +
                                                "\"ret\": \"OK\"" +
                                                "}")
                        )
                )
        );

我的配置

@Bean
public HttpClient httpClient() {
    return CitrusEndpoints
            .http()
            .client()
            .requestUrl("http://localhost:8282")
            .build();
}

@Bean
public HttpServer httpServer() throws Exception {
    return CitrusEndpoints.http()
            .server()
            .port(8080)
            .endpointAdapter(dispatchingEndpointAdapter())
            .timeout(300000)
            .autoStart(true)
            .build();
}

@Bean
public RequestDispatchingEndpointAdapter dispatchingEndpointAdapter() {
    RequestDispatchingEndpointAdapter dispatchingEndpointAdapter = new RequestDispatchingEndpointAdapter();
    dispatchingEndpointAdapter.setMappingKeyExtractor(mappingKeyExtractor());
    dispatchingEndpointAdapter.setMappingStrategy(mappingStrategy());
    return dispatchingEndpointAdapter;
}

@Bean
public HeaderMappingKeyExtractor mappingKeyExtractor() {
    HeaderMappingKeyExtractor mappingKeyExtractor = new HeaderMappingKeyExtractor();
    mappingKeyExtractor.setHeaderName(HttpMessageHeaders.HTTP_REQUEST_URI);
    return mappingKeyExtractor;
}

@Bean
public SimpleMappingStrategy mappingStrategy() {
    SimpleMappingStrategy mappingStrategy = new SimpleMappingStrategy();

    Map<String, EndpointAdapter> mappings = new HashMap<>();

    mappings.put("/api/callback", callbackResponseAdapter());

    mappingStrategy.setAdapterMappings(mappings);
    return mappingStrategy;
}

@Bean
public EndpointAdapter callbackResponseAdapter() {
    StaticResponseEndpointAdapter endpointAdapter = new StaticResponseEndpointAdapter();
    endpointAdapter.setMessagePayload("{" +
            "\"ret\": \"OK\"," +
            "}");
    return endpointAdapter;
}

httpclient步骤工作正常，但是当我添加httpserver时，我会得到此错误

com.consol.citrus.exceptions.TestCaseFailedException: Unable to create endpoint for static endpoint adapter type 'class com.consol.citrus.endpoint.adapter.RequestDispatchingEndpointAdapter'

Answer 1

在您的HTTP-Server配置中，您正在使用静态请求调度程序和基于测试操作的动态响应生成。这是无效的。

请一次只选择一种方法。要么完全删除请求调度程序配置，要么不尝试通过接收/发送操作在测试中接收传入请求。

顺便说一句，您使用的并行序列块可能不需要。您可以在第一个客户端请求上使用fork = true选项，然后顺序等待HTTP请求到达。这应该会大大简化测试。