我很乐意在调用内部处理程序的 SendAsync() 之前执行同步工作，并在内部处理程序通过完成完成后执行同步工作。例如:

protected override Task<HttpResponseMessage> SendAsync( 
    HttpRequestMessage request, CancellationToken cancellationToken) 
{ 
    // do some sync work before inner handler here 

    var sendTask = base.SendAsync(request, cancellationToken); 
    return sendTask.ContinueWith( 
        task => { // do some sync work afterwards here }); 
} 

但是，我现在需要从委托(delegate)处理程序中调用 IO 绑定(bind)操作。 IO 绑定(bind)操作已经包装为 Task<bool> .我需要使用结果来确定是否继续处理内部处理程序。

一个例子是进行网络调用以授权请求。我必须这样做才能与现有系统集成。总的来说，我认为这个问题有有效的场景，它应该有一个可行的解决方案。

在这种情况下，实现 SendAsync 的正确方法是什么，以便我异步执行 IO 绑定(bind)任务，然后继续异步执行内部处理程序？

关键是我想确定请求线程在任何时候都不会被阻塞。

最佳答案

好的，我想我已经破解了。我用一个身份验证场景来说明这一点:我想异步地对用户进行身份验证，并使用结果来决定是返回 401 还是继续消息处理程序链。

核心问题是在获得异步身份验证的结果之前，您无法调用内部处理程序 SendAsync()。

我的关键见解是使用 TaskCompletionSource (TCS) 来控制执行流程。这使我能够从 TCS 返回任务并在我喜欢的时候在其上设置结果 - 最重要的是延迟调用 SendAsync() 直到我知道我需要它。

因此，我设置了 TCS，然后开始执行授权任务。接下来，我看一下结果。如果获得授权，我将调用内部处理程序链并将延续附加到此 (避免任何线程阻塞) 以完成 TCS。如果身份验证失败，我只需在那里完成 TCS，然后返回 401。

这样做的结果是两个异步任务轮流执行，没有任何线程阻塞。我对此进行了负载测试，它似乎工作正常。

不过在 .NET 4.5 中使用 async/await 语法要好得多...虽然 TCS 的方法基本上仍在幕后进行，但代码要简单得多。

尽情享受吧!

第一个片段是在 .NET 4.0 上构建的，带有 Web API Beta - 第二个片段是在 .NET 4.5/Web API RC 上构建的。

protected override Task<HttpResponseMessage> SendAsync(
    HttpRequestMessage request, CancellationToken cancellationToken)
{
    var taskCompletionSource = new TaskCompletionSource<HttpResponseMessage>();

    // Authorize() returns a started
    // task that authenticates the user
    // if the result is false we should
    // return a 401 immediately
    // otherwise we can invoke the inner handler
    Task<bool> authenticationTask = Authorize(request);

    // attach a continuation...
    authenticationTask.ContinueWith(_ =>
    {
        if (authenticationTask.Result)
        {
            // authentication succeeded
            // so start the inner handler chain
            // and write the result to the
            // task completion source when done
            base.SendAsync(request, cancellationToken)
                .ContinueWith(t => taskCompletionSource.SetResult(t.Result));
        }
        else
        {
            // authentication failed
            // so complete the TCS immediately
            taskCompletionSource.SetResult(
                new HttpResponseMessage(HttpStatusCode.Unauthorized));
        }
    });

    return taskCompletionSource.Task;
}

这是一个 .NET 4.5/Web API 候选版本，它使用新的 async/await 语法更加性感:

protected override async Task<HttpResponseMessage> SendAsync(
    HttpRequestMessage request, CancellationToken cancellationToken)
{
    // Authorize still has a Task<bool> return type
    // but await allows this nicer inline syntax
    var authorized = await Authorize(request);

    if (!authorized)
    {
        return new HttpResponseMessage(HttpStatusCode.Unauthorized)
        {
            Content = new StringContent("Unauthorized.")
        };
    }

    return await base.SendAsync(request, cancellationToken);
}

关于c# - DelegatingHandler 应该如何进行异步调用(ASP.NET MVC Web API)？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/11035663/