在 Java 中通过 AKKA 同时调用外部 REST API

Question

我正在尝试 通过其 API 从 Tesla 服务器获取汽车信息

。我想同时进行。即使用 AKKA 演员并行获取多辆汽车的信息

我的方法：

(1)先获取汽车总数。

(2) 创建与汽车数量相等的actor。

(3) 每个actor内部调用rest API并行获取汽车信息。即每个参与者都将获得包含汽车 ID 的 url。

我的方法做得对吗？

具体来说，在第 3 点中，我使用来自 com.ning 的 AsyncHttpClient 调用了每个参与者内部的 Tesla 服务器。在每个actor内部使用AsyncHttpClient会确保每个actor异步发送请求到服务器而不阻塞其他actor吗？

如有需要，将提供更多信息。我是 AKKA 的初学者。看了很多帖子，但找不到我要找的东西。

Answer 1

特别是对于第 3 点，只要您在 actor 中使用基于 Future 的 API，actor 就不会阻塞。

一般来说，如果不知道您为什么选择每辆车使用一个演员，就很难说出更多关于您的方法的信息。

考虑这个问题：为什么不能简单地创建一个listOfCars: List[String] 的 URL 并使用 Future.traverse(listOfCars)(downloadCarDataForUrl _)？

最后，我不知道AsyncHttpClient 的行为如何，但我会仔细检查一下，如果您有数千辆汽车的列表，AsyncHttpClient 不会同时下载所有汽车......如果是这样的话，您可能会很快被 api 提供程序阻止。如果这成为一个问题，您可以查看 akka-http，它只使用与某个主机的连接数量有限。