springboot 批量调用接口同步数据

在Spring Boot中，可以使用RestTemplate来调用接口，批量调用接口的方式有多种。

一种方式是使用多线程并发调用接口。可以使用Java的Executor框架来实现多线程调用，将需要调用的接口放入一个List中，使用Executor框架的invokeAll方法批量执行这些任务，最后等待所有任务执行完成。示例代码如下：

RestTemplate restTemplate = new RestTemplate();
List<Callable<String>> tasks = new ArrayList<>();
tasks.add(() -> restTemplate.postForObject(url1, request1, String.class));
tasks.add(() -> restTemplate.postForObject(url2, request2, String.class));
tasks.add(() -> restTemplate.postForObject(url3, request3, String.class));

ExecutorService executorService = Executors.newFixedThreadPool(3);
List<Future<String>> futures = executorService.invokeAll(tasks);
executorService.shutdown();

for (Future<String> future : futures) {
    String result = future.get();
    // 处理返回结果
}

另一种方式是使用Java8的Stream API来批量调用接口。将需要调用的接口放入一个List中，使用Stream API的map方法将每个接口调用转换成一个CompletableFuture，再使用CompletableFuture的allOf方法等待所有任务执行完成。示例代码如下：

RestTemplate restTemplate = new RestTemplate();
List<String> urls = Arrays.asList(url1, url2, url3);

List<CompletableFuture<String>> futures = urls.stream()
        .map(url -> CompletableFuture.supplyAsync(() -> restTemplate.postForObject(url, request, String.class)))
        .collect(Collectors.toList());

CompletableFuture<Void> allFutures = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));
allFutures.join();

List<String> results = futures.stream()
        .map(CompletableFuture::join)
        .collect(Collectors.toList());
// 处理返回结果

以上两种方式都可以实现批量调用接口同步数据的功能，具体选择哪种方式要根据实际情况和需求来决定。需要注意的是，批量调用接口可能会对接口服务造成较大的负载，应该避免并发量过大而导致服务瘫痪。