使用Quarkus Keycloak Admin Client Reactive获取请求失败真实原因

方案一：手动调用底层Reactive REST Client接口 #

直接绕过封装好的UserResource.update()方法，使用Keycloak Admin Client提供的ReactiveWebTarget手动构建请求，完整控制响应处理流程，直接读取错误实体：

@Inject
@KeycloakAdminClient
ReactiveWebTarget keycloakWebTarget;

public Uni<Void> updateUser(String userId, UserRepresentation user) {
    return keycloakWebTarget.path("users").path(userId)
            .request(MediaType.APPLICATION_JSON)
            .put(Entity.json(user))
            .onItem().transform(response -> {
                if (Response.Status.Family.SUCCESSFUL.equals(response.getStatusInfo().getFamily())) {
                    return Uni.createFrom().voidItem();
                } else {
                    // 直接读取错误响应实体
                    return response.readEntity(KeycloakErrorRepresentation.class)
                            .onItem().failWith(error -> new RuntimeException(
                                    String.format("更新用户失败: %s", error.getErrorMessage())));
                }
            })
            .flatMap(uni -> uni);
}

这种方式跳过封装方法，直接操作响应对象，避免底层自动消费响应流导致无法读取实体。

方案二：通过ClientResponseFilter缓存响应体 #

默认HTTP响应流只能被读取一次，封装方法内部可能已消费流，导致ClientWebApplicationException中无法再次读取实体。可通过自定义响应过滤器缓存响应流，允许重复读取：

1. 创建缓存响应的过滤器：

@Provider
public class CachingResponseFilter implements ClientResponseFilter {
    @Override
    public void filter(ClientRequestContext requestCtx, ClientResponseContext responseCtx) throws IOException {
        if (responseCtx.hasEntity()) {
            var entityStream = responseCtx.getEntityStream();
            // 用BufferedInputStream包装，支持mark/reset实现重复读取
            if (!entityStream.markSupported()) {
                var bufferedStream = new BufferedInputStream(entityStream);
                bufferedStream.mark(Integer.MAX_VALUE);
                responseCtx.setEntityStream(bufferedStream);
            }
        }
    }
}

2. 在application.properties中注册该过滤器到Keycloak Admin Client：

quarkus.keycloak-admin-client.reactive.client-filters=com.your.package.CachingResponseFilter

3. 捕获异常时读取实体：

try {
    userResource.update(userRepresentation);
} catch (ClientWebApplicationException e) {
    Response response = e.getResponse();
    if (response != null) {
        KeycloakErrorRepresentation error = response.readEntity(KeycloakErrorRepresentation.class);
        // 处理错误信息，比如日志记录或业务逻辑处理
    }
}

为什么自定义异常映射无效？ #

ClientWebApplicationException是Keycloak Admin Client发起HTTP请求时直接抛出的客户端异常，不属于应用层的JAX-RS资源异常，因此自定义的异常映射器无法捕获这类客户端侧的异常，只能通过上述两种方式处理。

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