Rust中获取OAuth2 Token时服务器响应解析失败问题排查

问题现象 #

代码编译正常，但调用OAuth令牌接口时触发服务器错误。调试确认query.code为有效授权码，但无法成功获取Token。

错误日志 #

2024-03-26T20:40:52.505292Z ERROR rustapi::handlers::login_service: Application error: failed in sending request request to authorization server: Failed to parse server response: expected value at line 1 column 1

相关代码 #

令牌获取处理函数 #

pub async fn oauth_return(
    Query(query): Query<AuthRequest>,
    State(state): State<AppState>,
    Host(hostname): Host,
) -> Result<impl IntoResponse, ReturnError> {
    // Get an auth token
    let token = state.oauth_client
        .exchange_code(AuthorizationCode::new(query.code.clone()))
        .request_async(async_http_client)
        .await
        .context("failed in sending request request to authorization server")?;
    // ... 剩余代码
}

OAuth客户端初始化代码 #

pub(crate) fn oauth_client() -> Result<BasicClient, crate::types::OauthError> {
    let client_id = ClientId::new(env::var("CLIENT_ID")?);
    let client_secret = ClientSecret::new(env::var("CLIENT_SECRET")?);
    let redirect_url = "http://127.0.0.1:8080/auth/authorized".to_string();

    let auth_url = AuthUrl::new("https://accounts.google.com/o/oauth2/auth".to_string())
        .map_err(|_| "OAuth: invalid authorization endpoint URL")?;

    let token_url = TokenUrl::new("https://www.googleapis.com/oauth2/token".to_string())
        .map_err(|_| "OAuth: invalid token endpoint URL")?;

    let client = BasicClient::new(
        client_id,
        Some(client_secret),
        auth_url,
        Some(token_url),
    )
        .set_redirect_uri(RedirectUrl::new(redirect_url).map_err(|_| "OAuth: invalid redirect URL")?) 
        .set_revocation_uri(
            RevocationUrl::new("https://oauth2.googleapis.com/revoke".to_string())
                .map_err(|_| "OAuth: invalid revocation endpoint URL")?,
        );
    Ok(client)
}

排查原因及解决方法 #

原因1：HTTP客户端TLS配置缺失 #

若async_http_client未正确配置HTTPS支持（如缺少根证书），会导致请求失败，服务器返回非JSON内容（空响应、错误页面等），触发解析错误。

解决方法：

• 确保使用的HTTP客户端（如reqwest）启用TLS特性，在Cargo.toml中添加：

  reqwest = { version = "0.11", features = ["json", "async-std-tls"] }
  

• 直接调用谷歌令牌接口排查返回内容：

  let response = reqwest::Client::new()
      .post("https://www.googleapis.com/oauth2/token")
      .form(&[
          ("code", &query.code),
          ("client_id", &env::var("CLIENT_ID").unwrap()),
          ("client_secret", &env::var("CLIENT_SECRET").unwrap()),
          ("redirect_uri", "http://127.0.0.1:8080/auth/authorized"),
          ("grant_type", "authorization_code"),
      ])
      .send()
      .await?;
  println!("Response status: {}", response.status());
  println!("Response body: {}", response.text().await?);
  

根据返回内容判断是认证错误、网络问题还是其他异常。

原因2：重定向URI不匹配 #

谷歌开发者控制台中配置的重定向URI必须与代码中redirect_url完全一致（包括协议、域名、端口、路径），否则谷歌会返回错误页面而非JSON响应，导致解析失败。

解决方法：

• 登录谷歌开发者控制台，检查OAuth客户端的「已授权的重定向URI」列表，确保包含http://127.0.0.1:8080/auth/authorized；
• 注意localhost与127.0.0.1视为不同URI，必须完全匹配。

原因3：客户端凭证错误 #

若CLIENT_ID或CLIENT_SECRET配置错误（如多余空格、拼写错误），谷歌会返回非JSON的错误响应（如401页面），触发解析失败。

解决方法：

• 验证环境变量中的CLIENT_ID和CLIENT_SECRET与谷歌开发者控制台中的值完全一致；
• 通过上述直接调用的测试代码，查看返回的具体错误（如invalid_client、invalid_grant）。

原因4：oauth2库版本兼容性 #

不同版本的oauth2库对响应解析的逻辑可能存在差异，若使用版本与参考示例不一致，可能导致解析失败。

解决方法：

• 确保Cargo.toml中oauth2库版本与参考示例一致，例如：

  oauth2 = "4.3.0"
  

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