如何解决Agent failed before reply: OAuth token refresh failed for Qwen-Portal错误

1次阅读

共计 2819 个字符，预计需要花费 8 分钟才能阅读完成。

OAuth 2.0 是现代 API 认证的黄金标准，而 token 刷新机制是其核心功能之一。在 Qwen-Portal 这类需要长期保持连接的服务中，access_token 的有效期通常较短（如 1 小时），而 refresh_token 的有效期较长（如 30 天）。当 access_token 过期时，系统需要自动使用 refresh_token 获取新的 access_token，避免用户重新登录。

遇到 oauth token refresh failed 错误时，通常由以下原因导致：

Refresh Token 过期或失效：可能因为超过有效期、被主动撤销或用户修改了密码
网络问题：在向认证服务器发起请求时出现网络波动或超时
权限不足 ：客户端可能缺少offline_access 权限（获取 refresh_token 必需）
配置错误：客户端 ID/ 密钥不匹配、回调地址未正确配置等
并发冲突：多个线程同时尝试刷新同一个 token

检查当前 token 是否临近过期（建议提前 5 分钟刷新）
使用 refresh_token 向认证端点发起 POST 请求
实现指数退避 (backoff) 重试机制
更新本地 token 存储
记录监控指标

import requests
from time import sleep
import logging

class TokenManager:
    def __init__(self, client_id, client_secret):
        self.client_id = client_id
        self.client_secret = client_secret
        self.token_url = "https://qwen-portal.com/oauth/token"

    def refresh_token(self, refresh_token):
        """
        带重试机制的 token 刷新方法
        :param refresh_token: 现有的 refresh_token
        :return: 新的 access_token 和 refresh_token
        """payload = {'grant_type':'refresh_token','refresh_token': refresh_token,'client_id': self.client_id,'client_secret': self.client_secret}

        max_retries = 3
        for attempt in range(max_retries):
            try:
                response = requests.post(self.token_url, data=payload, timeout=5)
                response.raise_for_status()
                new_tokens = response.json()
                return new_tokens['access_token'], new_tokens.get('refresh_token', refresh_token)

            except requests.exceptions.RequestException as e:
                if attempt == max_retries - 1:
                    logging.error(f"Token refresh failed after {max_retries} attempts: {str(e)}")
                    raise

                wait_time = (2 ** attempt) + random.random()
                sleep(wait_time)
                continue

public class TokenRefresher {
    private static final int MAX_RETRIES = 3;

    public TokenPair refreshToken(String refreshToken, OAuthConfig config) {HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(config.getTokenEndpoint()))
                .header("Content-Type", "application/x-www-form-urlencoded")
                .POST(HttpRequest.BodyPublishers.ofString(buildFormData(refreshToken, config)))
                .build();

        for (int i = 0; i < MAX_RETRIES; i++) {
            try {HttpResponse<String> response = HttpClient.newHttpClient()
                        .send(request, HttpResponse.BodyHandlers.ofString());

                if (response.statusCode() == 200) {return parseTokenResponse(response.body());
                }
            } catch (Exception e) {if (i == MAX_RETRIES - 1) {throw new TokenRefreshException("Failed after" + MAX_RETRIES + "attempts", e);
                }

                try {Thread.sleep((long) (Math.pow(2, i) * 1000 + Math.random() * 1000));
                } catch (InterruptedException ie) {Thread.currentThread().interrupt();}
            }
        }
        throw new TokenRefreshException("Maximum retry attempts reached");
    }
}