如何为pac4j OAuth授权码/访问令牌交换配置非阻塞HTTP调用

可以实现非阻塞调用，但pac4j 5.7版本默认没有提供现成的配置开关，需要通过自定义组件替换同步逻辑来实现，具体步骤如下：

1. 自定义异步OAuth认证器 #

pac4j提供了AsyncAuthenticator接口用于支持异步认证逻辑，我们可以基于这个接口实现自己的认证器，调用scribejava OAuth20Service的异步方法完成令牌获取和用户信息拉取：

public class AsyncOAuth20Authenticator implements AsyncAuthenticator<OAuth20Credentials, CommonProfile> {
    private OAuth20Client oAuth20Client;

    public void setOAuth20Client(OAuth20Client oAuth20Client) {
        this.oAuth20Client = oAuth20Client;
    }

    @Override
    public CompletableFuture<CommonProfile> authenticate(OAuth20Credentials credentials, WebContext context) {
        // 获取scribejava的OAuth20服务实例
        OAuth20Service service = oAuth20Client.getOAuth20Service(context);
        
        // 异步获取访问令牌，再异步拉取用户信息
        return service.getAccessTokenAsync(credentials.getCode())
                .thenCompose(accessToken -> 
                        service.getUserProfileAsync(accessToken.getAccessToken())
                                .thenApply(scribeProfile -> {
                                    // 将scribejava的用户信息转换为pac4j的CommonProfile
                                    CommonProfile commonProfile = oAuth20Client.convertToCommonProfile(scribeProfile, accessToken);
                                    commonProfile.setAccessToken(accessToken.getAccessToken());
                                    // 处理刷新令牌等额外逻辑
                                    if (accessToken.getRefreshToken() != null) {
                                        commonProfile.setRefreshToken(accessToken.getRefreshToken());
                                    }
                                    return commonProfile;
                                })
                )
                .exceptionally(e -> {
                    throw new HttpAction(401, "OAuth认证失败", e);
                });
    }
}

2. 替换OAuth客户端的默认认证器 #

在Spring配置类中，将自定义的异步认证器绑定到OAuth20Client上，替换默认的同步认证器：

@Bean
public OAuth20Client yourOAuth20Client() {
    OAuth20Client client = new OAuth20Client();
    // 配置OAuth客户端基础信息
    client.setClientId("your-client-id");
    client.setClientSecret("your-client-secret");
    client.setAuthorizationUrl("https://your-auth-server/oauth2/authorize");
    client.setTokenUrl("https://your-auth-server/oauth2/token");
    client.setUserProfileUrl("https://your-auth-server/oauth2/userinfo");
    
    // 绑定自定义异步认证器
    AsyncOAuth20Authenticator asyncAuthenticator = new AsyncOAuth20Authenticator();
    asyncAuthenticator.setOAuth20Client(client);
    client.setAuthenticator(asyncAuthenticator);
    
    return client;
}

3. 适配Spring非阻塞环境 #

• 如果使用Spring WebFlux：确保使用pac4j提供的Pac4jAuthenticationWebFilter（异步过滤器），它会自动识别并调用AsyncAuthenticator的异步方法，整个认证流程保持非阻塞。
• 如果使用Spring MVC：可以结合Spring的@Async注解或CompletableFuture来包装认证逻辑，避免阻塞主线程，但需要注意请求上下文的传递问题。

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