如何在Keycloak SPI中创建用户？无需依赖keycloak-admin-client

你可以直接使用Keycloak核心内部的UserProvider API来创建用户，这是Keycloak自身服务层使用的原生接口，完全不需要依赖keycloak-admin-client。以下是修改后的完整createUser方法实现：

@POST
@Path("idp/create-user")
@Consumes(MediaType.APPLICATION_JSON)
public Response createUser(User member) {
    helper.checkTokenValidationThrowError(this.authResult);

    // 检查手机号是否已存在
    if (member.getAttributes().get("phone_number") != null
            && member.getAttributes().get("country_code") != null) {
        HashMap<String, String> attributeFilter = new HashMap<>();
        attributeFilter.put("phone_number", member.getAttributes().get("phone_number"));
        attributeFilter.put("country_code", member.getAttributes().get("country_code"));
        Stream<UserModel> userStream = session.users().searchForUserStream(this.realm, attributeFilter);
        List<UserModel> userList = userStream.toList();

        if (!userList.isEmpty() && userList.size() == 1) {
            String errorMessage = "{\"errorMessage\": \"User exists with same phone number\"}";
            return Response.ok().entity(errorMessage).status(409).type(MediaType.APPLICATION_JSON).build();
        }
    }

    // 使用Keycloak内部API创建用户
    UserProvider userProvider = session.userStorageManager().getUserProvider(realm);
    // 创建用户，用户名必填，可根据业务用手机号/邮箱等唯一标识填充
    UserModel newUser = userProvider.addUser(realm, member.getUsername());
    
    // 设置用户基础信息
    newUser.setEmail(member.getEmail());
    newUser.setEmailVerified(member.isEmailVerified());
    newUser.setEnabled(member.isEnabled());
    newUser.setFirstName(member.getFirstName());
    newUser.setLastName(member.getLastName());
    
    // 批量设置自定义属性
    member.getAttributes().forEach((key, value) -> {
        newUser.setSingleAttribute(key, value);
    });

    String memberId = newUser.getId();
    return Response
            .status(201)
            .header("Location",
                    session.getContext().getUri().getBaseUri() + "admin/realms/" + realm.getName()
                            + "/users/" + memberId)
            .type(MediaType.APPLICATION_JSON)
            .build();
}

关键说明 #

• session.userStorageManager().getUserProvider(realm)：获取当前Realm对应的用户存储提供者，是Keycloak处理用户数据的核心接口
• userProvider.addUser(realm, username)：直接创建用户，用户名是必填项，可根据业务逻辑用手机号、邮箱等唯一值填充
• 通过UserModel的方法可以直接操作用户属性、状态，无需经过UserRepresentation的序列化/反序列化，性能更优
• 这种方式完全复用Keycloak内部的用户处理逻辑，和官方Admin API的底层实现一致，避免了额外的HTTP调用开销

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