PHPAPI任务超时怎么处理

wen PHP项目 2026-07-05 82

本文目录导读：

PHPAPI任务超时怎么处理

应用层处理（PHP代码层面）
服务器配置
超时处理策略
监控与告警
前端处理（浏览器端）
最佳实践建议

在PHP中处理API任务超时,需要从应用层、服务器层和任务设计层三个维度综合处理，以下是详细的解决方案：

应用层处理（PHP代码层面）

设置脚本执行时间

// 在脚本开头设置（仅适用于当前脚本）
set_time_limit(30); // 30秒超时，0表示无限制
// 使用try-catch捕获超时异常
try {
    // 执行API调用
    $result = api_call();
} catch (Throwable $e) {
    // 处理超时错误
    if (strpos($e->getMessage(), 'timeout') !== false) {
        // 记录日志、返回错误给客户端
    }
}

cURL超时控制（推荐用于HTTP API）

$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $api_url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_TIMEOUT, 10);        // 总体超时10秒
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);  // 连接超时5秒
curl_setopt($ch, CURLOPT_TIMEOUT_MS, 10000);  // 毫秒级超时(PHP 5.2.3+)
$result = curl_exec($ch);
if (curl_errno($ch) == CURLE_OPERATION_TIMEDOUT) {
    // 处理超时
}
curl_close($ch);

Guzzle HTTP客户端超时（现代化PHP）

use GuzzleHttp\Client;
use GuzzleHttp\Exception\ConnectException;
use GuzzleHttp\Exception\RequestException;
$client = new Client([
    'timeout'  => 5.0,  // 请求超时
    'connect_timeout' => 3.0, // 连接超时
]);
try {
    $response = $client->get($api_url);
    $body = $response->getBody();
} catch (ConnectException $e) {
    // 连接超时处理
} catch (RequestException $e) {
    // 请求失败处理
}

服务器配置

Nginx配置

# nginx.conf
location ~ \.php$ {
    fastcgi_read_timeout 30s;  # FastCGI超时
    proxy_read_timeout 30s;     # 代理超时
    proxy_connect_timeout 10s;  # 连接超时
}

Apache配置

# httpd.conf
<IfModule mod_fcgid.c>
    FcgidIOTimeout 60
    FcgidBusyTimeout 60
</IfModule>
# 或 mod_php
<IfModule mod_php.c>
    php_value max_execution_time 30
    php_value max_input_time 60
</IfModule>

PHP-FPM配置

; php-fpm.conf
request_terminate_timeout = 30s
request_slowlog_timeout = 10s
slowlog = /var/log/php-fpm-slow.log

超时处理策略

重试机制（带指数退避）

function api_call_with_retry($url, $max_retries = 3) {
    $retry_delays = [1, 2, 4]; // 秒
    for ($attempt = 0; $attempt <= $max_retries; $attempt++) {
        try {
            $result = make_api_call($url);
            return $result;
        } catch (TimeoutException $e) {
            if ($attempt == $max_retries) {
                throw $e; // 最终失败
            }
            sleep($retry_delays[$attempt] ?? 8);
        }
    }
}

异步处理方案

// 使用消息队列处理耗时API
// 1. 将任务放入队列
$queue->push(['task' => 'api_call', 'params' => $params]);
// 2. 立即返回给客户端
echo json_encode(['task_id' => $task_id, 'status' => 'queued']);
// 3. 后台Worker处理
// worker.php
while (true) {
    $task = $queue->pop();
    if ($task) {
        set_time_limit(300); // 长时间运行
        $result = api_call($task['params']);
        save_result($task['id'], $result);
    }
}

超时降级处理

class ApiHandler {
    public function getData() {
        try {
            $data = $this->fetchFromRemoteAPI();
        } catch (TimeoutException $e) {
            // 降级策略1：返回缓存数据
            $data = $this->getCachedData();
            // 降级策略2：返回默认数据
            $data = $this->getDefaultData();
            // 降级策略3：返回部分数据
            $data = $this->getPartialData();
        }
        return $data;
    }
}

监控与告警

记录超时日志

class TimeoutMonitor {
    public static function logTimeout($api_name, $timeout_value) {
        $log = sprintf(
            "[%s] API timeout: %s, timeout=%s\n",
            date('Y-m-d H:i:s'),
            $api_name,
            $timeout_value
        );
        file_put_contents('/var/log/api_timeout.log', $log, FILE_APPEND);
        // 可选：发送告警
        if (self::isCritical($api_name)) {
            self::sendAlert($log);
        }
    }
}

设置健康检查

// health_check.php
$timeout = 3; // 健康检查超时3秒
$api_health = [];
$target_apis = [
    'payment' => 'https://payment-api.com/health',
    'user'    => 'https://user-api.com/health'
];
foreach ($target_apis as $name => $url) {
    $start = microtime(true);
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    $response = curl_exec($ch);
    $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $elapsed = microtime(true) - $start;
    curl_close($ch);
    $api_health[$name] = [
        'status' => ($http_code == 200) ? 'healthy' : 'unhealthy',
        'response_time' => $elapsed,
        'timeout' => $elapsed > $timeout
    ];
}

前端处理（浏览器端）

对于用户等待的场景,前端也应该处理超时：

// JavaScript with AbortController
const controller = new AbortController();
const timeoutId = setTimeout(() => controller.abort(), 10000);
fetch('/api/slow-endpoint', { signal: controller.signal })
  .then(response => response.json())
  .catch(err => {
    if (err.name === 'AbortError') {
      // 处理超时
      showUserMessage('请求超时，请稍后重试');
    }
  })
  .finally(() => clearTimeout(timeoutId));