我正试图以最快、最直接的方式显示阿克卡( Akka -集群)的分裂大脑。
要做到这一点,我需要3个节点进程,但其中两个节点应该只使用中间的一个节点进行通信,所以当我杀死它时,就会出现分裂。它应该是这样的:
1--2-3
杀死2,使1和3不能沟通,分裂的脑再生器处理它。
或者,是否有更简单的方法来展示大脑分裂的简单场景,以及Akka拆分脑再生器是如何处理它们的?
发布于 2016-06-02 06:08:00
我还没有使用拆分脑功能,显然是因为它是一个高级功能:)。但是,根据描述,解析器也会激活超时工作。那么,当接收到特定消息时,为什么不实际阻止参与者2呢?所以,设置它,让它(使用Thread.sleep
)睡上一两分钟。这可能会被检测为失败(同样,工作在直觉上)。
另一个想法是在您的参与者中抛出某种异常,并使用OneForOneStrategy
处理程序处理它,将Throwable
映射到Stop
指令。
https://stackoverflow.com/questions/37572085
复制相似问题