演员模型与阿卡。NET：如何防止向已死的参与者发送消息

Question

我用的是Akka。NET来实现一个actor系统，其中一些actor是按需创建的，并在可配置的空闲时间后删除（我使用Akka的“ReceiveTimeout”机制）。这些参与者中的每一个都由一个密钥标识，并且不应该存在具有相同密钥的两个参与者。

这些参与者当前由一个普通主管创建和删除。可以要求主管返回与给定密钥匹配的参与者的引用，如果具有该密钥的参与者尚不存在，则可以返回现有的参与者，也可以创建新的参与者。当一个参与者收到“ReceiveTimeout”消息时，它会通知主管，主管会用“毒药丸”杀死它。

我有一个问题，当一个消息被删除后立即发送给这些演员之一。我注意到向死去的演员发送消息不会产生异常。更糟糕的是，当发送“询问”消息时，发送者仍然被阻止，无限期（或直到超时）等待他永远不会收到的响应。

我首先想到Akka的“Deatchwatch”机制来监控演员的生命周期。但是，如果我没有弄错的话，垂死的参与者发送的“终止”消息将被监控参与者异步接收，就像任何其他消息一样，因此问题仍然可能发生在目标参与者死亡和接收其“终止”消息之间。

为了解决这个问题，我这样做了，任何人要求主管对这样的演员进行引用，都必须向主管发送“关闭会话”消息，以便在他不再需要演员时释放他（这是通过一次性“演员会话”透明地完成的“对象）。只要有关于某个演员的公开会话，监管者就不会删除。

我认为这种情况很常见，因此我想知道是否有一种更简单的模式来解决这种问题。如有任何建议，将不胜感激。

Answer 1

我通过Akka的集群分片机制创建的实体参与者解决了这个问题：

如果实体的状态是持久的，则可以停止未用于减少内存消耗的实体。这是由实体参与者的应用程序特定实现完成的，例如通过定义接收超时（context.setReceiveTimeout）。如果消息在实体停止时已经排队到实体，则邮箱中排队的消息将被删除。为了支持优雅的钝化，而不丢失这样的消息，实体参与者可以发送碎片区域。钝化到它的父碎片。钝化中指定的包装消息将被发回实体，然后实体应该停止自己。在接收到钝化和终止实体之间，传入的消息将由碎片缓冲。这种缓冲的消息随后被传递到实体的新化身。

Answer 2

我有一个问题，当发送消息给这些演员之一后，它已被删除。我注意到向死去的演员发送消息不会产生异常。

这是故意的。在尝试发送消息时，您永远不会收到异常-它只会被路由到死信并被记录。有很多原因我不想在这里讨论，但底线是这是有意的行为。

DeathWatch是这项工作的合适工具，但正如您所指出的，您可能会在向该参与者发送消息后收到一条终止的消息。

比跟踪打开/关闭会话更简单的模式是简单地使用接收方的确认/回复消息，使用询问等待硬超时。当然，不利的一面是，如果您的收件人参与者有很多长时间运行的操作，那么您可能会在发件人内部阻塞很长一段时间。

您可以使用的另一个选项是重新设计收件人参与者，使其充当状态机，并具有软终止或终止状态，用于排出与潜在发件人的连接/引用。这样，原始参与者仍然可以回复和接受消息，但让呼叫者知道它不再可以工作。