使用 Autofac 在 WCF 服务中实现工作单元

Question

如何使用 Autofac 在 WCF 服务中实现工作单元模式？

使用 Autofac 的 wcf 集成很容易将工作单元接口的每次调用（或 Autofac 术语 LifetimeScope）的相同实例注入我的服务和存储库 - 我所追求的是一种在返回时提交工作单元更改的方法显然只有在没有任何异常的情况下才会调用 WCF 服务。

我见过Using a Custom Endpoint Behavior with WCF and Autofac，这基本上是我开始的方式，但不处理异常。

目前我拥有的是一个IOperationInvoker，它启动 Invoke 中的工作单元并仅在没有任何异常的情况下提交它。这种方法的问题是我需要在 Invoke 方法中解析我的工作单元实例，这给了我一个与使用 AutofacInstanceProvider 注入到我的服务和存储库中的实例不同的实例。

Answer 1

Bradley Boveinis 找到了解决此问题的方法。我们尚未对其进行彻底测试，但它似乎可以工作：

public class UnitOfWorkAwareOperationInvoker : IOperationInvoker
{
    private readonly IOperationInvoker _baseInvoker;

    public UnitOfWorkAwareOperationInvoker(IOperationInvoker baseInvoker)
    {
        _baseInvoker = baseInvoker;
    }

    public object[] AllocateInputs()
    {
        return _baseInvoker.AllocateInputs();
    }

    public object Invoke(object instance, object[] inputs, out object[] outputs)
    {
        var result = _baseInvoker.Invoke(instance, inputs, out outputs);
        var context = OperationContext.Current.InstanceContext.Extensions.Find<AutofacInstanceContext>();

        try
        {
            context.Resolve<IUnitOfWork>().Save();
        }
        catch (Exception ex)
        {
            var message = Message.CreateMessage(MessageVersion.Default, string.Empty);
            new ElmahErrorHandler().ProvideFault(ex, null, ref message);
            throw;
        }
        return result;
    }

    public IAsyncResult InvokeBegin(object instance, object[] inputs, AsyncCallback callback, object state)
    {
        return _baseInvoker.InvokeBegin(instance, inputs, callback, state);
    }

    public object InvokeEnd(object instance, out object[] outputs, IAsyncResult result)
    {
        return _baseInvoker.InvokeEnd(instance, out outputs, result);
    }

    public bool IsSynchronous
    {
        get { return _baseInvoker.IsSynchronous; }
    }
}

关键在下面一行：

OperationContext.Current.InstanceContext.Extensions.Find<AutofacInstanceContext>();

这会将 UoW 从环境/当前/上下文 LifetimeScope 中提取出来。