如何优化Java实现Azure AD B2C用户批量上传的效率？

问题根因 #

你当前使用的单线程串行逐个调用POST /users接口的方式，每次请求都要完整走一次HTTP往返流程，2万次请求累计耗时自然会达到数小时。

优化方案 #

1. 改用Microsoft Graph批量请求接口（$batch） #

Microsoft Graph支持单请求内打包最多20个用户创建请求，直接将请求往返次数降低到原来的1/20，是性价比最高的优化方式。
Java SDK示例代码如下：

GraphServiceClient<Request> graphClient = GraphServiceClient.builder().authenticationProvider( tokenCredentialAuthProvider ).buildClient();
// 每批次处理20个用户，符合Graph $batch接口上限
int batchSize = 20;
for (int i = 0; i < users.size(); i += batchSize) {
    int end = Math.min(i + batchSize, users.size());
    List<DBuser> batchUsers = users.subList(i, end);
    
    BatchRequestContent batchContent = new BatchRequestContent();
    for (DBuser dbuser : batchUsers) {
        com.microsoft.graph.models.User user = new com.microsoft.graph.models.User();
        user.accountEnabled = true;
        user.displayName = dbuser.getFirstName();

        final LinkedList<ObjectIdentity> identitiesList = new LinkedList<ObjectIdentity>();
        ObjectIdentity identities = new ObjectIdentity();
        identities.signInType = "emailAddress";
        identities.issuerAssignedId = dbuser.getEmail();
        identities.issuer = "issuer"; // 此处替换为你实际的B2C租户域名
        identitiesList.add(identities);
        user.identities = identitiesList;

        PasswordProfile passwordProfile = new PasswordProfile();
        passwordProfile.password = dbuser.getPassword();
        passwordProfile.forceChangePasswordNextSignIn = false;
        user.passwordProfile = passwordProfile;
        user.passwordPolicies = "DisablePasswordExpiration";
        
        // 将单用户创建请求加入批次
        batchContent.addBatchRequestStep(graphClient.users().buildRequest().getHttpRequest(HttpMethod.POST, user));
    }
    // 执行批次请求
    BatchResponseContent batchResponse = graphClient.batch().buildRequest().post(batchContent);
    // 可选：处理批次中失败的请求，记录错误日志方便后续补传
}

2. 增加并行批次处理（可选，进一步提速） #

• 控制3-5个线程并行提交批次请求，避免单线程等待IO的空耗
• 遇到接口返回429限流错误时，根据响应头的Retry-After字段等待指定时间后重试即可

性能预期 #

仅使用批量请求的情况下，2万用户可在15-30分钟内完成迁移，配合并行处理可进一步将耗时压缩到10分钟以内。

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