如何在ReactPHP事件循环中无阻塞使用Guzzle 7实现带Cookie的异步请求

要在ReactPHP事件循环里实现带Cookie验证的非阻塞HTTP请求，核心是让Guzzle的CurlMultiHandler与React事件循环无缝集成，无需手动调用tick()或阻塞wait()。具体实现方案如下：

核心思路 #

Guzzle的CurlMultiHandler依赖文件描述符监听处理异步请求，我们可以将这些文件描述符注册到React事件循环中，让循环自动在有活动时触发tick()，替代手动定时轮询。同时用Guzzle的CookieJar管理验证所需的Cookie。

具体实现代码 #

确保已安装依赖：guzzlehttp/guzzle、react/event-loop

<?php

require 'vendor/autoload.php';

use React\EventLoop\Factory;
use GuzzleHttp\Client;
use GuzzleHttp\Handler\CurlMultiHandler;
use GuzzleHttp\Cookie\CookieJar;

// 初始化React事件循环
$loop = Factory::create();

// 创建CurlMultiHandler并禁用内部定时tick
$handler = new CurlMultiHandler([
    'tick_interval' => 0 // 关闭Guzzle自带的定时tick，交给React循环处理
]);

// 将CurlMultiHandler的文件描述符注册到React循环
foreach ($handler->getSelectFds() as $fd) {
    // 监听读事件
    $loop->addReadStream($fd, function ($fd) use ($handler) {
        $handler->tick();
    });
    // 监听写事件
    $loop->addWriteStream($fd, function ($fd) use ($handler) {
        $handler->tick();
    });
}

// 配置带Cookie的Guzzle客户端
$cookieJar = CookieJar::fromArray(
    ['auth_token' => 'your-valid-cookie-value'], // 替换为实际Cookie键值对
    'target-site.com' // 替换为目标网站域名
);

$client = new Client([
    'handler' => $handler,
    'cookies' => $cookieJar
]);

// 发起异步GET请求，非阻塞处理响应
$client->getAsync('https://target-site.com/protected-resource')
    ->then(function ($response) {
        echo "请求成功，状态码: " . $response->getStatusCode() . "\n";
        echo "响应内容:\n" . $response->getBody() . "\n";
    })
    ->otherwise(function (\Exception $e) {
        echo "请求失败: " . $e->getMessage() . "\n";
    });

// 启动React事件循环
$loop->run();

关键细节说明 #

1. 禁用内部tick：将CurlMultiHandler的tick_interval设为0，避免Guzzle内部定时任务与React循环冲突。
2. 文件描述符注册：通过getSelectFds()获取curl的读写文件描述符，注册到React循环的读/写流监听，当curl有数据需要处理时，循环会自动调用tick()，完全替代手动定时调用。
3. Cookie管理：CookieJar既可以预设置Cookie，也能在请求后自动保存响应中的Cookie，后续请求会自动带上（比如先登录获取Cookie，再访问受保护页面）。

动态Cookie场景示例 #

如果需要先登录获取Cookie再发起请求，只需复用同一个CookieJar即可：

<?php
// 复用上面的$loop和$handler初始化代码

$cookieJar = new CookieJar();
$client = new Client([
    'handler' => $handler,
    'cookies' => $cookieJar
]);

// 先发起登录请求获取Cookie
$client->postAsync('https://target-site.com/login', [
    'form_params' => [
        'username' => 'your-username',
        'password' => 'your-password'
    ]
])->then(function () use ($client) {
    // 登录成功后，用同一个CookieJar访问受保护页面
    return $client->getAsync('https://target-site.com/protected-resource');
})->then(function ($response) {
    echo "受保护页面响应: " . $response->getBody() . "\n";
})->otherwise(function (\Exception $e) {
    echo "流程失败: " . $e->getMessage() . "\n";
});

$loop->run();

内容的提问来源于stack exchange，提问作者James Risner