如何使用RestEasy批量并发发起PUT请求？

你想要把串行的PUT请求改成并发执行，这样总耗时等于最慢的单次请求，最后根据所有响应状态码的逻辑与（即所有请求都成功才返回true）返回布尔值。下面是具体的实现方案，以JavaScript为例（前端和Node.js场景都适用）：

核心思路 #

1. 用Promise.all实现并发请求：它会等待所有异步请求完成，总耗时由最慢的请求决定，完美符合你的需求。
2. 对每个请求做独立错误处理，确保单个请求失败不会中断整个并发流程，而是记录其失败状态。
3. 最后通过检查所有请求的成功状态，实现逻辑与的效果（只有全部成功才返回true）。

代码实现 #

1. 单个PUT请求的封装函数 #

这个函数负责发起单个PUT请求，并返回该请求是否成功的布尔值：

async function sendPutRequest(requestOptions) {
  try {
    const response = await fetch(requestOptions.url, {
      method: 'PUT',
      body: requestOptions.body,
      headers: {
        'Content-Type': 'application/json', // 根据你的请求格式调整，比如form-data等
        // 可添加其他请求头，比如Authorization
      },
      // 需要携带Cookie的话，加上credentials: 'include'
    });
    // response.ok会在状态码为2xx时返回true，符合常规的请求成功定义
    return response.ok;
  } catch (error) {
    // 捕获网络错误（比如连接失败、跨域问题等），视为请求失败
    console.error(`请求 ${requestOptions.url} 失败：`, error);
    return false;
  }
}

2. 并发请求的主函数 #

这个函数接收所有请求的配置数组，并发执行它们，最后返回逻辑与的结果：

async function concurrentPutRequests(allRequests) {
  // 将每个请求配置映射为Promise实例
  const requestPromises = allRequests.map(req => sendPutRequest(req));
  
  // 等待所有请求完成，得到每个请求的成功状态数组
  const successResults = await Promise.all(requestPromises);
  
  // 逻辑与运算：只有所有结果都是true时，才返回true
  return successResults.every(result => result);
}

3. 使用示例 #

// 定义所有需要发起的PUT请求配置
const myPutRequests = [
  { url: '/api/user/1', body: JSON.stringify({ name: '张三' }) },
  { url: '/api/post/2', body: JSON.stringify({ title: '新标题' }) },
  { url: '/api/setting/3', body: JSON.stringify({ theme: 'dark' }) },
  // 可添加更多请求...
];

// 调用并发请求函数
concurrentPutRequests(myPutRequests)
  .then(isAllSuccess => {
    if (isAllSuccess) {
      console.log('所有PUT请求都成功了！');
    } else {
      console.log('至少有一个PUT请求失败了。');
    }
  })
  .catch(unexpectedError => {
    console.error('发生意外错误：', unexpectedError);
  });

可选扩展：获取具体状态码 #

如果你需要基于具体状态码做判断（比如要求所有状态码都是200），可以修改封装函数：

async function sendPutRequestWithStatus(requestOptions) {
  try {
    const response = await fetch(requestOptions.url, {
      method: 'PUT',
      body: requestOptions.body,
      headers: { 'Content-Type': 'application/json' },
    });
    return response.status;
  } catch (error) {
    console.error(`请求 ${requestOptions.url} 失败：`, error);
    return -1; // 用特殊值标记网络错误
  }
}

async function concurrentPutRequestsWithStatus(allRequests) {
  const statusCodes = await Promise.all(allRequests.map(req => sendPutRequestWithStatus(req)));
  // 逻辑与：所有状态码都是200才返回true（可按需修改判断条件）
  return statusCodes.every(code => code === 200);
}

注意事项 #

• 确保服务器能够处理你发起的并发请求数量，避免触发限流机制。
• 如果请求数量极大（比如上百个），可以考虑分批次并发（比如每次并发10个），避免超出浏览器或Node.js的并发限制。
• 跨域请求需要确保服务器配置了正确的CORS头。

内容的提问来源于stack exchange，提问作者Destructor