基于Mockserver测试带异步副作用HTTP服务的回调实现问询

我刚好做过类似的Mockserver测试场景，针对你说的ServiceA这种带异步副作用的HTTP服务，完全可以用Mockserver的回调动作来实现需求。下面我一步步给你讲具体怎么搞：

核心思路 #

Mockserver提供了callback机制，当它匹配到符合规则的请求时，可以执行你自定义的逻辑——这正好对应你需要的“接收到请求后触发一次回调”的需求，用来模拟ServiceA触发的异步分析流程（调用ServiceB）。

具体实现步骤 #

1. 初始化Mockserver客户端 #

首先你需要创建Mockserver的客户端实例，连接到你的Mockserver服务：

MockServerClient mockServerClient = new MockServerClient("localhost", 1080);

2. 定义请求匹配规则 #

先明确哪些请求需要触发回调——也就是ServiceA中满足“特定条件”的/api/status/{id}请求。比如假设当请求带有triggerAsync=true的查询参数时触发异步流程，你可以这么写匹配规则：

HttpRequestMatcher targetRequest = request()
    .withMethod("GET")
    .withPath("/api/status/.*") // 匹配任意id的路径
    .withQueryStringParameter("triggerAsync", "true"); // 你的特定条件

3. 实现回调逻辑 #

你可以自定义一个回调类实现ExpectationCallback接口，在handle方法里写触发异步流程的逻辑（比如调用ServiceB），同时返回给ServiceA对应的状态响应：

public class AsyncServiceCallback implements ExpectationCallback {
    @Override
    public HttpResponse handle(HttpRequest httpRequest) throws Exception {
        // 1. 提取请求中的id（从路径/api/status/{id}中解析）
        String requestId = httpRequest.getPath().split("/")[3];
        
        // 2. 模拟异步调用ServiceB——这里用新开线程模拟原服务的异步行为
        new Thread(() -> {
            try {
                // 用HTTP客户端发送请求到ServiceB（如果ServiceB也是Mock的话，地址就是Mockserver的地址）
                HttpClient httpClient = HttpClient.newHttpClient();
                HttpRequest serviceBReq = HttpRequest.newBuilder()
                    .uri(URI.create("http://localhost:1080/api/analyze")) // 假设ServiceB的接口在Mockserver上
                    .POST(HttpRequest.BodyPublishers.ofString("{\"id\":\"" + requestId + "\"}"))
                    .header("Content-Type", "application/json")
                    .build();
                httpClient.send(serviceBReq, HttpResponse.BodyHandlers.discarding());
                System.out.println("异步回调已触发，调用ServiceB完成，id: " + requestId);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }).start();
        
        // 3. 返回给ServiceA的状态响应，不用等待异步流程完成
        return response()
            .withStatusCode(200)
            .withContentType(MediaType.APPLICATION_JSON)
            .withBody("{\"status\":\"processing\",\"message\":\"异步分析已启动\"}")
            .build();
    }
}

4. 绑定回调到Mockserver期望 #

把上面的匹配规则和回调逻辑绑定起来，这样Mockserver收到符合条件的请求时就会触发回调：

mockServerClient.when(targetRequest)
    .callback(new AsyncServiceCallback());

简化写法（用Lambda） #

如果不想写单独的回调类，也可以直接用Lambda表达式简化代码：

mockServerClient.when(
    request()
        .withMethod("GET")
        .withPath("/api/status/.*")
        .withQueryStringParameter("triggerAsync", "true")
)
.callback(httpRequest -> {
    String requestId = httpRequest.getPath().split("/")[3];
    // 异步执行ServiceB调用逻辑
    new Thread(() -> {
        // 这里写调用ServiceB的代码
    }).start();
    // 返回响应
    return response()
        .withStatusCode(200)
        .withBody("{\"status\":\"processing\"}")
        .build();
});

验证回调是否正确触发 #

如果你需要验证异步流程确实被触发（也就是ServiceB的调用是否发生），可以把ServiceB也用Mockserver模拟，然后用verify方法检查请求：

// 先模拟ServiceB的/api/analyze接口
mockServerClient.when(
    request()
        .withMethod("POST")
        .withPath("/api/analyze")
        .withContentType(MediaType.APPLICATION_JSON)
)
.respond(response().withStatusCode(200));

// 测试结束后，验证是否收到了预期的ServiceB请求
mockServerClient.verify(
    request()
        .withMethod("POST")
        .withPath("/api/analyze")
        .withBody("{\"id\":\"test-123\"}")
);

注意事项 #

• 异步 vs 同步：上面的例子里用了new Thread来模拟原服务的异步行为，这样Mockserver会立即返回响应给ServiceA，不会阻塞。如果不新开线程，Mockserver会等待回调逻辑执行完再返回，这和原服务的异步特性不符，所以一定要注意这一点。
• 异常处理：回调逻辑里最好加上异常捕获，避免因为调用ServiceB失败导致Mockserver返回错误给ServiceA。
• 请求匹配精度：可以根据你的实际需求细化请求匹配规则，比如匹配特定的header、请求体内容等，确保只有符合“特定条件”的请求才会触发回调。

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