java - 远程系统上的 Akka fire-forget 不会传递所有消息

Question

我有以下情况：

• Akka 远程系统 A
• Akka 远程系统 B

B 是一个分析引擎，它向 A 发送早午餐并忘记消息。系统 B 在分析后停止。

但是如果B在分析之后调用system.shutdown，并不是所有的消息都会传递给A。B的actor系统是否在缓冲消息？

我如何能够确保所有 B 邮件现在都在 A 的收件箱中？我可以确定 B 何时可以安全断开连接吗？如何正确断开 B 与 A 的连接？

感谢您的任何建议！

Answer 1

你可以创建几个子actors来发送消息并在他们发送完消息后立即杀死自己。在监督下，您可以等待所有子演员被终止，然后关闭系统。海事组织这应该足以发送消息。