原文地址:Saga Overview
系列地址
- 聊聊MassTransit——状态机实现Saga模式(译)
- 聊聊MassTransit——Consumer Saga(译)
Introduce
编排一系列事件的能力是一个强大的功能,而MassTransit使这成为可能。
saga是由协调器管理的长期事务。saga是由事件发起的,saga编排事件,saga维护整个事务的状态。saga旨在管理分布式事务的复杂性,而不需要锁定和一致性。它们管理状态并跟踪发生部分故障时所需的任何补偿。
State Machine Sagas
MassTransit包括Automatonymous,它提供了一个强大的状态机(State Machine)语法来创建saga。在使用MassTransit时,强烈建议使用这种方法。
Consumer Sagas
MassTransit支持Comsumer Sagas,它实现一个或多个接口来消费相关的saga events。包含此支持,以便将应用程序从其他saga实现轻松移动到MassTransit。文章来源:https://www.toymoban.com/news/detail-463090.html
Definitions
Saga 定义用于指定消费者的行为,以便可以自动配置它们。定义可以由AddSaga显式添加,也可以使用任何AddSaga方法自动发现。
下面显示了一个示例传奇定义。完整的配置参考,请参见配置部分。文章来源地址https://www.toymoban.com/news/detail-463090.html
public class OrderStateDefinition :
SagaDefinition<OrderState>
{
public OrderStateDefinition()
{
// specify the message limit at the endpoint level, which influences
// the endpoint prefetch count, if supported
Endpoint(e => e.ConcurrentMessageLimit = 16);
}
protected override void ConfigureSaga(IReceiveEndpointConfigurator endpointConfigurator, ISagaConfigurator<OrderState> sagaConfigurator)
{
var partition = endpointConfigurator.CreatePartitioner(16);
sagaConfigurator.Message<SubmitOrder>(x => x.UsePartitioner(partition, m => m.Message.CorrelationId));
sagaConfigurator.Message<OrderAccepted>(x => x.UsePartitioner(partition, m => m.Message.CorrelationId));
sagaConfigurator.Message<OrderCanceled>(x => x.UsePartitioner(partition, m => m.Message.CorrelationId));
}
}
到了这里,关于聊聊MassTransit——实现Saga模式概览(译)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!