PHP curl_close函数

示例 4：长时间运行脚本中的资源管理

@php
// 在长时间运行的脚本中（如守护进程、队列处理器），资源管理尤为重要

class LongRunningService {
    private $memoryLimit;
    private $requestCount = 0;

    public function __construct($memoryLimit = '128M') {
        $this->memoryLimit = $memoryLimit;
        // 设置内存限制
        ini_set('memory_limit', $memoryLimit);
    }

    public function processQueue($maxRequests = 100) {
        echo "开始处理队列，最大请求数: {$maxRequests}\n";
        echo "内存限制: " . ini_get('memory_limit') . "\n";

        for ($i = 0; $i < $maxRequests; $i++) {
            $this->requestCount++;

            // 监控内存使用
            $memoryUsage = memory_get_usage(true);
            $memoryUsageMB = round($memoryUsage / 1024 / 1024, 2);
            echo "请求 {$this->requestCount} - 内存使用: {$memoryUsageMB} MB\n";

            // 处理单个请求
            $this->processSingleRequest();

            // 定期检查内存使用，必要时进行垃圾回收
            if ($this->requestCount % 10 === 0) {
                $this->performCleanup();
            }

            // 模拟处理间隔
            sleep(1);
        }

        echo "队列处理完成，总共处理了 {$this->requestCount} 个请求\n";
    }

    private function processSingleRequest() {
        $ch = curl_init();

        try {
            curl_setopt_array($ch, [
                CURLOPT_URL => "https://httpbin.org/delay/1", // 模拟1秒延迟的API
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_TIMEOUT => 5
            ]);

            $response = curl_exec($ch);

            if ($response !== false) {
                // 处理响应数据
                $data = json_decode($response, true);
                echo "请求成功: " . $data['url'] . "\n";
            } else {
                echo "请求失败: " . curl_error($ch) . "\n";
            }

        } catch (Exception $e) {
            echo "处理请求时发生异常: " . $e->getMessage() . "\n";

        } finally {
            // 关键：确保在每次请求后都关闭cURL会话
            if (is_resource($ch)) {
                curl_close($ch);
            }
        }
    }

    private function performCleanup() {
        echo "执行清理操作...\n";

        // 强制垃圾回收
        $collected = gc_collect_cycles();
        echo "垃圾回收器回收了 {$collected} 个循环引用\n";

        // 显示当前内存状态
        $memoryUsage = memory_get_usage(true);
        $peakMemory = memory_get_peak_usage(true);

        echo "当前内存: " . round($memoryUsage / 1024 / 1024, 2) . " MB\n";
        echo "峰值内存: " . round($peakMemory / 1024 / 1024, 2) . " MB\n";
    }
}

// 运行长时间服务
$service = new LongRunningService('256M');
$service->processQueue(5); // 处理5个请求作为演示
@endphp