quarkus-keycloak-admin-client扩展的反应式版本？

Quarkus Keycloak Admin Client 扩展是一个用于在 Quarkus 应用程序中与 Keycloak 进行交互的库。它允许你在应用程序中执行 Keycloak 管理操作，如创建和管理用户、角色和客户端等。这个扩展提供了同步和反应式两种版本。

基础概念

Quarkus 是一个为 Kubernetes 设计的 Java 框架，旨在简化开发、部署和运行云原生应用程序。

Keycloak 是一个开源的身份和访问管理解决方案，提供单点登录（SSO）、身份代理、LDAP 和 Active Directory 集成等功能。

Reactive 编程是一种编程范式，它处理异步数据流和变化传播。在 Quarkus 中，Reactive 版本通常使用 Mutiny 库来实现非阻塞的反应式编程。

类型

Quarkus Keycloak Admin Client 扩展提供了两种类型：

同步版本：使用传统的阻塞 I/O 操作。
反应式版本：使用 Mutiny 库实现非阻塞的反应式编程。

应用场景

反应式版本的 Quarkus Keycloak Admin Client 扩展适用于需要高吞吐量和低延迟的应用程序，特别是在处理大量并发请求时。例如，微服务架构中的身份验证和授权服务。

示例代码

以下是一个简单的示例，展示如何在 Quarkus 应用程序中使用反应式版本的 Keycloak Admin Client 扩展：

import io.smallrye.reactive.messaging.annotations.Channel;
import io.smallrye.reactive.messaging.annotations.Emitter;
import io.smallrye.mutiny.Uni;
import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.keycloak.admin.client.Keycloak;
import org.keycloak.admin.client.KeycloakBuilder;
import org.keycloak.admin.client.resource.RealmResource;
import org.keycloak.admin.client.resource.UserResource;
import org.keycloak.representations.idm.UserRepresentation;

@ApplicationScoped
public class KeycloakService {

    private final Keycloak keycloak;

    public KeycloakService() {
        this.keycloak = KeycloakBuilder.builder()
                .serverUrl("http://localhost:8080/auth")
                .realm("myrealm")
                .clientId("myclient")
                .clientSecret("myclientsecret")
                .build();
    }

    public Uni<UserRepresentation> findUserByUsername(String username) {
        RealmResource realm = keycloak.realm("myrealm");
        return Uni.createFrom().item(realm)
                .emitOn(Dispatchers.IO)
                .onItem().transformToUni(realm -> realm.users().search(username).firstResult());
    }

    @Incoming("user-updates")
    @Outgoing("user-updates-processed")
    public Uni<Void> processUserUpdate(UserRepresentation user) {
        return findUserByUsername(user.getUsername())
                .onItem().invoke(userResource -> userResource.get())
                .onItem().transform(userRepresentation -> {
                    userRepresentation.setEmail(user.getEmail());
                    return userResource.update(userRepresentation);
                })
                .then();
    }
}