Google API RefreshTokenAsync返回false问题及异步调用差异排查

问题背景 #

我使用Google.Apis.Auth库的UserCredential.RefreshTokenAsync方法刷新OAuth令牌时遇到了异常情况：

• 最初直接调用credential.RefreshTokenAsync(CancellationToken.None).Result时，时常返回false（已确认RefreshToken不为空，查看源码发现仅当RefreshToken为空时才会返回false）
• 尽管日志中大量报错，但实际仍能正常访问Google Workspace邮箱
• 改为Task.Run(async() => await credential.RefreshTokenAsync(CancellationToken.None)).Result调用后，测试12小时以上未再出现失败

两种调用方式的核心差异 #

1. 同步上下文的绑定与脱离 #

直接调用.Result时，当前线程的同步上下文（比如ASP.NET传统管道的请求上下文、WinForms/WPF的UI线程上下文）会被保留。RefreshTokenAsync内部的await操作完成后，默认会尝试回到原同步上下文执行后续逻辑（比如更新令牌到DataStore）。如果原上下文因.Result调用被阻塞，就会触发上下文死锁，导致异步逻辑的后续步骤无法正常完成，最终方法错误返回false。

而Task.Run会将异步操作委托给线程池线程执行，完全脱离原同步上下文。RefreshTokenAsync内部的await无需再回到原上下文，异步逻辑可以完整执行，避免了上下文相关的异常或执行中断。

2. 异常处理的隐性差异 #

直接调用.Result时，异步方法抛出的异常会被包装为AggregateException；而Task.Run结合await的方式，虽然最终仍用.Result阻塞，但异步逻辑内部的异常会被正确展开。更关键的是，同步上下文死锁会导致异步逻辑中途终止，方法未完成令牌刷新流程就返回false，而非因为RefreshToken无效。

为什么报错但功能正常？ #

Google.Apis.Auth客户端库内部存在自动令牌刷新和缓存机制：

• 即使显式调用的RefreshTokenAsync返回false，后续实际发起API请求（比如访问Gmail）时，库会自动检查令牌状态并重新尝试刷新
• 另外，IsExpired的判断存在微小时间差，调用刷新时令牌可能尚未完全过期，后续请求仍可使用原令牌，因此功能不受影响

更优的解决方案 #

虽然Task.Run的方式暂时解决了问题，但全程异步化才是根本方案，应避免使用.Result/.Wait()这类阻塞调用：

1. 将GetImapAccessToken改为异步方法：

public async Task<string> GetImapAccessTokenAsync(string localStorageId, string username)
{
    var tokenResponse = await _dataStore.GetAsync<TokenResponse>(localStorageId);

    var clientSecrets = new ClientSecrets
    {
        ClientId = "TODO:GoogleClientId",
        ClientSecret = "TODO:GoogleClientSecret"
    };

    IAuthorizationCodeFlow flow = new GoogleAuthorizationCodeFlow(
        new GoogleAuthorizationCodeFlow.Initializer
        {
            ClientSecrets = clientSecrets,
            Scopes = _scopes,
            DataStore = _dataStore
        });
    var credential = new UserCredential(flow, localStorageId, tokenResponse);

    await RefreshExpiredTokenAsync(credential, false);
    return credential.Token.AccessToken;
}

2. 同步修改RefreshExpiredToken为异步方法：

private async Task RefreshExpiredTokenAsync(UserCredential credential, bool force)
{
    if (!force && !credential.Token.IsExpired(SystemClock.Default))
        return;

    var originalRefreshToken = credential.Token.RefreshToken;
    
    var success = await credential.RefreshTokenAsync(CancellationToken.None);
    if (success)
        Log.Info($"RefreshTokenAsync succeeded. UserId=[{credential.UserId}]");
    else
    {
        Log.Error(originalRefreshToken == null
            ? $"RefreshTokenAsync failed. UserId=[{credential.UserId}]. Original RefreshToken=[NULL]"
            : $"RefreshTokenAsync failed. UserId=[{credential.UserId}]. Original RefreshToken=[{originalRefreshToken}]");
    }
}

这种方式从根源上避免了同步上下文阻塞和死锁风险，代码也更符合异步编程的最佳实践。

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