如何在Moq中用异步匹配验证HttpRequestMessage的HttpContent？

你遇到的核心问题是：Moq的ItExpr.Is表达式树不支持异步操作，导致await request.Content.ReadAsStringAsync()无法编译。下面提供两种可行的解决方案：

方案一：通过回调捕获请求后异步验证（推荐） #

这种方法先在Mock的Setup阶段捕获请求对象，之后再异步读取内容进行验证，既避开了表达式树的异步限制，也符合异步编程的最佳实践，没有同步调用异步方法的风险。

修改后的完整测试代码如下：

[TestMethod]
public async Task Example()
{
    HttpRequestMessage capturedRequest = null;
    var mockHttpMessageHandler = new Mock<HttpMessageHandler>(MockBehavior.Strict);
    
    mockHttpMessageHandler
        .Protected()
        .Setup<Task<HttpResponseMessage>>(
            "SendAsync",
            ItExpr.IsAny<HttpRequestMessage>(),
            ItExpr.IsAny<CancellationToken>()
        )
        .Callback<HttpRequestMessage, CancellationToken>((req, token) => capturedRequest = req) // 捕获请求对象
        .ReturnsAsync(new HttpResponseMessage()
        {
            StatusCode = HttpStatusCode.OK,
            Content = new StringContent(""),
        })
        .Verifiable();

    // 初始化HttpClient并关联Mock的Handler
    var httpClient = new HttpClient(mockHttpMessageHandler.Object);
    
    // 调用发送POST请求的业务组件
    await ExecuteSomeBusinessComponentThatPostsViaHttp(httpClient);   

    // 第一步：异步验证请求内容
    var actualContent = await capturedRequest.Content.ReadAsStringAsync();
    var expectedContent = JObject.FromObject(new { Result = new { Foo = "Bar" } });
    Assert.IsTrue(JToken.DeepEquals(JToken.Parse(actualContent), expectedContent));

    // 第二步：验证SendAsync方法被调用次数
    mockHttpMessageHandler.Protected().Verify(
        "SendAsync",
        Times.Once(),
        ItExpr.IsAny<HttpRequestMessage>(),
        ItExpr.IsAny<CancellationToken>());
}

方案二：同步调用异步方法（不推荐，需谨慎） #

如果一定要在ItExpr.Is的表达式内完成验证，可以用.GetAwaiter().GetResult()同步获取异步操作的结果，但这种方式可能在存在同步上下文的环境（如WPF、传统ASP.NET）中引发死锁，仅建议在无同步上下文的测试环境中使用：

[TestMethod]
public async Task Example()
{
    var mockHttpMessageHandler = new Mock<HttpMessageHandler>(MockBehavior.Strict);
    mockHttpMessageHandler
        .Protected()
        .Setup<Task<HttpResponseMessage>>(
            "SendAsync",
            ItExpr.IsAny<HttpRequestMessage>(),
            ItExpr.IsAny<CancellationToken>()
        )
        .ReturnsAsync(new HttpResponseMessage()
        {
            StatusCode = HttpStatusCode.OK,
            Content = new StringContent(""),
        })
        .Verifiable();

    var httpClient = new HttpClient(mockHttpMessageHandler.Object);
    await ExecuteSomeBusinessComponentThatPostsViaHttp(httpClient);   

    mockHttpMessageHandler.Protected().Verify(
        "SendAsync",
        Times.Once(),
        ItExpr.Is<HttpRequestMessage>(request => 
            JToken.DeepEquals(
                JToken.Parse(request.Content.ReadAsStringAsync().GetAwaiter().GetResult()),
                JObject.FromObject(new { Result = new { Foo = "Bar" } })
            )),
        ItExpr.IsAny<CancellationToken>());
}

关键说明 #

• 优先选择方案一，回调捕获的方式更安全，也更符合异步代码的设计逻辑。
• 方案二的同步调用仅作为备选，使用前需确认测试环境不存在同步上下文，避免死锁风险。

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