- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
我正在研究 Axon 框架,但在命令状态的自动持久化方面遇到了困难。
我查看了有关 command model repository 的文档根据我的理解,如果我有正确的依赖关系,标准存储库的命令模型的状态应该是自动持久化的。这种情绪也存在于另一个 blog/tutorial 中。我看过(您可能需要向下滚动到存储库部分)。
问题是,虽然我添加了 axon-mongo
依赖项,但命令状态不会自动保留。我已尝试根据文档配置相关的存储库 bean,但它似乎也没有用。我什至不确定这是否是必需的,因为(根据我对文档的理解)如果您想查询命令状态,您主要会这样做。
虽然我知道我可以创建自己的存储库并自己保存实体(类似于 this tutorial ),但我宁愿不提供开箱即用的功能。
我是不是漏掉了什么?
注意:我的 Mongo 设置似乎是正确的,因为我已经按照 documentation 设法将我的事件保存在 MongoDB 中。 .
更新
根据 Steven 的评论(以及后续评论),我决定尝试实现状态存储聚合,但是我发现了聚合的(反)序列化问题。我已将我的聚合发送给史蒂文,他已确认它足够简单,应该由 XStream 进行(反)序列化。我还尝试使用 XStream 的独立实例序列化我的聚合并且它起作用了,这让我相信这更多是 Axon 问题而不是 XStream 问题。我还尝试使用 Jackson 和 java(反)序列化器(因为它们是 Axon 提供的其他选项),我发现了类似的问题。我得出结论,这是一个 Axon 错误,我已停止尝试解决该问题。
最佳答案
从您的问题来看,您是否知道可以选择的可能的命令模型存储机制并不清楚。所以首先,就像@Mzzl 在他的评论中指出的那样,您可以从两个角度查看命令模型状态:
默认情况下,Axon Framework 将使用 EventSourcingRepository
设置您的聚合在它后面。这意味着,如果需要聚合(例如您的命令模型)来处理新命令,则聚合将通过检索已发布的所有事件流来加载。其次,它会调用所有 @EventSourcingHandler
在聚合实现上注释方法以重新创建命令模型的状态。最后,一旦处理了作为聚合事件流一部分的所有事件,该命令将提供给 @CommandHandler
。注释方法。
状态存储方法显然有点不同,因为这意味着您的整个聚合将存储在存储库中。
但请注意,只有通过 GenericJpaRepository
才支持状态存储方法。类(class)。因此,将聚合作为一个整体存储在 MongoDB 中是不是一个选项。如果您正在为您的聚合寻找事件溯源方法,事件可以来自任何 EventStore
框架涵盖的实现。因此,这意味着您可以选择 JPA、JDBC、MongoDb 和 Axon Server 作为存储事件和检索事件流以重新创建命令模型的方法。
在配置方面,有几种方法可以解决这个问题。如果你是直接使用Axon提供的Configuration API,你可以使用:
AggregateConfigurer#defaultConfiguration(Class<A>)
对于事件源方法AggregateConfigurer#jpaMappedConfiguration(Class<A>)
用于状态存储方法如果您的应用程序处于 Spring Boot 环境中,那么在事件源和状态存储之间切换会更简单一些。只需拥有 @Entity
聚合实现上的注释足以让框架注意到您希望按原样存储聚合。
希望这能对@The__Malteser 的情况有所了解!
更新
根据评论,很明显 XStreamSerializer
框架默认使用它来反序列化/序列化对象,无法以状态存储的方式序列化您的聚合实例。
根据您收到的异常,为 Cannot marshal the XStream instance in action
,我做了一些搜索/挖掘。我有一种预感 XStream
默认情况下不能简单地序列化非静态内部类。
但是,由于我们不确定您的聚合的实现是什么,因此很难推断这是否是手头的问题。您能否在这里与我们分享您的实现,以便我们更好地推断问题是否出在内部类上?
关于java - 命令状态的自动持久化 [Axon Framework],我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56680699/
我正在通读 Windows Phone 7.5 Unleashed,有很多代码看起来像这样(在页面的代码隐藏中): bool loaded; protected override void OnNav
在cgi服务器中,我这样返回 print ('Status: 201 Created') print ('Content-Type: text/html') print ('Location: htt
我正在查看 esh(easy shell)的实现,无法理解在这种情况下什么是 22 和 9 信号。理想情况下,有一个更具描述性的常量,但我找不到列表。 最佳答案 信号列表及其编号(包括您看到的这两个)
我的Oozie Hive Action 永远处于运行模式。 oozie.log文件中没有显示错误。
我正在编写一个使用 RFCOMM 通过蓝牙连接到设备的 Android 应用程序。我使用 BluetoothChat 示例作为建立连接的基础,大部分时间一切正常。 但是,有时由于出现套接字已打开的消息
我有一个云调度程序作业,它应该每小时访问我的 API 以更新一些价格。这些作业大约需要 80 秒才能运行。 这是它的作用: POST https://www.example.com/api/jobs/
我正在 Tomcat 上访问一个简单的 JSP 页面: 但是当我使用 curl 测试此页面时,我得到了 200 响应代码而不是预期的 202: $ curl -i "http://localhos
有时 JAR-RS 客户端会发送错误的语法请求正文。服务器应响应 HTTP status 400 (Bad Request) , 但它以 HTTP status 500 (Internal Serve
我正在尝试通过 response.send() 发送一个整数,但我不断收到此错误 express deprecated res.send(status): Use res.sendStatus(sta
我已经用 Excel 和 Java 做过很多次了……这次我需要用 Stata 来做,因为保存变量更方便'labels .如何将 dataset_1 重组为下面的 dataset_2? 我需要转换以下
我正在创建一个应用程序,其中的对象具有状态查找功能。为了提供一些上下文,让我们使用以下示例。 帮助台应用程序,其中创建作业并通过以下工作流程移动: 新 - 工作已创建但未分配 进行中 - 分配给工作人
我想在 Keras 中运行 LSTM 并获得输出和状态。在 TF 中有这样的事情 with tf.variable_scope("RNN"): for time_step in range
有谁知道 Scala-GWT 的当前状态 项目? 那里的主要作者 Grzegorz Kossakowski 似乎退出了这个项目,在 Spring 中从事 scalac 的工作。 但是,在 interv
我正在尝试编写一个 super 简单的 applescript 来启动 OneDrive App , 或确保打开,当机器的电源设置为插入时,将退出,或确保关闭,当电源设置为电池时。 我无法找到如何访问
目前我正在做这样的事情 link.on('click', function () { if (link.attr('href') !== $route.current.originalPath
是否可以仅通过查看用户代理来检测浏览器上是否启用/禁用 Javascript。 如果是,我应该寻找什么。如果否,检测用户浏览器是否启用/禁用 JavaScript 的最佳方法是什么 最佳答案 不,没有
Spring 和 OSGi 目前的开发状况如何? 最近好像有点安静了。 文档的最新版本 ( http://docs.spring.io/osgi/ ) 来自 2009 年。 我看到一些声明 Sprin
我正在从主函数为此类创建一个线程,但即使使用 Thread.currentThread().interrupt() 中断它,输出仍然包含“Still Here”行。 public class Writ
为了满足并发要求,我想知道如何在 Godog 中的多个步骤之间传递参数或状态。 func FeatureContext(s *godog.Suite) { // This step is ca
我有一个UIButton子类,它不使用UIImage背景,仅使用背景色。我注意到的一件事是,当您设置按钮的背景图像时,有一个默认的突出显示状态,当按下按钮时,该按钮会稍微变暗。 这是我当前的代码。
我是一名优秀的程序员,十分优秀!