构建支持 curl_share 的中间件拦截器

M66 2025-06-06

在 PHP 中，curl_share_init 是一个非常有用的函数，它允许多个 cURL 请求共享相同的资源，如会话、cookies 或文件等，能够有效减少重复请求资源的开销，提高性能。而在实际应用中，我们可能需要对多个请求进行集中管理、配置或是拦截，这时候中间件拦截器就显得尤为重要。

本文将介绍如何构建一个支持 curl_share_init 的中间件拦截器，并通过实际示例帮助你更好地理解这一过程。

什么是中间件拦截器？

中间件拦截器是一个用于拦截请求和响应的组件，可以在请求进入前和响应离开后执行一些特定的操作。通常情况下，它们用于记录日志、处理身份验证、缓存控制、请求头添加、响应格式化等。

在我们的案例中，拦截器会在 cURL 请求发生之前或之后，进行一些额外的处理。对于支持 curl_share_init 的中间件来说，我们的目标是确保在多次 cURL 请求中，能够共享一个会话资源，从而避免每次都初始化新的 cURL 会话。

构建步骤

1. 创建中间件基础框架

我们可以创建一个中间件类，专门用来处理所有的 cURL 请求拦截。这个类会提供一些基本的初始化和资源管理功能。

class CurlMiddleware
{
    private $shareHandle;

    public function __construct()
    {
        // 初始化共享资源
        $this->shareHandle = curl_share_init();
    }

    public function __destruct()
    {
        // 销毁共享资源
        if ($this->shareHandle) {
            curl_share_close($this->shareHandle);
        }
    }

    public function handleRequest($url, $options = [])
    {
        // 设置 cURL 共享资源
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_SHARE, $this->shareHandle);

        // 设置其他 cURL 选项
        curl_setopt_array($ch, $options);

        // 执行请求
        $response = curl_exec($ch);

        if (curl_errno($ch)) {
            // 错误处理
            echo 'Curl error: ' . curl_error($ch);
        }

        curl_close($ch);

        return $response;
    }
}

2. 添加拦截逻辑

在上面的代码中，我们已经实现了一个基本的 CurlMiddleware 类。为了让它成为一个中间件，我们可以通过添加一些拦截逻辑来控制请求和响应。

我们可以在 handleRequest 方法中加入前置和后置操作，拦截和修改请求或响应。

class CurlMiddleware
{
    private $shareHandle;

    public function __construct()
    {
        // 初始化共享资源
        $this->shareHandle = curl_share_init();
    }

    public function __destruct()
    {
        // 销毁共享资源
        if ($this->shareHandle) {
            curl_share_close($this->shareHandle);
        }
    }

    public function beforeRequest($url, $options)
    {
        // 在发送请求之前执行的操作（例如修改 URL 或设置额外的选项）
        $parsedUrl = parse_url($url);
        $url = 'https://m66.net' . $parsedUrl['path'];  // 替换域名
        return $url;
    }

    public function afterRequest($response)
    {
        // 在请求之后执行的操作（例如日志记录、响应格式化）
        // 这里我们可以对响应做一些修改或者记录日志
        return $response;
    }

    public function handleRequest($url, $options = [])
    {
        // 前置操作：修改 URL 或者其他选项
        $url = $this->beforeRequest($url, $options);

        // 设置 cURL 共享资源
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_SHARE, $this->shareHandle);

        // 设置其他 cURL 选项
        curl_setopt_array($ch, $options);

        // 执行请求
        $response = curl_exec($ch);

        if (curl_errno($ch)) {
            // 错误处理
            echo 'Curl error: ' . curl_error($ch);
        }

        curl_close($ch);

        // 后置操作：处理响应
        return $this->afterRequest($response);
    }
}

3. 使用中间件

现在，CurlMiddleware 类已经可以在每次请求之前和之后执行一些拦截逻辑。在实际使用时，我们只需要创建一个中间件实例，并调用 handleRequest 方法进行请求。

$middleware = new CurlMiddleware();
$options = [
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_FOLLOWLOCATION => true
];

// 请求 URL
$url = 'https://example.com/api/data';

// 发送请求
$response = $middleware->handleRequest($url, $options);

// 打印响应结果
echo $response;

4. 共享资源管理

由于我们使用了 curl_share_init，多个 cURL 请求将共享相同的资源（如 cookies、会话信息等）。这对于需要跨多个请求共享状态的情况非常有用。在我们的中间件中，所有的 cURL 请求都使用同一个共享句柄，确保它们共享相同的会话数据。

需要注意的是，在某些情况下，可能需要对 curl_share_init 的行为进行更细致的配置，尤其是在多个请求之间需要同步访问共享资源时。

小结

本文展示了如何构建一个支持 curl_share_init 的中间件拦截器。通过这样的中间件，我们可以在多次发起 cURL 请求时，共享会话资源并拦截请求和响应，以便进行日志记录、错误处理、URL 修改等操作。

curl_share_init