关闭远程作为演员连接?
Closing a remote akka actor connection?
是否有可能 and/or 有必要在 akka 中关闭远程 actor?
我可以将 akka.actor.ActorSystem
作为 "server"(在 scala 中)启动:
val actorSystem = ActorSystem("TestServer")
val actor = actorSystem.actorOf(..., name = "TestActor")
然后在单独的 JVM 上从 "client" ActorSystem 运行 连接到它:
remote = context.actorSelection("akka.tcp://TestServer@localhost:1234/user/TestActor")
我可以向 remote
发送消息并接收回复消息。
但是,当客户端关闭时,我在客户端 JVM 死机后从服务器 ActorSystem 看到以下日志消息:
[WARN] [04/01/2015 11:27:27.107]
[TestServer-akka.remote.default-remote-dispatcher-5] ...
[akka.tcp://ConsoleSystem@localhost:1236] has failed, address is now
gated for [5000] ms. Reason is: [Disassociated]
这些警告不好吗?我应该调用一些 remote.closeConnection
方法来阻止警告消息吗?
提前致谢。
这个警告在你的测试例子中是不错的。但是,如果远程系统与您的系统关联断开(关闭、连接丢失等),则有必要警告您
是否有可能 and/or 有必要在 akka 中关闭远程 actor?
我可以将 akka.actor.ActorSystem
作为 "server"(在 scala 中)启动:
val actorSystem = ActorSystem("TestServer")
val actor = actorSystem.actorOf(..., name = "TestActor")
然后在单独的 JVM 上从 "client" ActorSystem 运行 连接到它:
remote = context.actorSelection("akka.tcp://TestServer@localhost:1234/user/TestActor")
我可以向 remote
发送消息并接收回复消息。
但是,当客户端关闭时,我在客户端 JVM 死机后从服务器 ActorSystem 看到以下日志消息:
[WARN] [04/01/2015 11:27:27.107] [TestServer-akka.remote.default-remote-dispatcher-5] ... [akka.tcp://ConsoleSystem@localhost:1236] has failed, address is now gated for [5000] ms. Reason is: [Disassociated]
这些警告不好吗?我应该调用一些 remote.closeConnection
方法来阻止警告消息吗?
提前致谢。
这个警告在你的测试例子中是不错的。但是,如果远程系统与您的系统关联断开(关闭、连接丢失等),则有必要警告您