Rebus发送事务范围

Question

在以前(<=0.84.0)版本的Rebus中，可以在TransactionScope中发送消息，并且只有当作用域完成时才发送消息。

using (var scope = new TransactionScope())
{
    var ctx = new AmbientTransactionContext();
    sender.Send(recipient.InputQueue, msg, ctx);

    scope.Complete();
}

是否有可能在Rebus2中实现同样的行为？

Answer 1

正如您正确地发现的，Rebus版本的>= 0.90.0不会自动登记在环境事务中。

(更新:从0.99.16开始，就可以得到所需的行为-关于如何实现的详细信息，请参阅这个答案的结尾)

然而，这并不意味着Rebus不能加入事务-它只是使用它自己的环境事务机制(它不依赖于System.Transactions，并且在Rebus移植到.NET核心时是可用的)。

您可以使用Rebus‘DefaultTransactionContext，并在此AmbientRebusTransactionContext中使用“使其为环境”

/// <summary>
/// Rebus ambient transaction scope helper
/// </summary>
public class AmbientRebusTransactionContext : IDisposable
{
    readonly DefaultTransactionContext _transactionContext = new DefaultTransactionContext();

    public AmbientRebusTransactionContext()
    {
        if (AmbientTransactionContext.Current != null)
        {
            throw new InvalidOperationException("Cannot start a Rebus transaction because one was already active!");
        }

        AmbientTransactionContext.Current = _transactionContext;
    }

    public Task Complete()
    {
        return _transactionContext.Complete();
    }

    public void Dispose()
    {
        AmbientTransactionContext.Current = null;
    }
}

然后您可以像这样使用：

using(var tx = new AmbientRebusTransactionContext())
{
    await bus.Send(new Message());

    await tx.Complete();
}

或者，如果您在web应用程序中使用它，我建议您将它封装在类似于以下的OWIN中间件中：

app.Use(async (context, next) =>
{
    using (var transactionContext = new AmbientRebusTransactionContext())
    {
        await next();

        await transactionContext.Complete();
    }
});

更新:自Rebus 0.99.16以来，支持以下内容(通过Rebus.TransactionScope包)：

using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
    scope.EnlistRebus(); //< enlist Rebus in ambient .NET tx

    await _bus.SendLocal("hallå i stuen!1");

    scope.Complete();
}