同时发送多个API请求，每个API调用请求使用不同的授权标头Java

Question

我正在努力同时发送多个API请求，以下是我为同时发送多个API调用所做的步骤：

1. 创建具有40个授权值的哈希映射
2. 迭代hashmap，以便为每个调用检索不同的授权值

我知道如何按顺序制作，我希望能够用线程来制作。

这是我的代码：

private void createUsers() throws ApiException {
    AuthAPI authAPI = new AuthAPI(HOST);
    usersMap = new HashMap<>();
    for (int i = 0; i < 40 - 1; i++) {
        String USER_NAME = "Introductory Content User " + StringUtils.getRandomString(5, true, false);
        usersAPIUnitTest.createUser(USER_NAME, UserRole.ADMIN, "", "", "");
        String email = UsersAPIUnitTest.getEmail();
        System.out.println(email);
        String userToken = authAPI.generateToken(email);
        usersMap.put(USER_NAME, userToken);
    }
}

然后我使用此方法发送api调用：

public void sendMultipleAPIRequests() throws IOException {
        for(Map.Entry mapElement : usersMap.entrySet()){
            LabAPIChecker labAPIChecker = new LabAPIChecker(HOST, mapElement.getValue());
            JsonObject jsonObject = labAPIChecker.launchLabGetRequest();//this line perform simple 'get' request
        }
        
    }

Answer 1

@michael-gantman建议下的结果代码：

public void sendMultipleAPIRequests() throws IOException 
{
    ExecutorService executorService = Executors.newFixedThreadPool(10); // max 10 concurrent threads
    for (Map.Entry mapElement : usersMap.entrySet()) {
        Runnable thread = () -> {
          LabAPIChecker labAPIChecker = new LabAPIChecker(HOST, mapElement.getValue());
          JsonObject jsonObject = labAPIChecker.launchLabGetRequest();
        };
        executorService.execute(thread);
     }
     executorService.shutdown(); 
 }

所有功劳都归于迈克尔·甘特曼

Answer 2

您可以使用标准java工具来完成这一切。您需要使用ScheduledExecutorService，或者可能只是一个执行器服务（ExecutorService），以获得一次性[Executors]class2的距离。您需要创建（或修改）自己的类来实现Runnable接口，其中方法run（）将负责发送单个请求。然后，您需要将所有可运行文件提交给ScheduledExecutorService以同时运行。将线程数设置为可运行的线程数，它们将同时运行