PHP中如何有效处理token的缓存问题以减少API请求次数？

wufei123 2025-04-06 阅读:8 评论:0

优化PHP Token缓存机制，降低API调用频率在PHP项目中，尤其涉及微信API等第三方接口时，高效管理Token至关重要。本文针对Token缓存问题，提供优化方案，有效减少API请求次数。现有代码存在的问题：将Token存储于S...

php中如何有效处理token的缓存问题以减少api请求次数？

优化PHP Token缓存机制，降低API调用频率

在PHP项目中，尤其涉及微信API等第三方接口时，高效管理Token至关重要。本文针对Token缓存问题，提供优化方案，有效减少API请求次数。

现有代码存在的问题：将Token存储于Session中，且逻辑存在缺陷。Session存储不适合高并发场景，而代码中的if-else结构导致第一次请求总是获取Token，无法直接执行业务逻辑。此外，120秒的过期时间过短，频繁刷新Token，反而增加了API请求。

改进方案：采用文件缓存机制，并优化代码逻辑

使用文件缓存，可以避免Session的并发问题和性能瓶颈。文件内容格式为cache_time access_token，定期更新。为了避免并发读写冲突，采用文件锁机制。

改进后的代码：

PHP

<?php
header("Content-type:text/html;charset=utf-8");
$cacheFile = __DIR__ . '/access_token.cache'; // 缓存文件路径

function getAccessToken($appId, $appSecret) {
    $tokenUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appId}&secret={$appSecret}";
    $ch = curl_init();
    curl_setopt_array($ch, [
        CURLOPT_URL => $tokenUrl,
        CURLOPT_SSL_VERIFYPEER => false,
        CURLOPT_SSL_VERIFYHOST => false,
        CURLOPT_RETURNTRANSFER => true,
    ]);
    $response = curl_exec($ch);
    curl_close($ch);
    $data = json_decode($response, true);
    if (isset($data['access_token'])) {
        return $data;
    } else {
        return false; // 获取Token失败
    }
}

function cacheAccessToken($accessToken, $expireTime) {
    global $cacheFile;
    $data = "{$expireTime} {$accessToken}";
    if (!file_exists($cacheFile)) {
        touch($cacheFile);
    }
    if (flock($cacheFile, LOCK_EX)) { // 获取独占锁
        file_put_contents($cacheFile, $data);
        flock($cacheFile, LOCK_UN); // 释放锁
    }
}

function getCachedAccessToken() {
    global $cacheFile;
    if (file_exists($cacheFile)) {
        if (flock($cacheFile, LOCK_SH)) { // 获取共享锁
            $data = file_get_contents($cacheFile);
            flock($cacheFile, LOCK_UN); // 释放锁
            list($cacheTime, $accessToken) = explode(' ', $data, 2);
            if (time() < $cacheTime) {
                return $accessToken;
            }
        }
    }
    return false;
}

// ... (其余代码保持不变，仅修改Token获取和使用部分) ...

$accessToken = getCachedAccessToken();
if (!$accessToken) {
    $appId = 'xxx';
    $appSecret = 'xxx';
    $tokenData = getAccessToken($appId, $appSecret);
    if ($tokenData) {
        $accessToken = $tokenData['access_token'];
        $expireTime = time() + $tokenData['expires_in'] - 600; // 预留600秒缓冲
        cacheAccessToken($accessToken, $expireTime);
    } else {
        // 处理获取Token失败的情况
        die("获取access_token失败");
    }
}

$url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" . $accessToken;
// ... (发送消息的代码保持不变) ...