聊聊MassTransit——实现Saga模式概览(译)

聊聊,masstransit,实现,saga,模式,概览 · 浏览次数 : 65

小编点评

**Saga Overview 系列地址聊聊MassTransit——状态机实现Saga模式** **什么是 saga？** Saga 是一个协调器管理的长期事务。saga 是由事件发起的，saga 编排事件，saga维护整个事务的状态。saga 管理分布式事务的复杂性，而不需要锁定和一致性。它们管理状态并跟踪发生部分故障时所需的任何补偿。 **使用 MassTransit 创建 saga？** 强烈建议使用 State Machine SagasMassTransit 方法创建 saga。它提供了一个强大的状态机语法来创建 saga。 **Consumer SagasMassTransit 支持哪些接口？** Consumer SagasMassTransit 支持 Comsumer Sagas。它允许将应用程序从其他 saga 实现轻松移动到 MassTransit。 **如何定义 saga？** 使用 `public class OrderStateDefinition : SagaDefinition<OrderState>` 类定义 saga。 **示例配置：** ```java 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); } // ... } ``` **总结：** MassTransit 提供状态机实现 Saga 的功能，使开发人员可以轻松管理分布式事务的复杂性。

正文

原文地址：Saga Overview

系列地址

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。

Definitions

Saga 定义用于指定消费者的行为，以便可以自动配置它们。定义可以由AddSaga显式添加，也可以使用任何AddSaga方法自动发现。
下面显示了一个示例传奇定义。完整的配置参考，请参见配置部分。

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));
    }
}