将eventstore与Axon Framework 3和Spring

Question

我试图实现一个简单的分布式应用程序，我想把所有的事件保存到事件存储区。出于这个原因，正如这里Axon的“文档”中所建议的那样，我想使用Mysql作为事件存储。

由于我对Spring没有太多的经验，我不知道如何让它工作。我将有两个独立的服务，一个用于命令端，一个用于查询端。由于我计划有更多的服务，我想知道如何配置它们来使用外部事件存储（不存储在任何这些服务中）。

@Bean
public org.springframework.amqp.core.Exchange exchange() {
    return ExchangeBuilder.fanoutExchange("AxonEvents").build();
}

@Bean
public Queue queue() {
    return QueueBuilder.durable("AxonEvents").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());
}

这将在本地运行的RabbitMQ实例上创建所需的队列（使用默认的用户名和密码）。

我的问题是：如何配置Axon以使用mysql作为事件存储？

Answer 1

由于参考指南目前没有具体说明这一点，我将在这里指出这一点。目前，在分发Axon应用程序或将Axon应用程序分离为（微）服务时，大致有两种方法：

1. 使用完全开放源码方法
2. 使用AxonHub/axondb

采用方法2（您可以在开发人员环境中完成），您只需运行AxonHub和AxonDb，并将它们配置到您的应用程序中。就这样，你搞定了；您可以扩展应用程序，并且所有消息都按需要进行路由。

首先，您声明您使用RabbitMQ路由命令和事件。事实上，该框架根本不允许使用RabbitMQ路由命令。请注意，分发EventMessages是一种解决方案，而不是CommandMessages。我建议在开源场景中使用JGroups或Spring Cloud路由命令（我已经添加了关于为JGroups和Spring Cloud分发CommandBus的参考指南页面的链接）。

要分发事件，可以采用三种方法：

1. 对事件使用共享数据库。
2. 使用AMQP将evens发送到不同的实例。
3. 使用Kafka将evens发送到不同的实例。

经过一番思考，我认为你的解决办法很简单。您正在使用Spring Boot，并且希望设置EventStore以使用MySQL。要让Axon设置正确的EventStorageEngine（下面用来读/写事件的infra组件），只需添加对spring-boot-starter-data-jpa的依赖关系。Axon IT的自动配置将在该场景中自动注意到类路径上有Spring数据JPA，因此将设置JPAEventStorageEngine。