## 簡介 PRipple是一個高性能的原生PHP協程框架，旨在處理高并發、復雜的網絡通信和數據操作。項目基于PHP8.1自身的纖程特性 + Revolt工具庫實現，提供了更加簡單易用的API和工具，使得開發者可以輕松地構建高性能的PHP應用。 ## 特點 * 高性能: 通過使用原生PHP協程, 大幅提高了應用的并發處理能力 * 兼容性: 兼容現有的PHP框架和庫, 支持在`FPM/CLI`環境下使用 * 易于使用: 100%的PHP代碼實現,無需更多的學習成本,提供了簡單易用的API， * 協程調度: 使用 `Fiber` 和 `Promise` 機制, 實現了高效的協程調度。 * 異步I/O: 提供異步的網絡和文件`I/O`操作，避免阻塞。 * 高并發處理: 支持高并發請求處理，適用于實時應用和高負載場景。 * 易于集成: 可以與傳統項目無縫集成，提供簡單的安裝和使用指南。 ## 特性 ### 原生 基于PHP原生協程實現,100%的PHP代碼率, 無需第三方擴展, 所有函數都如你所知的方式工作, 無需額外的學習成本 ### 生態 保持所有組件的原生性, 提供豐富的生態支持, 與絕大多數的composer包兼容, 無需擔心生態問題 ### 集成 傳統的PHP框架支持高度集成, 無縫支持Laravel, Symfony, ThinkPHP, Yii等主流框架, 無需改動原有代碼, 支持FPM環境使用 ## 運行機制 Runtime ### 介紹 在PRipple中,所有define的異步閉包都由EventLoop驅動, EventLoop將會在恰當的時候運行指定事件, 開發者無需過于關心EventLoop的處理機制, 只需做好流程的控制, 不同的閉包可能會在不同的上下文空間中被執行, 開發過程中應該注意這些上下文空間的約束 PRipple對任何一個閉包的發生運行時都會特別聲明與嚴格把控, 所有對于插件/組件的開發者也應該關心這點,防止閉包發生進程/纖程逃逸, 運行黑洞的情況 ### 主程運行時 框架的的使用者幾乎不用關心該運行時,因為開發者的代碼通常運行在事件運行時與協程運行時上下文 進程的入口點, 構建PRipple的過程即是主程運行時, 它發生在PRipple驅動機之前, 以Laravel的入口文件為例子 ```php <?php use Illuminate\Http\Request; define('LARAVEL_START', microtime(true)); if (file_exists($maintenance = __DIR__.'/../storage/framework/maintenance.php')) { require $maintenance; } require __DIR__.'/../vendor/autoload.php'; //TODO: 主程運行時 \P\async(function(){ //TODO: 協程運行時,包括 Laravel中間件/服務提供者/控制器 等運行過程都處于協程序空間中 (require_once __DIR__.'/../bootstrap/app.php') ->handleRequest(Request::capture()); }); # 啟動PRipple \P\tick(); ``` ## 安裝 ### Composer 安裝 ``` composer require cclilshy/p-ripple-drive ``` ### Webman 配置 > 配置`config/server.php`文件 ``` <?php return [ //... 'event_loop' => \Psc\Drive\Workerman\PDrive::class, ]; ``` ## 使用方法 ### 手動創建 ~~~php public function index(Request $request): string { $handle = new \Psc\Plugins\Guzzle\PHandler([ 'pool' => 1 // 是否啟用Http長連接 ]); $client = new \GuzzleHttp\Client(['handle' => $handle]); // 發送請求(即使該請求耗時很長, 也不會堵塞當前進程的其他請求) $response = $client->get('http://www.baidu.com'); return $response->getBody()->getContents(); } ~~~ ### 全局使用(薦) ~~~php public function index(Request $request): string { $client = \P\Plugin::Guzzle(); // 發送請求(即使該請求耗時很長, 也不會堵塞當前進程的其他請求) $response = $client->get('http://www.baidu.com'); return $response->getBody()->getContents(); } ~~~ ## 效果演示 ~~~php use function P\async; use function P\await; /** * @desc 方法描述 * @param Request $request * @return string * @author Tinywan(ShaoBo Wan) */ public function index(Request $request): string { for ($i = 0; $i < 100; $i++) { async(function () use ($i) { $response = await(\P\Plugin::Guzzle()->getAsync('https://www.qq.com/')); $time = microtime(true); $responseStatusCode = $response->getStatusCode(); var_dump("[{$time}] request {$i} status: {$responseStatusCode}"); }); } return '開源技術小棧！'; } ~~~