在Akka actor中,如何找到群集的节点?即,本地节点认为当前可访问的节点。
谢谢-丹尼尔
您实际上不需要订阅ClusterDomainEvent
或MemberEvent
。您可以只访问state
集群扩展的成员,例如,
val cluster = akka.cluster.Cluster(context.system)
val members = cluster.state.members.filter(_.status == MemberStatus.Up)
我想在我的集群中有一个调度器,它会在一段时间后发送一些消息。从我看到的调度器是每个actorsystem,从我的测试只针对本地actor系统。不是集群那一个。因此,如果在一个节点上调度某个任务,如果它被关闭,那么所有调度的任务都将被丢弃。 如果我创建一个集群单例来负责调度,那么已经制定的调度是否可以在其他节点上重新创建?还是我应该将它作为一个具有已经创建的调度元数据结构的持久执行元,并在预启动阶段
null
我试图学习Akka集群下面的教程提供了这里 我已经创建了应用程序和回购是在这里。 正如教程中提到的,我已经启动了FrontEndApp 即使我在2551和2552上启动后端应用程序,上述警告消息也会不断重复。 在2551上启动后端参与者的终端日志。 最后一个日志持续重复。 在2552上启动后端参与者的终端日志。 不确定是什么原因群集节点不能检测到彼此和参与者节点与后端。 我会错过任何设置吗?
我有两个MariaDB Galera群集(PROD(服务器A、B和C)和DR(服务器1、2和3)。我有从PROD群集的主组件节点(服务器A)到DR群集的主组件节点(服务器1)的标准复制(主从)配置。每个群集都可以正常地独立于其他群集运行(也就是说,如果对一个节点进行更改,则群集中的所有节点立即复制更改)。 这种配置的目的是允许我将中继日志在从机上的应用延迟一段预定的时间。不幸的是,Mariadb1
问题内容: 我希望Selenium通过箭头键浏览菜单-首先单击顶部菜单项,然后按“ DOWN”,“ DOWN”,… 问题是您必须始终提供特定的元素才能将“ DOWN”发送到。 有什么方法可以获取当前元素? 我试过了: 但它表示该表达式无法识别或未返回正确的对象。 我希望我错过了一些愚蠢的把戏。 问题答案: 没有比访问更直接的方法了