我正在关注 Allard ( https://github.com/abuijze/bootiful-axon ) 分享的 axon-springboot 示例。
到目前为止我的理解是:(如果我误解了一些概念,请纠正我)
事件被引发并存储在事件存储/事件总线(Mysql)中(使用 EmbeddedEventStore)。现在,事件处理器(TrackingProcessors - 在我的例子中)将从源(MySql - 对吗?)中提取事件,事件处理程序将执行业务逻辑并更新发布到 RabbitMQ 的查询存储和消息。
第一个问题是在何处、何时以及由谁将此消息发布到 RabbitMQ(由配置了消息侦听器的统计应用程序使用。)
我已经配置了 TrackingProcessor 来尝试回放功能。为了执行重播,我停止了我的处理器,删除了处理器的令牌条目,启动了处理器并重播了事件,并且我的查询存储按预期是最新的。
第二个问题是,当触发重播并更新查询存储时,我看不到任何消息发布到 RabbitMQ ......所以我的统计应用程序不同步。难道我做错了什么?
你能给些建议么?谢谢辛格