OAuth2 身份认证与授权提供者 (vertx-auth-oauth2)

OAuth2Options credentials = new OAuth2Options()
  .setClientId("<client-id>")
  .setClientSecret("<client-secret>")
  .setSite("https://api.oauth.com");

// 初始化 OAuth2 认证实例
OAuth2Auth oauth2 = OAuth2Auth.create(vertx, credentials);

// 生成 OAuth2 授权引导 URI
String authorization_uri = oauth2.authorizeURL(new OAuth2AuthorizationURL()
  .setRedirectUri("http://localhost:8080/callback")
  .addScope("<scope>")
  .setState("<state>"));

// 使用 Vert.x HTTP 响应执行 302 重定向
response.putHeader("Location", authorization_uri)
  .setStatusCode(302)
  .end();

Credentials tokenConfig = new Oauth2Credentials()
  .setCode("<code>")
  .setRedirectUri("http://localhost:3000/callback");

// 在回调端点中兑换 Access Token
oauth2.authenticate(tokenConfig)
  .onSuccess(user -> {
    // 成功获取用户访问令牌对象
  })
  .onFailure(err -> {
    System.err.println("获取 Access Token 失败: " + err.getMessage());
  });

OAuth2Auth oauth2 = OAuth2Auth.create(vertx);

Credentials tokenConfig = new UsernamePasswordCredentials(
  "username", "password");

oauth2.authenticate(tokenConfig)
  .onSuccess(user -> {
    // 成功获取令牌对象
    // 随后可以在后续受保护请求的 HTTP Authorization 头中传递该值：
    String httpAuthorizationHeader = user.principal()
      .getString("access_token");

  })
  .onFailure(err -> {
    System.err.println("获取 Access Token 失败: " + err.getMessage());
  });

OAuth2Options credentials = new OAuth2Options()
  .setClientId("<client-id>")
  .setClientSecret("<client-secret>")
  .setSite("https://api.oauth.com");

// 初始化 OAuth2 认证库
OAuth2Auth oauth2 = OAuth2Auth.create(vertx, credentials);

Credentials tokenConfig = new TokenCredentials("<token>");

oauth2.authenticate(tokenConfig)
  .onSuccess(user -> {
    // 认证成功
  })
  .onFailure(err -> {
    System.err.println("获取 Access Token 失败: " + err.getMessage());
  });

JsonObject keycloakJson = new JsonObject()
  .put("realm", "master")
  .put("realm-public-key", "MIIBIjANBgkqhk...wIDAQAB")
  .put("auth-server-url", "http://localhost:9000/auth")
  .put("ssl-required", "external")
  .put("resource", "frontend")
  .put("credentials", new JsonObject()
    .put("secret", "2fbf5e18-b923-4a83-9657-b4ebd5317f60"));

// 初始化 OAuth2 认证实例
OAuth2Auth oauth2 = KeycloakAuth
  .create(vertx, OAuth2FlowType.PASSWORD, keycloakJson);

// 第一步：获取令牌（认证）
oauth2.authenticate(
    new UsernamePasswordCredentials("user", "secret"))
  .onSuccess(user -> {
    // 第二步：执行权限鉴权判定
    AuthorizationProvider authz = KeycloakAuthorization.create();

    authz.getAuthorizations(user)
      .onSuccess(v -> {
        if (
          RoleBasedAuthorization.create("manage-account")
            .setResource("account")
            .match(user)) {
          // 当前用户已获得管理账户的权限！
        }
      });
  });

JsonObject idToken = user.attributes().getJsonObject("idToken");

// 亦可直接从 Keycloak principal 中读取属性：
String username = user.principal().getString("preferred_username");

OpenIDConnectAuth.discover(
    vertx,
    new OAuth2Options()
      .setClientId("clientId")
      .setTenant("your_realm")
      .setSite("https://server:port/auth/realms/{tenant}"))
  .onSuccess(oauth2 -> {
    // 发现与加载成功，直接使用即可！
  });

boolean isExpired = user.expired();

oauth2.refresh(user)
  .onSuccess(refreshedUser -> {
    // 令牌刷新成功，获得更新后的用户对象
  })
  .onFailure(err -> {
    // 刷新失败。作为最佳实践，此时应引导用户重新登录，因为这通常意味着刷新令牌已失效或用户在授权端已被踢下线。
  });

oauth2.revoke(user, "access_token")
  .onSuccess(v -> {
    // Access Token 吊销成功
  })
  .onFailure(err -> {
    // 吊销失败
  });

oauth2.authenticate(new TokenCredentials(user.<String>get("access_token")))
  .onSuccess(validUser -> {
    // 服务端自省确认令牌当前依然合法有效
  })
  .onFailure(err -> {
    // 自省失败，说明该令牌已被授权端主动注销或失效，应立即终止会话
  });

String logoutUrl = oauth2.endSessionURL(user);