5

我开始使用 ninject 拦截器来包装我的一些具有各种行为的异步代码，并且在让一切正常工作时遇到了一些麻烦。

这是我正在使用的拦截器：

public class MyInterceptor : IInterceptor
{
    public async void Intercept(IInvocation invocation)
    {
        try
        {
            invocation.Proceed();
            //check that method indeed returns Task
            await (Task) invocation.ReturnValue;
            RecordSuccess();
        }
        catch (Exception)
        {
            RecordError();
            invocation.ReturnValue = _defaultValue;
            throw;
        }
    }

在大多数正常情况下，这似乎运行正常。我不确定这是否会达到我的预期。尽管它似乎将控制流异步返回给调用者，但我仍然有点担心代理无意中阻塞线程或其他东西的可能性。

除此之外，我无法让异常处理正常工作。对于这个测试用例：

[Test]
public void ExceptionThrown()
{
    try
    {
        var interceptor = new MyInterceptor(DefaultValue);
        var invocation = new Mock<IInvocation>();
        invocation.Setup(x => x.Proceed()).Throws<InvalidOperationException>();
        interceptor.Intercept(invocation.Object);
    }
    catch (Exception e)
    {

    }
}

我可以在拦截器中看到 catch 块被击中，但我的测试中的 catch 块从未被重新抛出。我更困惑，因为这里没有代理或任何东西，只有非常简单的模拟和对象。我也在Task.Run(() => interceptor.Intercept(invocation.Object)).Wait();我的测试中尝试过类似的东西，但仍然没有改变。测试顺利通过，但 nUnit 输出确实有异常消息。

我想我把事情搞砸了，而且我并不像我想的那样完全理解发生了什么。有没有更好的方法来拦截异步方法？我在异常处理方面做错了什么？

4

1 回答 1

10

我建议您阅读我的async/ awaitintro，如果您还没有这样做的话。您需要非常了解async方法与返回Task的方法之间的关系，以便拦截它们。

考虑您当前的Intercept实现。正如 svick 评论的那样，最好避免async void. 一个原因是错误处理不寻常：方法的任何异常都直接async void在当前引发。SynchronizationContext

在您的情况下，如果该Proceed方法引发异常（就像您的模拟那样），那么您的async void Intercept实现将引发异常，该异常将直接发送到SynchronizationContext(这是默认值或线程池 -SynchronizationContext因为这是一个单元测试，如我在我的博客上解释）。因此，您将看到在某个随机线程池线程上引发的异常，而不是在单元测试的上下文中。

要解决此问题，您必须重新考虑Intercept. 常规拦截只允许你拦截方法的第一部分async；要响应方法的结果，async您需要在返回Task完成时做出响应。

这是一个仅捕获返回的简单示例Task：

public class MyInterceptor : IInterceptor
{
    public Task Result { get; private set; }

    public void Intercept(IInvocation invocation)
    {
        try
        {
            invocation.Proceed();
            Result = (Task)invocation.ReturnValue;
        }
        catch (Exception ex)
        {
            var tcs = new TaskCompletionSource<object>();
            tcs.SetException(ex);
            Result = tcs.Task;
            throw;
        }
    }
}

您可能还想运行NUnit 2.6.2 或更高版本，它增加了对async单元测试的支持。这将使您能够await（MyInterceptor.Result这将在单元测试上下文中正确引发异常）。

如果你想要更复杂的异步拦截，你可以使用async- just not async void。;)

// Assumes the method returns a plain Task
public class MyInterceptor : IInterceptor
{
    private static async Task InterceptAsync(Task originalTask)
    {
        // Await for the original task to complete
        await originalTask;

        // asynchronous post-execution
        await Task.Delay(100);
    }

    public void Intercept(IInvocation invocation)
    {
        // synchronous pre-execution can go here
        invocation.Proceed();
        invocation.ReturnValue = InterceptAsync((Task)invocation.ReturnValue);
    }
}

不幸的是，拦截必须同步进行，因此不可能进行异步预执行（除非您同步等待它完成，或者使用IChangeProxyTarget）。但是，即使有这个限制，您也应该能够使用上述技术做几乎任何您需要的事情。

于 2012-11-30T04:36:57.663 回答