1

是否有可能和/或有必要关闭 akka 中的远程参与者?

我可以akka.actor.ActorSystem作为“服务器”启动(在 scala 中):

val actorSystem = ActorSystem("TestServer")

val actor = actorSystem.actorOf(..., name = "TestActor")

然后从运行在单独 JVM 上的“客户端”ActorSystem 连接到它:

remote = context.actorSelection("akka.tcp://TestServer@localhost:1234/user/TestActor")

我能够发送消息remote和接收响应消息。

但是,当客户端需要关闭时,在客户端 JVM 死机后,我会看到来自服务器 ActorSystem 的以下日志消息:

[警告] [04/01/2015 11:27:27.107] [TestServer-akka.remote.default-remote-dispatcher-5] ... [akka.tcp://ConsoleSystem@localhost:1236] 失败,地址现在门控 [5000] 毫秒。原因是:[解除关联]

这些警告不好吗?remote.closeConnection我应该调用一些方法来防止警告消息吗?

先感谢您。

4

1 回答 1

2

在您的测试示例中,此警告还不错。但是,如果与您的系统关联的远程系统被解除关联(关闭、连接丢失等),则有必要警告您。

于 2015-04-01T17:48:13.833 回答