-
2 votesanswersviews
Akka遥控器/工作人员断开连接并被隔离
遥控系统： 码： private final ActorRef reaper = getContext().actorOf(Props.create(Reaper.class), "reaper"); private final ActorRef router = getContext().actorOf(Props.create(Worker.class).withRoute... -
2 votesanswersviews
是akka Scheduler单身人士吗？
如果我有一个3个节点的集群，下面的代码会为每个节点创建一个调度程序或3个调度程序吗？我对文档中的上下文感到有点困惑 . system.scheduler.schedule(50.milliseconds, 5.seconds, wire[SchedulerRunnable]) 在那里，您找到了一个返回akka.actor.Scheduler实例的调度程序方法，该实例对于每个ActorSyste... -
1 votesanswersviews
Akka Persistence Query和actor分片
我正在做CQRS Akka演员应用程序的查询端 . 查询actor被设置为集群分片，并使用来自一个持久性查询流的事件填充 . 我的问题是： 如果群集分片中的一个actor重新启动如何恢复它？ 关闭整个群集分片并回复所有事件？ 使集群中的actor成为持久化actor并为查询端保存新的事件集？ 如果使用持久性查询填充的actor重新启动，如何取消当前PQ并再次启动它？ -
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 / scala -OversizedPayloadException如何handel呢？
我们在akka集群上有一个分布式应用程序 . 演员“A”向远程演员发送大尺寸的消息 . 我们收到以下警告： 2016-08-10 23：08：29,737 [EndpointWriter]错误 - 瞬态关联错误（关联保持活动）akka.remote.OversizedPayloadException：丢弃发送给Actor的超大有效负载[akka.tcp：//abcd@127.0.0.1：5166... -
2 votesanswersviews
Akka Camel多个消费者
我正在使用akka camel来消费来自activemq的消息，我正在试图弄清楚如何在多台机器上部署这个消费者，而不会重复消息 . 在这种情况下，我正在消费来自主题的消息，而activemq应该知道我在各种机器中有一个akka系统，而不是各种单独的独立系统 . 我尝试使用akka集群实现这一点，但是使用前端订阅后端集群的示例没有帮助，因为我的“后端”actor是activemq消费者本身，我不能告...