如何解决PHP应用中API请求阻塞问题，并使用Composer和GuzzlePromises提升并发效率

<pre class="brush:php;toolbar:false;">foreach ($recipients as $recipient) {
    // 假设这里是同步的SparkPost API调用
    $sparky->transmissions->post([
        'content' => [...],
        'recipients' => [['address' => ['email' => $recipient->email]]]
    ]);
    // 每次调用都会等待SparkPost服务器响应，耗时！
}
echo "所有邮件发送请求已完成。"; // 这句话可能要等很久才能打印出来

<pre class="brush:php;toolbar:false;"># 首先确保你的项目已经初始化了Composer
# 如果没有，可以在项目根目录运行：composer init

# 安装 SparkPost 客户端库
composer require sparkpost/sparkpost

# SparkPost 客户端库依赖于 HTTPlug 抽象层，我们需要一个具体的 HTTP 客户端实现。
# Guzzle 是一个流行的选择。这里我们安装 Guzzle 6 适配器和 Guzzle 本身。
composer require php-http/guzzle6-adapter "^1.1"
composer require guzzlehttp/guzzle "^6.0"

<pre class="brush:php;toolbar:false;">// 引入Composer的自动加载文件
require 'vendor/autoload.php';

// 导入必要的类
use SparkPost\SparkPost;
use GuzzleHttp\Client;
use Http\Adapter\Guzzle6\Client as GuzzleAdapter;

// ... 你的代码 ...

<pre class="brush:php;toolbar:false;">// 确保你已经设置了SPARKPOST_API_KEY环境变量
// 或者直接将API Key写入配置，但在生产环境不推荐硬编码
$httpClient = new GuzzleAdapter(new Client());
$sparky = new SparkPost($httpClient, [
    'key' => getenv('SPARKPOST_API_KEY'),
    'async' => true // 关键：将客户端设置为异步模式
]);

<pre class="brush:php;toolbar:false;">$recipients = [
    ['email' => 'user1@example.com', 'name' => 'User One'],
    ['email' => 'user2@example.com', 'name' => 'User Two'],
    // ... 更多收件人
];

$promises = [];
foreach ($recipients as $recipient) {
    $promises[] = $sparky->transmissions->post([
        'content' => [
            'from' => ['name' => 'Your App', 'email' => 'no-reply@yourdomain.com'],
            'subject' => '异步邮件测试',
            'html' => '<h1>你好, {{name}}!</h1><p>这是一封异步发送的邮件。</p>',
        ],
        'substitution_data' => ['name' => $recipient['name']],
        'recipients' => [['address' => ['email' => $recipient['email']]]],
    ])->then(
        // 成功回调：当这封邮件发送请求成功时执行
        function ($response) use ($recipient) {
            echo "邮件发送给 {$recipient['email']} 成功！状态码: " . $response->getStatusCode() . "\n";
        },
        // 失败回调：当这封邮件发送请求失败时执行
        function (\Exception $e) use ($recipient) {
            echo "邮件发送给 {$recipient['email']} 失败！错误: " . $e->getMessage() . "\n";
        }
    );
}

// 使用 GuzzleHttp\Promise\all() 等待所有 Promise 完成
// 这会等待所有异步请求完成，但它们是并行执行的，而不是顺序等待。
GuzzleHttp\Promise\Utils::all($promises)->wait();

echo "所有邮件发送请求（无论成功或失败）都已处理完毕。\n";