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 不会自动加入环境事务。

（更新：自 2016 年 9 月 9 日起，可以实现所需的行为 - 有关详细信息，请参阅此答案的末尾）

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

您可以将 Rebus 的 DefaultTransactionContext 和 "make it ambient" 与 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();
}

Rebus 在事务范围内发送

Rebus Send in transactionscope

servicebus

rebus