是否有可能,和/或有必要,关闭 akka 中的远程 Actor?
我能够启动一个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")
我能够向远程
发送消息并接收响应消息。
但是,当客户端需要关闭时,在客户端 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
方法来防止出现警告消息?
提前谢谢您。
最佳答案
这个警告在您的测试示例中还不错。但如果与您的系统关联的远程系统已解除关联(关闭、连接丢失等),则有必要警告您
关于java - 关闭远程 akka actor 连接?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29397084/