当前位置：首页 > PHP

php实现接口轮询

2026-01-30 08:14:50PHP

PHP实现接口轮询的方法

轮询是一种客户端定期向服务器发送请求以获取最新数据的技术。以下是几种常见的PHP实现方式：

基础HTTP轮询实现

使用简单的循环和sleep函数实现基本轮询：

$url = 'https://api.example.com/data';
$interval = 5; // 轮询间隔(秒)

while(true) {
    $response = file_get_contents($url);
    $data = json_decode($response, true);

    // 处理返回数据
    if($data['status'] === 'ready') {
        processData($data);
        break;
    }

    sleep($interval);
}

使用cURL的轮询实现

更健壮的cURL版本，支持超时和错误处理：

function pollApi($url, $maxAttempts = 10, $interval = 3) {
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

    $attempt = 0;
    while($attempt < $maxAttempts) {
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

        if($httpCode === 200) {
            $data = json_decode($response, true);
            if($data['status'] === 'completed') {
                curl_close($ch);
                return $data;
            }
        }

        sleep($interval);
        $attempt++;
    }

    curl_close($ch);
    return false;
}

带指数退避的轮询

在网络不稳定的情况下，采用指数退避策略：

function exponentialBackoffPolling($url, $maxRetries = 5) {
    $baseInterval = 1; // 初始间隔(秒)
    $maxInterval = 30; // 最大间隔(秒)

    for($retry = 0; $retry < $maxRetries; $retry++) {
        $response = file_get_contents($url);
        if($response !== false) {
            return json_decode($response, true);
        }

        $waitTime = min($maxInterval, $baseInterval * pow(2, $retry));
        sleep($waitTime);
    }

    return false;
}

使用数据库存储轮询状态

对于需要持久化状态的轮询任务：

function dbBasedPolling($taskId, $pdo) {
    $query = "SELECT status FROM async_tasks WHERE id = ?";
    $stmt = $pdo->prepare($query);

    while(true) {
        $stmt->execute([$taskId]);
        $result = $stmt->fetch(PDO::FETCH_ASSOC);

        if($result['status'] === 'COMPLETED') {
            return true;
        } elseif($result['status'] === 'FAILED') {
            return false;
        }

        sleep(5);
    }
}

前端配合的轮询实现

PHP后端提供状态检查接口，由前端JavaScript实现轮询：

// status_check.php
$taskId = $_GET['task_id'];
$status = checkTaskStatus($taskId); // 自定义状态检查函数

header('Content-Type: application/json');
echo json_encode(['status' => $status]);

前端JavaScript轮询代码示例：

php实现接口轮询

function pollStatus(taskId) {
    const interval = setInterval(async () => {
        const response = await fetch(`status_check.php?task_id=${taskId}`);
        const data = await response.json();

        if(data.status === 'completed') {
            clearInterval(interval);
            // 处理完成状态
        }
    }, 3000);
}