在未来的akka java中无限期地等待参与者的响应

Question

我有一段非基于演员的代码，它将一些操作委托给akka演员，我想无限期地等待这个演员的响应，我的意思是，直到这个演员返回一个响应，无论需要多长时间。问题是我不知道如何在未来无限期地等待attern.ask和wait.result方法。

我更喜欢这样的东西：

Timeout timeout = new Timeout(Duration.inf());
Future<Object> future = Patterns.ask(actor, msg, timeout);
String result = (String) Await.result(future, timeout.duration());

但这不起作用，因为Timeout不接受Duration对象作为构造函数参数，它只接受FiniteDuration对象。。。

任何想法？

干杯

Answer 1

免责声明：我对Akka不是很有经验。

建议：你不能放弃Timeout对象，简单地写

Future<Object> future = Patterns.ask(actor, msg);
Await.result(f, Duration.Inf);

或者，或者使用Timeout timeout=Timeout.never

然而，要注意：

具有无限持续时间的超时。永远不会超时。对此要非常小心，因为它可能会导致内存泄漏、线程阻塞，甚至可能不被接收器支持，这将导致异常。（来自Akka API文档）

Answer 2

您可能永远不会收到回复，因为消息传递不是100%保证的。因此，无限期地等待不是一个好方法——你很可能会永远等待下去。

您可能需要某种程度的超时（如果合适的话，可能是长超时），然后是必要时重新发送请求的后备情况。这将是处理这种情况的更有力的方法。