在使用axon的微服务和不使用axon的微服务之间管理传奇？

Question

为了这个问题，我正在做一个项目，其中有两个微服务：

null

根据我所读到的，为了进行这种更改，我们需要做以下几点：

1. 从SimpleCommandBus->DistributedCommandBus
切换
2. 更改配置以启用分布式命令
3. 使用SpringCloud或JCloud连接微服务
4. 将AxonFramework添加到遗留InvoiceService项目并处理接收到的saga事件。

这是我们遇到麻烦的第四点：发票服务是由一个不愿意进行更改的单独团队维护的。

在这种情况下，使用消息代理而不是命令网关是否可行。例如，不要这样做：

public class OrderManagementSaga {

    private boolean paid = false;
    private boolean delivered = false;
    @Inject
    private transient CommandGateway commandGateway;

    @StartSaga
    @SagaEventHandler(associationProperty = "orderId")
    public void handle(OrderCreatedEvent event) {
        // client generated identifiers
        ShippingId shipmentId = createShipmentId();
        InvoiceId invoiceId = createInvoiceId();
        // associate the Saga with these values, before sending the commands
        SagaLifecycle.associateWith("shipmentId", shipmentId);
        SagaLifecycle.associateWith("invoiceId", invoiceId);
        // send the commands
        commandGateway.send(new PrepareShippingCommand(...));
        commandGateway.send(new CreateInvoiceCommand(...));
    }

    @SagaEventHandler(associationProperty = "shipmentId")
    public void handle(ShippingArrivedEvent event) {
        delivered = true;
        if (paid) { SagaLifecycle.end(); }
    }

    @SagaEventHandler(associationProperty = "invoiceId")
    public void handle(InvoicePaidEvent event) {
        paid = true;
        if (delivered) { SagaLifecycle.end(); }
    }

    // ...
}

我们可以这样做：

public class OrderManagementSaga {

    private boolean paid = false;
    private boolean delivered = false;
    @Inject
    private transient RabbitTemplate rabbitTemplate;

    @StartSaga
    @SagaEventHandler(associationProperty = "orderId")
    public void handle(OrderCreatedEvent event) {
        // client generated identifiers
        ShippingId shipmentId = createShipmentId();
        InvoiceId invoiceId = createInvoiceId();
        // associate the Saga with these values, before sending the commands
        SagaLifecycle.associateWith("shipmentId", shipmentId);
        SagaLifecycle.associateWith("invoiceId", invoiceId);
        // send the commands
        rabbitTemplate.convertAndSend(new PrepareShippingCommand(...));
        rabbitTemplate.convertAndSend(new CreateInvoiceCommand(...));
    }

    @SagaEventHandler(associationProperty = "shipmentId")
    public void handle(ShippingArrivedEvent event) {
        delivered = true;
        if (paid) { SagaLifecycle.end(); }
    }

    @SagaEventHandler(associationProperty = "invoiceId")
    public void handle(InvoicePaidEvent event) {
        paid = true;
        if (delivered) { SagaLifecycle.end(); }
    }

    // ...
}

在这种情况下，当我们从exchange中的InvoiceService收到消息时，我们将在事件网关或使用SpringAMQPublisher发布相应的事件。

问题：

• 这是一种有效的方法吗？
• 在轴突中有没有文件化的方法来处理这种情况？如果是这样，请提供文档或任何示例代码的链接好吗？

Answer 1

首先，您指的是支持分布式消息传递的Axon扩展，而不是完全针对您的问题定制的。尽管这确实是一个选项，但要知道，这将要求您配置几个单独的解决方案，专门用于分布式命令、事件和事件存储。为此使用统一的解决方案，如Axon Server，将确保用户不必使用三种（或更多）不同的方法来使其全部工作。相反，Axon Server附加到Axon Framework应用程序，它为您完成所有的分发和事件存储。

因此，如果要使用Axon Server，那么DistributedCommandBus和SpringAMQPpPublisher之类的东西对于实现您的目标是不必要的。

这是一个可以简化你生活的片段；当然，这绝不是必要的。让我们来讨论你的实际问题：

这是一个有效的方法吗？

我认为一个传奇以这种形式充当反腐败层是完全没有问题的。一个传奇声明它对事件做出反应并发送操作。这些操作是以命令的形式还是以另一个第三方服务的形式完全取决于您。

不过请注意，我觉得AMQP更多的是一种分布式事件的解决方案（在广播方法中），而不是发送命令（到直接处理程序）的方法。它可以根据你的需要进行变形，但我认为它对指挥调度来说是次优的，因为它需要调整。

• 传奇管理复杂的业务html" target="_blank">事务。
• 对发生的事情（事件）做出反应并发出操作（命令）。
• 这个传奇有一个时间概念。
• 传奇随着时间的推移保持状态，以便知道如何做出反应。

那是我的两分钱，希望这能帮到你！