-
6 votesanswersviews
持久性的唯一性在akka-persistence中
我正在使用scala api for akka-persistence来持久化一组组织成树的actor实例 . 树中的每个节点都是持久性actor，并根据“根”节点到该节点的路径命名 . persistenceId设置为名称 . 例如，根节点actor具有persistenceId'root' . 下一个节点有persistenceId'root-europe' . 另一个演员可能有persis... -
1 votesanswersviews
如何坚持高消息率的演员状态
我想开始使用带有重率信息的演员 . 演员的最后一个状态非常重要我是按照这里显示的持久性示例http://doc.akka.io/docs/akka/2.3.9/scala/persistence.html#event-sourcing我试图发送大量的消息 for (i <-0 to 100000){ persistentActor ! Cmd("foo"+i) } ... -
1 votesanswersviews
Akka持久性测试方法
我熟悉这里定义的Akka测试方法： http://doc.akka.io/docs/akka/snapshot/scala/testing.html 我理解如何使用TestKit，TestActorRef，TestProbe等 . 我也理解我的核心域逻辑应该从Akka中提取和测试 . 我的问题是关于在Akka Persistence actor上进行TDD的策略，即PersistentActor和... -
1 votesanswersviews
PersistentFSM不会保留到日志中
我正在尝试使用下面的简单示例测试Akka 2.4的新功能 - PersistentFSM （http://doc.akka.io/docs/akka/2.4.0/scala/persistence.html#Persistent_FSM） . 此示例生成5个随机整数并将其广告到序列中 . 我希望它能够持久保存数据，并在下一次运行应用程序时继续追加现有的数字序列 . 关于 PersistentF... -
3 votesanswersviews
了解AKKA持久性以及ES和CQRS原则
我最近观看了几个关于ES和CQRS模型的视频以及我几乎没有关于AKKA持久性的讨论 . 我知道它们是什么，但我在编写将要执行的实际代码时遇到问题 . 我有几个问题 . 我应该如何进行视图和事件堆栈通信？是否会在视图和相同持久性ID的持久actor之间传递事件？什么是持久的演员和视图负责根据模型？ 编辑：我应该在哪里放置我的业务逻辑？根据模型我应该写在写，但如果我需要检查读取的东西，以验证cmd怎么... -
1 votesanswersviews
在Akka中PersistentView的典型用例是什么？
这里http://doc.akka.io/docs/akka/current/scala/persistence.html写道： PersistentView：视图是一个持久的有状态actor，它接收由另一个持久化actor编写的记录消息 . 视图本身不会记录新消息，而是仅从持久性actor的复制消息流更新内部状态 . PersistentView的典型用例是什么？ 它与Akka Stream... -
4 votesanswersviews
Kafka 作为Akka持久性期刊[暂停]
在实施事件采购的写作期刊的不同选项中，Kafka似乎是“外部”的一个非常合理的选择： 它有一个伟大的生态系统 这是有据可查的 它自然支持流媒体和听众 然而，考虑到Akka持久性，似乎Kafka期刊仅通过社区贡献的包来支持，该包在过去的两年中没有被修改过 . Kafka 不是一个好选择，是否有更好的选择，如果它是最好的选择，人们如何使用它与akka-persistance？ -
0 votesanswersviews
轻量级的普通期货或Akka
有一些用例如下 . 1） createUser API调用是通过前端进行的 . 一旦此调用成功，意味着数据成功保存到db，将成功返回到前端 . API Contract 在前端和后端之间结束 . 2）现在后端需要生成并触发 CreateUser 事件，该事件将用户创建到第三方应用程序中（为了示例，我们可以说它成功或失败 . 但是所有对此 CreateUser 事件的调用都必须记录，因为它的失败... -
4 votesanswersviews
如何测试Akka Persistence演员
我正在开发一个基于Akka Persistent FSM的项目 . 特别是： 我想知道构建独立测试用例的最佳方法是什么？由于状态更改是持久的（文档中没有很好地解释，但可以看到here），确保我的持久性actor始终处于干净状态可能很棘手 . 是否有必要手动将重置为我的actor FSM协议？如果是这样，这似乎并不理想，因为它自己进行了测试 . 在测试中管理期刊本身的最佳方法是什么？有没有一... -
1 votesanswersviews
Akka Persistence Cassandra：timestamp！= offset . 或者如何只处理一次事件？
我目前正在使用Akka Persistence和Cassandra Journal插件构建一个事件源应用程序 . 我有一些视图，需要捕获多个持久性ID的事件，因此我使用eventsByTag查询来更新（例如）我的mongodb视图 . 如果我重新启动我的应用程序，则会重放查询，因此我需要以某种方式存储视图的状态，因此它不会重放已经处理过的事件 . 起初我计划使用最后处理事件的偏移量，因为Cassa... -
0 votesanswersviews
在测试时清除Akka-persistance中的源事件
我正在编写一个具有Akka-persistance的模块，并且在单元测试中遇到了一个问题：所有事件都是在测试期间获得的，因此状态发生了变化 . 当我再次运行hte测试套件时，事件会被重放，因此演员不会以它应该具有的初始状态开始 . 原始解决方案是每次都删除本地事件存储，或者每次都更改persistenceId . 两者都太粗糙了 . 有没有办法将其纳入测试套件？ -
2 votesanswersviews
持续演员的Akka Sharding背压
是否有Akka流背压模型或使用持久演员的akka分片？ 因为我有问题，我有一个持久演员的akka分片集群 . （使用cassandra作为日志插件） .有时候应该同时创建很多演员 . （例如，当我们想要向所有用户发送广播消息时 . ）成千上万的持久性演员试图在短时间内恢复（例如3.秒）并且在重负荷下cassandra无法在一段时间内做出响应并且许多演员多次无法恢复并且永远不会再次恢复 . -
0 votesanswersviews
Akka Persistence：ReadJournal.runFold永远不会返回
我是第一次尝试Akka，更具体地说是Akka Persistence . 我最终试图实现一个小玩具程序来复制Akka在事件源应用程序中的使用 . 我已经取得了成功，直到我尝试使用 ReadJournal 将我的事件流投射到我的域中 . def main(args: Array[String]): Unit = { val commands: EmployeeCommandStream = ... -
3 votesanswersviews
需要DB调用的CQRS命令验证
在CQRS中，验证需要数据库调用的命令的最佳方法是什么？例如，我有 Order 聚合验证命令 CommitOrder 并且除非有足够的库存，否则我不想接受此命令 . 在这种情况下，命令处理程序如何检查我是否有订单商品的库存或没有？我可以从写入端查询读取端吗？ 注意：我正在使用akka来实现 -
0 votesanswersviews
akka持久化演员测试事件生成
通过CQRS命令的定义可以/应该验证并且最终甚至拒绝（如果验证没有通过） . 作为我的命令验证的一部分，我检查是否真的需要状态转换 . 因此，让我们举一个简单的虚拟示例：actor处于状态A.命令被发送到actor以转移到状态B.命令被验证并且在结束时生成事件 StateBUpdated . 然后发送完全相同的命令以转移到状态B.再次命令得到验证，并且在验证期间确定不会生成任何事件（因为我们已经... -
3 votesanswersviews
如何在CQRS中向命令发送响应？
我正在实现具有Akka持久性的CQRS系统，并且我正在尝试理解CQRS的请求响应位 . 关于如何将响应发送回客户端的问题答案很少，this article也提到了一些好的模式 . 但是，有人可以解释如何在CQRS中将响应发送回客户端，而不是使用大词进行泛化，以用于以下简单用例 . Use case 假设用户位于显示用户配置文件的页面上，该页面显示以下信息 用户名 地址 电话号码 在... -
9 votesanswersviews
使用akka-persistance进行事件采购：将状态增长为列表？
我正在使用Akka Scala设计使用CQRS事件采购的后端 . 我不确定如何应对不断增长的状态 . 例如，我将有越来越多的用户 . 据我了解，每个用户都将在UserCreated事件之后创建，这些事件将由PersistentActor重播，用户将存储在一个集合中 . 就像是： class UsersActor extends PersistentActor { override def... -
2 votesanswersviews
akka-persistence（cqrs？）的事件来源和副作用
我试图弄清楚如何使用持久性actor来模拟远程“IoT”设备的状态，例如： 用户想打开灯，这样我们才能做到最合乎逻辑 . 用户发送 OnCommand 持久化actor接收命令，生成 LightTurnedOnEvent 并将其状态更新为 on 所以这是有道理的，但这里的问题是灯光实际上从未打开过 . 好的，那么我们 Build 一个知道低级硬件控制伏都教的 LightControlA... -
0 votesanswersviews
在Akka Persistence中发生事件时生成命令
我正在实现一个处理大量原始和派生数据点的EventSourcing应用程序 . 简而言之，我们有一个 PersistentActor 作为聚合根接受命令： UpdateValue(name, value, timestamp) UpdateValue(name, value, timestamp) UpdateValue(name, value, timestamp) 验证这些命令后，它们会生成... -
1 votesanswersviews
触发其他事件的事件 - 实际上在阿卡的传奇/过程管理者
我正在构建一个使用Akka持久性的CQRS驱动系统作为辅助项目和学习练习 . 我正在寻找一些关于我如何建模的帮助 . 总之，我有一个游戏 . 纯粹的游戏机制是一个FSM（我实际上是使用PersistentFSM对此进行建模）并且我已经读取了这个持久化actor的视图，前端客户端API查询确定在客户端呈现什么 . 这很好用 . 游戏是基于单词的游戏 . 简而言之，你可以想象游戏中的每个玩家提交一些句... -
1 votesanswersviews
Akka Persistence Query和actor分片
我正在做CQRS Akka演员应用程序的查询端 . 查询actor被设置为集群分片，并使用来自一个持久性查询流的事件填充 . 我的问题是： 如果群集分片中的一个actor重新启动如何恢复它？ 关闭整个群集分片并回复所有事件？ 使集群中的actor成为持久化actor并为查询端保存新的事件集？ 如果使用持久性查询填充的actor重新启动，如何取消当前PQ并再次启动它？ -
0 votesanswersviews
是否有可能在所有演员上重播Akka Persistence Journal？
我有一个Akka Persistence Journal和几个数据库，为日志中保存的数据提供不同的视图 . 大多数视图包括多个实体（ - >多个持久性参与者） . 我知道我可以触发一个actor的恢复，这将重建仅由该实体组成的视图，但是如果我想重建所有视图，我将如何解决这个问题？ 我可以启动所有现有的演员（我需要知道所有这些演员）以触发整个系统的恢复，但是有没有办法将日志赋予演员系统并基本上... -
4 votesanswersviews
使用Akka Persistence在每个Actor的基础上指定存储插件
是否有可能提供手动实例化为持久性actor的存储插件（用于日记和快照）？ （而不是引用那些通过配置硬编码的那些 . ）换句话说，而不是override journal and snapshot plugin ids. as described by Multiple persistence plugin configurations from the manual，我想这样做： trait Act... -
2 votesanswersviews
如何以及在何处处理AkkaPersistence持久化事件以使信息对响应式UI有 Value 且有意义？
我非常熟悉 PersistentActor 和 PersistentView 在实现 Akka Persistence 时如何工作 . 根据我的理解，请考虑以下示例 . Scala案例类 Contact . case class Contact(id: String, version: Int, fName: String, lName: String, age: Int) 期刊中的Persi... -
8 votesanswersviews
Akka：两个演员之间同步状态的正确模式
在重写Akka中已弃用的 persistentView 的过程中，我有一个需要对其状态进行快照的读取actor，并且到目前为止读取了日志事件偏移量 . 要停止需要序列化复合数据结构的视图actor（状态偏移量），我将偏移值快照的责任委托给子actor . 然后问题是同步这两者之间的偏移值 . 目前在阅读演员，我有： case RecoveryCompleted ⇒ implicit val e... -
1 votesanswersviews
Akka Cluster，Cluster Sharding和Cluster singleton用例
我正在写一个Akka应用程序，我想使用Typsafe提供的Akka Cluster功能 . 我试图了解Akka Cluster，Akka Cluster Singleton和Akka Cluster Sharding之间的主要区别 . 对我来说，他们似乎在提供类似的东西 . 在我的场景中，我希望有一个群集，它将具有： 可以住在任何机器上的无国籍演员（我会有一个游泳池） 无国籍的演员，我希望... -
0 votesanswersviews
Akka群集分片不起作用
我在Scala 2.11.8上使用akka 2.4.7 . 事件来自extractShardId和extractEntityId，但它们没有被传播到actor的receive方法 . 有什么想法可能是什么？ https://bitbucket.org/kuzelac/apt-billing/overview分支价格碎片 定义了一个集群分片： val dailyPriceAggregateActor... -
1 votesanswersviews
将未来[单位]转换为Scala中的Try [Unit]
我正在尝试实现一个API方法（ AsyncWriteJournal.asyncWriteMessages - Akka 2.4的持久性API的一部分），它要求我返回 Future[Seq[Try[Unit]]] . 这个想法是可以执行许多操作，其中任何操作可以单独成功或失败，未来可以用于等待所有操作的完成 . 即使在个别运营中出现某种类型的失败，未来本身也可以成功 . 我试图将 Seq[F... -
0 votesanswersviews
如何在CQRS akka存在的写入和读取之间共享EntityModel
我正在考虑使用CQRS的Akka持久性 . 在我的写作方面，我有像这样的实体 case class Evt(data:String) 我的持久代码看起来像 persist(Evt(s"${data}")) 所有工作都在写作方面 . 我正在使用Redis journal插件 . 当我尝试读取Read端的日志条目时，它会查找WriteModel.Evt类并看到下面的错误 [ak... -
11 votesanswersviews
使用akka-persistence的CQRS Event Sourcing实现
我想使用akka-persistence事件采购功能，以便在我的新项目中实现CRQS事件采购理念 . 问题是，除了文档（http://doc.akka.io/docs/akka/snapshot/scala/persistence.html），我找不到任何好的示例或指南如何处理它 . 该文档在解释体系结构的所有构建块（如处理器，视图，通道）方面非常出色，但没有解释如何将它们组合在一起 . 所以问题...