如何使用Java的Microsoft Graph缓存令牌

Question

我使用 Microsoft Graph SDK 来处理某些请求，但是每次执行 GET 请求时，它都会执行另一个请求来获取令牌。我尝试阅读有关此的文档，但在 Java 中找不到任何内容。

这是我的客户端的实现，

         ClientSecretCredential clientSecretCredential = new ClientSecretCredentialBuilder()
            .clientId(clientId)
            .clientSecret(clientSecret)
            .tenantId(tenantId)
            .httpClient(httpClient)
            .build();

我还尝试在我的构建器中使用方法 .tokenCachePersistenceOptions() 但我收到此警告/错误，

c.m.a.m.CrossProcessCacheFileLock        : null

谢谢！

Answer 1

要实现上述要求，首先您需要进行身份验证以实施 MSAL 以从 Azure AD 获取令牌。

要获取访问令牌，您的应用程序必须向 Microsoft 标识平台注册，并由添加为该应用程序所有者的用户或管理员批准访问其所需的 Microsoft Graph 资源。

有关完整设置，请参阅此 MS 文档身份验证和Microsoft Graph 授权基础知识、此示例 & GitHub 示例|msgraph-sdk -java-core

Answer 2

我一直在寻找相同的思考，这是我为此实施的：

实现您自己的身份验证提供商类：

public class DelegateAuthenticationProvider implements IAuthenticationProvider {
    private String token;

    public DelegateAuthenticationProvider(String token) {
        this.token = token;
    }

    @NotNull
    @Override
    public CompletableFuture<String> getAuthorizationTokenAsync(@NotNull URL url) {
        return CompletableFuture.completedFuture(token);
    }
}

然后您可以使用它如下：

String token = "<YOUR_TOKEN_STRING>"
IAuthenticationProvider tokenCredentialAuthProvider = new DelegateAuthenticationProvider(token);

// Create the Graph Client with the given Token Provider
GraphServiceClient graphClient = GraphServiceClient.builder()
        .authenticationProvider(tokenCredentialAuthProvider)
        .buildClient();

如果您获得 GraphServiceException 代码 401 401 < /em>您应该更新您的令牌。

当您成功登录客户时，您可以通过以下方式获得令牌：

List<String> scopes = Arrays.asList("https://graph.microsoft.com/.default");
IAuthenticationProvider tokenCredentialAuthProvider = new TokenCredentialAuthProvider(scopes, clientSecretCredential);
String token = tokenCredentialAuthProvider.getAuthorizationTokenAsync("https://graph.microsoft.com/v1.0/me").get()

希望这会有所帮助。

Answer 3

您可以覆盖为GraphServiceClient提供的Authentication Provider，

import com.azure.core.credential.AccessToken;
import com.azure.core.credential.TokenCredential;
import com.azure.core.credential.TokenRequestContext;
import com.microsoft.graph.authentication.TokenCredentialAuthProvider;
import org.jetbrains.annotations.NotNull;

import java.net.URL;
import java.time.OffsetDateTime;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.CompletableFuture;

public class CachingTokenCredentialAuthProvider extends TokenCredentialAuthProvider {
    private final TokenCredential tokenCredential;
    private final TokenRequestContext context;
    private AccessToken accessToken;

    public CachingTokenCredentialAuthProvider(@NotNull List<String> scopes, @NotNull TokenCredential tokenCredential) {
        super(scopes, tokenCredential);
        if (!scopes.isEmpty()) {
            this.context = new TokenRequestContext();
            this.context.setScopes(scopes);
            this.tokenCredential = Objects.requireNonNull(tokenCredential, "tokenCredential parameter cannot be null.");
        } else {
            throw new IllegalArgumentException("scopes parameter cannot be null or empty");
        }
    }

    @NotNull
    @Override
    public CompletableFuture<String> getAuthorizationTokenAsync(@NotNull URL requestUrl) {
        if (this.shouldAuthenticateRequestWithUrl(Objects.requireNonNull(requestUrl, "requestUrl parameter cannot be null"))) {
            if(this.accessToken != null && !OffsetDateTime.now().minusMinutes(1).isAfter(this.accessToken.getExpiresAt())) {
                return CompletableFuture.completedFuture(this.accessToken.getToken());
            }

            return this.tokenCredential.getToken(this.context).toFuture().thenApply(accessToken -> {
                saveToken(accessToken);
                return accessToken.getToken();
            });
        } else {
            return CompletableFuture.completedFuture(null);
        }
    }

    void saveToken(AccessToken accessToken) {
        this.accessToken = accessToken;
    }
}

这将缓存令牌，直到一分钟不再有效。