是DistributedPubSub中介,它为无法访问的集群成员存储消息



在集群环境中,我们通过DistributedPubSub中介器发送消息。因此,当消息被发送时,我们在集群中有一些机器是不可访问的。在"自动关闭"到期之前,这些机器可以再次访问,然后这些机器确实会收到消息。

这是否意味着DistributedPubSub中介器为集群中不可访问的成员隐藏消息,并在它们再次变得可访问时传递这些消息?

我们对上述查询的场景是-

  1. 群集环境,例如由3台不同机器上的3台服务器组成
  2. 在通信过程中,其中一个服务器无法访问(服务器进程暂停),然后模拟消息重播

所以在上面的例子中,我们有连接,所以数据包到达了机器。由于进程已暂停并且数据包并没有丢失,所以一旦恢复,服务器进程就会收到消息。

因此,为了以正确的方式模拟所需的场景,我们没有暂停进程,而是断开了其中一台机器与网络的连接,这样断开连接的成员就无法访问集群的其他成员。

所以结论是,DistributedPubSubMediator在akka集群中没有隐藏消息

最新更新