告別PHP阻塞等待：GuzzlePromises如何優(yōu)雅處理異步操作

composer require guzzlehttp/promises

use GuzzleHttpPromisePromise;  // 創(chuàng)建一個(gè)新的Promise $promise = new Promise();  // 注冊回調(diào)函數(shù)：當(dāng)Promise被兌現(xiàn)時(shí)執(zhí)行onFulfilled，被拒絕時(shí)執(zhí)行onRejected $promise->then(     // $onFulfilled 回調(diào)：接收兌現(xiàn)的值     function ($value) {         echo "操作成功： " . $value . "n";     },     // $onRejected 回調(diào)：接收拒絕的原因     function ($reason) {         echo "操作失敗： " . $reason . "n";     } );  // 模擬異步操作完成并兌現(xiàn)Promise // 假設(shè)這里是某個(gè)耗時(shí)操作完成后，我們得到了一個(gè)結(jié)果 echo "異步操作開始...n"; // 可以在某個(gè)條件滿足時(shí)調(diào)用 resolve 或 reject if (rand(0, 1)) {     $promise->resolve('數(shù)據(jù)已成功獲取！'); } else {     $promise->reject('網(wǎng)絡(luò)連接超時(shí)！'); }  // 注意：在沒有事件循環(huán)的情況下，需要手動(dòng)運(yùn)行任務(wù)隊(duì)列來確保回調(diào)被執(zhí)行 // 對于簡單的同步測試，Guzzle Promise會(huì)自動(dòng)在wait()時(shí)運(yùn)行隊(duì)列 // 但在真正的異步場景下（如結(jié)合ReactPHP），需要周期性運(yùn)行 GuzzleHttpPromiseUtils::queue()->run();

use GuzzleHttpPromisePromise;  $firstPromise = new Promise();  $firstPromise     ->then(function ($initialValue) {         echo "第一步：處理初始值 - " . $initialValue . "n";         // 返回一個(gè)新的值，這個(gè)值將作為下一個(gè)then的輸入         return $initialValue . " -> 經(jīng)過處理";     })     ->then(function ($processedValue) {         echo "第二步：處理中間值 - " . $processedValue . "n";         // 你也可以在這里返回一個(gè)新的Promise，后續(xù)的then會(huì)等待這個(gè)新Promise完成         $anotherPromise = new Promise();         $anotherPromise->resolve('最終數(shù)據(jù)');         return $anotherPromise;     })     ->then(function ($finalValue) {         echo "第三步：得到最終結(jié)果 - " . $finalValue . "n";     })     ->otherwise(function ($reason) { // 使用otherwise()更清晰地處理拒絕         echo "鏈中發(fā)生錯(cuò)誤：" . $reason . "n";     });  // 模擬異步操作的開始 $firstPromise->resolve('原始數(shù)據(jù)');  // 確保所有回調(diào)執(zhí)行 GuzzleHttpPromiseUtils::queue()->run();

use GuzzleHttpPromisePromise; use GuzzleHttpPromiseRejectedPromise;  $apiCallPromise = new Promise();  $apiCallPromise     ->then(function ($response) {         if ($response['status'] !== 200) {             // 如果響應(yīng)狀態(tài)碼不是200，則拒絕這個(gè)Promise             throw new Exception("API返回錯(cuò)誤碼: " . $response['status']);         }         echo "api調(diào)用成功，處理數(shù)據(jù)...n";         return $response['data'];     })     ->then(function ($data) {         // 進(jìn)一步處理數(shù)據(jù)         echo "數(shù)據(jù)處理完成: " . $data . "n";     })     ->otherwise(function (Throwable $e) { // 捕獲鏈中的任何異常或拒絕         echo "發(fā)生錯(cuò)誤： " . $e->getMessage() . "n";         // 可以在這里進(jìn)行錯(cuò)誤日志記錄、回滾操作等         // 如果這里不返回任何東西，鏈會(huì)繼續(xù)向下傳遞拒絕狀態(tài)         // 如果返回一個(gè)普通值，后續(xù)的then會(huì)接收這個(gè)值（從錯(cuò)誤中恢復(fù)）         // 如果返回一個(gè)RejectedPromise，則繼續(xù)傳遞拒絕         return new RejectedPromise("錯(cuò)誤已處理，但仍拒絕: " . $e->getMessage());     })     ->then(null, function ($finalReason) { // 捕獲上一個(gè)otherwise返回的拒絕         echo "最終錯(cuò)誤處理：" . $finalReason . "n";     });  // 模擬API調(diào)用失敗 $apiCallPromise->resolve(['status' => 500, 'message' => 'Internal Server Error']);  // 確保所有回調(diào)執(zhí)行 GuzzleHttpPromiseUtils::queue()->run();

use GuzzleHttpClient; use GuzzleHttpPromiseUtils;  $client = new Client();  // 同時(shí)發(fā)起多個(gè)異步請求 $promises = [     'users' => $client->getAsync('https://api.example.com/users'),     'products' => $client->getAsync('https://api.example.com/products'),     'orders' => $client->getAsync('https://api.example.com/orders'), ];  // 等待所有Promise完成 $results = Utils::settle($promises)->wait();  foreach ($results as $key => $result) {     if ($result['state'] === 'fulfilled') {         echo "{$key} 數(shù)據(jù)獲取成功: " . $result['value']->getBody() . "n";     } else {         echo "{$key} 數(shù)據(jù)獲取失敗: " . $result['reason']->getMessage() . "n";     } }