在Springboot中从阵列发送并发HTTP请求

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.concurrent.CompletableFuture;

@Service
public class HttpService {

    private RestTemplate restTemplate;

    public HttpService(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @Async
    public CompletableFuture<String> sendHttpRequest(String url) {
        String response = restTemplate.getForObject(url, String.class);
        return CompletableFuture.completedFuture(response);
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

@RestController
public class MyController {

    @Autowired
    private HttpService httpService;

    @GetMapping("/concurrent-requests")
    public String sendConcurrentRequests() throws ExecutionException, InterruptedException {
        CompletableFuture<String> request1 = httpService.sendHttpRequest("http://example.com/api/1");
        CompletableFuture<String> request2 = httpService.sendHttpRequest("http://example.com/api/2");
        CompletableFuture<String> request3 = httpService.sendHttpRequest("http://example.com/api/3");

        CompletableFuture.allOf(request1, request2, request3).join();

        String response1 = request1.get();
        String response2 = request2.get();
        String response3 = request3.get();

        // 处理响应结果
        // ...

        return "Concurrent requests completed";
    }
}