使用Spring boot/java进行并行API调用

Question

我对Spring的靴子是陌生的，在它们到来的时候学习。我有一个关于并行API调用的快速问题。

我有一个ID数组，我将把它附加到第三方APIendpoint，发出GET请求，聚合数据，并在所有3000个调用完成后从中生成一个文件。

这里的问题是Array的大小为3000，即我预计会进行3000次调用。我觉得使用for循环并迭代超过3000次没有任何意义，而且效率较低。

有谁能给我建议一个最好、最有效的方法吗？

谢谢你

Answer 1

您可以这样做：

List<Integer> ids = IntStream.range(1, 13).boxed().collect(Collectors.toList());
int partitionSize = 5;

for (int i = 0; i < ids.size(); i += partitionSize) {
    List<Integer> currPartition = ids.subList(i, Math.min(i + partitionSize, ids.size()));

    String partitionStr = currPartition.parallelStream() 
            .map(id -> callAPI(id)) // change the aggeragtion according to your needs
            .collect(Collectors.joining(", ")); 

    System.out.println(partitionStr);
}