如何从命令侧轴上发布更多实例的事件

Question

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    <dependency>
        <groupId>org.axonframework</groupId>
        <artifactId>axon-amqp</artifactId>
        <version>${axon.version}</version>
    </dependency>
    <dependency>
        <groupId>org.axonframework</groupId>
        <artifactId>axon-spring-boot-starter</artifactId>
        <version>${axon.version}</version>
    </dependency>

    @Bean
    public Exchange exchange() {
        return ExchangeBuilder.fanoutExchange("SeatReserveEvents").build();
    }

    @Bean
    public Queue queue() {
        return QueueBuilder.durable("SeatReserveEvents").build();
    }

    @Bean
    public Binding binding() {
        return BindingBuilder.bind(queue()).to(exchange()).with("*").noargs();
    }

    @Autowired
    public void configure(AmqpAdmin admin) {
        admin.declareExchange(exchange());
        admin.declareQueue(queue());
        admin.declareBinding(binding());
    }

axon:
  amqp:
    exchange: SeatReserveEvents 

    @Bean
public SpringAMQPMessageSource statisticsQueue(Serializer serializer) {
    return new SpringAMQPMessageSource(new DefaultAMQPMessageConverter(serializer)) {
        @RabbitListener(queues = "SeatReserveEvents")
        @Override
        public void onMessage(Message arg0, Channel arg1) throws Exception {
            super.onMessage(arg0, arg1);
        }

    };
}

@Component
@ProcessingGroup("statistics")
public class EventLoggingHandler
{
    @EventHandler
    protected void on(SeatResurvationCreateEvent event) {
        System.err.println(event);
    }

    @EventHandler
    protected void on(SeatReservationUpdateEvent event) {
        System.err.println(event);
    }
}

axon:
  eventhandling:
    processors:
      statistics.source: statisticsQueue

Answer 1

我想说，这更多的是一个AMQP/RabbitMQ配置设置，而不是Axon框架特定的问题。也就是说，您希望将RabbitMQ设置为不进行循环，而是进行pub/sub，如本教程中所述。

然而，我确实有另一个，更多的Axon框架的具体反应在脑海中。如果还可以直接从存储中提取事件，为什么要立即在队列中发布事件呢？因此，在应用程序的查询端有TrackingEventProcessors，它在应用程序的命令端追加事件时从事件存储中提取事件。

这就是集成了CQRS的Axon Framework应用程序的整体版本最初的样子。因此，在命令和查询端拆分CQRS应用程序的最简单的下一步是保留接收事件的方式，而不在两者之间添加队列。但是，如果您有通过队列发布的特定需求，或者您只是更喜欢使用队列而不是让查询应用程序直接从事件存储中提取，请忽略此注释，回到RabbitMQ教程。