Axon框架-从非聚合（eventGateway）启动saga

Question

    @Component
    @ProcessingGroup("OrderProcessor")
    public class OrderEventHandler {
        @Inject
        private EventGateway eventGateway;
        public void createOrder() {
            OrderCreatedEvent orderCreatedEvent = new OrderCreatedEvent("orderId",
                100,
                "CREATED");
            eventGateway.publish(orderCreatedEvent);
        }

@Repository
 public interface SagaViewRepository extends CassandraRepository<SagaView, String> {
}

public CassandraSagaStore sagaStoreStore() {
    return  CassandraSagaStore(...);
}

    @Saga(sagaStore = "sagaStoreStore")
    public class OrderManagementSaga {

        @Inject
        private transient CommandGateway commandGateway;

        @StartSaga
        @SagaEventHandler(associationProperty = "orderId")
        public void handle(OrderCreatedEvent orderCreatedEvent){
            //Saga invoked;
        }

中的任何提示都非常感谢，谢谢。

Answer 1

几乎在任何项目中，我都不会立即选择微服务路线。如果您采用这种方法，这意味着您将被困在基础设施工作中，比如如何将消息从一个服务发送到另一个服务，而不是提供业务功能。

这并不意味着我不会在您的应用程序中使用消息传递。正是命令、事件和查询的用法允许您将消息总线的距离更改为任意长度。

不管怎样，这更像是一个建议，而不是对你问题的回答。老实说，我不确定你在找什么。您已经声明您正在使用Cassandra（顺便说一句，Axon在任何方式都不支持）和Kafka。这使得Kafka是在服务之间发布事件的方法，对吗？例如，这就是Axon提供Kafka扩展的目的。