问题标签 [axon]

我正在关注 Allard ( https://github.com/abuijze/bootiful-axon ) 分享的 axon-springboot 示例。

到目前为止我的理解是：（如果我误解了一些概念，请纠正我）

事件被引发并存储在事件存储/事件总线（Mysql）中（使用 EmbeddedEventStore）。现在，事件处理器（TrackingProcessors - 在我的例子中）将从源（MySql - 对吗？）中提取事件，事件处理程序将执行业务逻辑并更新发布到 RabbitMQ 的查询存储和消息。

第一个问题是在何处、何时以及由谁将此消息发布到 RabbitMQ（由配置了消息侦听器的统计应用程序使用。）

我已经配置了 TrackingProcessor 来尝试回放功能。为了执行重播，我停止了我的处理器，删除了处理器的令牌条目，启动了处理器并重播了事件，并且我的查询存储按预期是最新的。

第二个问题是，当触发重播并更新查询存储时，我看不到任何消息发布到 RabbitMQ ......所以我的统计应用程序不同步。难道我做错了什么？

你能给些建议么？谢谢辛格

我尝试使用 axon 配置cqrs和事件源。 SeatReseveCreateCommand工作正常。但SeatReserveUpadateCommand无法正常工作。

这是我的 SeatReserve汇总

这是我的控制器

我尝试使用邮递员发送请求

这是我的创建请求

这是我的更新请求

更新使这个错误

我该如何解决这个问题。

在AXON有什么用@AnnotationDriven，我们在AXON 3.1中还有这个注解吗？

import org.axonframework.contextsupport.spring.AnnotationDriven;

我正在研究迁移，这个特定的库显示错误，3.1其中很好2.4

我是 axon 的新手，正在从 Axon 2.4.3 迁移到 3.1.1，但我找不到任何可用于其他版本的迁移指南？您能否分享您的经验如何做同样的事情。我面临很多问题，一些类已被删除，一些包已被更改。对于某些课程，我什至无法找到替代品，所以请帮助我提出一些建议。如果有相同的指南，请向我提供该链接。

提前致谢

实际上，我无法找到轴突 2.4.3 ClusteringEventBus- DefaultClusterSelector- EventBusTerminal- SimpleCluster- SpringAMQPTerminal- SpringAMQPConsumerConfiguration- ListenerContainerLifecycleManager- 中的替代品

我将使用 axon 制作 cqrs 应用程序。我尝试将 axon RabbitMq 配置到我的应用程序中。如果添加 spring-boot-starter-amqp 和 axon-amqp 则会出现此错误。我该如何解决这个问题。

这是我的 pom.xml 文件。

我使用 docker 实例作为我的 rabbitmq 代理。在构建这个之前是否需要任何配置。

我尝试使用 cqrs 实现应用程序，并使用 axon 框架实现事件源。我将命令端和查询部分实现为单独的微服务并复制（扩展）查询微服务。我使用消息代理作为 RabbitMq。如果命令部分发布事件不更新所有查询微服务。它以循环方式工作。如何同时更新所有微服务。

这是我的依赖文件

这是我在命令端的配置

这是 application.yml

这是命令端配置

这是处理程序

这是 application.yml

Axon 框架支持分发事件，这应该允许将事件发布到外部消息中断并从消息代理读取事件。

亚马逊提供两种不同的消息服务

1. 亚马逊简单队列服务 (SQS)
2. 亚马逊 MQ

问题：

1. 哪种 Amazon 消息服务（SQS、MQ 或两者兼有）可以用作 Axon 框架的消息队列？
2. 在 Amazon EC2 云中实施分布式 Axon 消息处理的最佳实践是什么？

看起来 Amazon MQ 应该与 Axon Framework 作为消息队列一起正常工作，因为它支持 AMQP。但是我没有找到任何关于将 MQ 与 Axon 结合使用的实际经验的参考资料。

我正在使用 axon 3.1.1，在将事件存储到 mongodb 时，
我能够以 XML 格式存储它。
但是在使用杰克逊序列化程序将其转换为 JSON 格式时，我无法获得存储策略。

我在这里做的是
@Bean
public EventStorageEngine mongoEventStorageEngine() {
return new
MongoEventStorageEngine(axonJsonSerializer(),NoOpEventUpcaster.INSTANCE, aggregateMongoTemplate(),[strategy??]);
}

另外请分享如果我不想要任何存储策略并保留此默认值怎么办

提前致谢

我正在做的是我试图从存储库中获取聚合，然后处理该特定事件并将其标记为新事件......以便查询识别它是一个更新事件。但问题是我无法获得那个特定的聚合。

我所做的是在这里：

我在 2.4.3 中使用了这段代码，它正在返回 aCustomerAggregate但现在它正在返回 a LockAwareAggregate。你能建议我哪里出错了。

您能否也分享
UnitOfWork work = DefaultUnitOfWork.startAndGet(message??);

提前致谢。

我正在使用 Axon 3.1.1 并想知道，
如何在我的配置文件中获取事件处理器列表，
我浏览了 springAmQPmessageSource 文件，但仍然不确定如何准确地做到这一点。
这样我就可以将我的事件传递给查询端的适当事件处理程序。

更新
我正在从 kafka 主题中检索消息，并希望将它们连接到特定的事件处理程序，但由于我无法获得偶数处理器，我无法做到这一点。如果我使用的是 Axon 3.0.5，你能告诉我怎么做吗