Использование RebusTransactionScope - PullRequest
Новая
       22

Использование RebusTransactionScope

1 голос
/ 23 апреля 2020

Мне нужно уточнить использование областей транзакций в Rebus. В опциях конфигурации у меня есть o.HandleMessagesInsideTransactionScope (); Теперь нужно ли мне использовать утверждение с помощью scope = new RebusTransactionScope () в моих обработчиках, или выполненных настроек достаточно. В моем обработчике я выполняю транзакцию базы данных, а затем отправляю сообщения другим обработчикам для дальнейшей обработки. Мне нужно, чтобы вся обработка в хандере была атомарной c и, следовательно, заключалась в область транзакции.

Мне просто нужно знать правильный подход для достижения этой цели. С уважением Амур Рашид.

1 Ответ

0 голосов
/ 23 апреля 2020

Вы путаете два типа областей транзакций: Rebus имеет свою собственную область транзакций, которую вы можете использовать следующим образом: 

using (var scope = new RebusTransactionScope())
{
    await bus.Send(oneMessage);
    await bus.Send(anotherMessage);

    // no messages have been sent at this point
    //
    // 
    // but when we do this ? they will be sent
    await scope.CompleteAsync();
}

Когда вы находитесь в обработчике Rebus, нет необходимости используйте RebusTransactionScope, потому что обработчик будет иметь свою собственную область транзакции, которая завершается после того, как ваш код завершил выполнение без каких-либо исключений.

Другая область транзакции является частью. NET. Это то, что вы включаете, когда вызываете 

Configure.With(...)
    .(...)
    .Options(o => o.HandleMessagesInsideTransactionScope())
    .(...)

, что приведет к выполнению обработчиков Rebus внутри System.Transactions.TransactionScope.

(...) Мне нужна вся обработка в Стремитесь быть атомом c (...)

К сожалению, это никогда не может быть атомом c*, потому что система очередей и ваша база данных не могут быть зачислены в одну транзакцию. Я имею в виду, что они могут ПРОДОЛЖИТЬ быть, подняв вашу транзакцию до РАСПРЕДЕЛЕННОЙ СДЕЛКИ, используя протокол двухфазной фиксации для организации фиксаций, но, к сожалению, распределенные транзакции медленны и сопровождаются кучей проблем.

Обычно Так как Rebus обеспечивает «хотя бы раз доставку» сообщений, вам лучше убедиться, что ваш код идемпотентен.

(*), по крайней мере, в общем, он не может

...