-
2 votesanswersviews
针对Reactor（或Akka）解决方案的CompletableFuture解决方案
我有以下方法使用 CompletableFuture 这样： public AClass aMethod() { CompletableFuture<SomeClassA> someClassAFuture = CompletableFuture.supplyAsync(() -> someMethodThatReturnsA()); Compl... -
10 votesanswersviews
SLF4J：类路径包含多个SLF4J绑定 . 消息在控制台上打印
我想在控制台上打印日志，并将它们写在文件中 . 在我使用akka Logger 的scala项目中，这是我的 build.sbt libraryDependencies ++= Seq("org.mongodb" %% "casbah" % "2.8.0", "org.sl... -
0 votesanswersviews
将数据发送到Kerberos从scala Client启用Kafka群集
我正在写scala中的akka，Kafka Producer，我正在尝试从scala kafka客户端向kafka代理发送消息，问题是代理没有收到这些消息我通过从命令行启动kafka consumer来验证它 . Kafka的制作人和消费者在命令提示符下工作正常 . Kafka启用了Kerberos和SASL_PlainText安全性 . 请在下面找到我的conf文件，客户端代码和应用程序日志... -
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... -
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.再次命令得到验证，并且在验证期间确定不会生成任何事件（因为我们已经... -
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... -
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... -
8 votesanswersviews
Akka：两个演员之间同步状态的正确模式
在重写Akka中已弃用的 persistentView 的过程中，我有一个需要对其状态进行快照的读取actor，并且到目前为止读取了日志事件偏移量 . 要停止需要序列化复合数据结构的视图actor（状态偏移量），我将偏移值快照的责任委托给子actor . 然后问题是同步这两者之间的偏移值 . 目前在阅读演员，我有： case RecoveryCompleted ⇒ implicit val e... -
4 votesanswersviews
在Akka集群中同步数据的简单方法？
我有一些运行时数据我希望存在于我的Akka集群中每个节点上的指定actor上，可以通过内部事件或API调用更新到单个节点 . 我可以将这些数据存储在共享数据库中以使其永久化，但我宁愿将其存储在内存中以提高速度，因为它不需要持久化 . Akka Cluster Singleton，Distributed Pub Sub以及可能的其他内置模块使用八卦协议来保持分布式状态同步 . 是否有一种现成的方法... -
29 votesanswersviews
Akka中聚类和远程处理的区别
我在一个JVM上用Akka开发了我的应用程序 . 现在我想在多台机器上分配工作负载 . 我开始阅读文档并感到困惑 . 有两种方法可以通过聚类和远程处理来分发Akka应用程序 . 我没有区分这两者 . 如果我理解正确两者都相互排除，因为在配置中需要使用不同的提供者作为参与者： akka.remote.RemoteActorRefProvider akka.cluster.ClusterActorR... -
1 votesanswersviews
Akka Cluster，Cluster Sharding和Cluster singleton用例
我正在写一个Akka应用程序，我想使用Typsafe提供的Akka Cluster功能 . 我试图了解Akka Cluster，Akka Cluster Singleton和Akka Cluster Sharding之间的主要区别 . 对我来说，他们似乎在提供类似的东西 . 在我的场景中，我希望有一个群集，它将具有： 可以住在任何机器上的无国籍演员（我会有一个游泳池） 无国籍的演员，我希望... -
10 votesanswersviews
Akka cluster-sharding：Entry actor可以拥有动态道具
Akka Cluster-Sharding看起来与用例匹配得很好我必须在Akka节点上创建有状态持久性actor的单个实例 . 我不清楚是否有可能有一个Entry actor类型需要参数来构造它 . 或者我可能需要重新考虑Entry actor如何获取此信息 . Object Account { def apply(region: String, accountId: String): Pro... -
0 votesanswersviews
Akka群集分片不起作用
我在Scala 2.11.8上使用akka 2.4.7 . 事件来自extractShardId和extractEntityId，但它们没有被传播到actor的receive方法 . 有什么想法可能是什么？ https://bitbucket.org/kuzelac/apt-billing/overview分支价格碎片 定义了一个集群分片： val dailyPriceAggregateActor... -
2 votesanswersviews
Akka集群分片的Cassandra性能问题
My application: akka cluster 2.5.x; akka分片具有均匀分布的功能; cassandra插件"com.typesafe.akka" %% "akka-persistence-cassandra"（默认配置）; 专用单节点Cassandra 3.3; 我的应用程序模拟了一种支持以下操作的帐户的财务应用程序...