Revolt是并發PHP應用程序的堅如磐石的事件循環。通常的PHP應用程序將大部分時間花在等待I/O上。雖然PHP是單線程的,但可以使用協作多任務來允許并發性,方法是使用等待時間來做不同的事情。
PHP的傳統同步執行流程很容易理解。一次只做一件事。如果查詢數據庫,則發送查詢并等待數據庫服務器的響應。一旦你有了答案,你就可以開始做下一件事。
ReactPHP和其他庫已經在PHP中提供了很長一段時間的協作多任務。然而,它們的事件驅動特性與許多現有的接口不兼容,需要不同的思維模型。PHP 8.1內置了fibers,它提供了協作多線程。調用可以是異步的,沒有promise或回調,同時仍然允許非阻塞I/O。
每個使用協同多任務的應用程序都需要一個調度器(也稱為事件循環),這個包提供了這個調度器。Revolt是結合了React和ReactPHP的事件循環實現的多年經驗的結果。然而,它并不是一個用于編寫并發PHP應用程序的成熟框架,而只是提供了必要的公共基礎。不同的(強烈的)固執己見的庫可以在它的基礎上構建,React和ReactPHP將繼續共存。
composer require revolt/event-loop
注意:此包可以作為Composer依賴項安裝在PHP 8.1及更高版本上。
<?phprequire __DIR__ . '/vendor/autoload.php';use Revolt/EventLoop;$suspension = EventLoop::getSuspension();$repeatId = EventLoop::repeat(1, function (): void { print '++ Executing callback created by EventLoop::repeat()' . PHP_EOL;});EventLoop::delay(5, function () use ($suspension, $repeatId): void { print '++ Executing callback created by EventLoop::delay()' . PHP_EOL; EventLoop::cancel($repeatId); $suspension->resume(null); print '++ Suspension::resume() is async!' . PHP_EOL;});print '++ Suspending to event loop...' . PHP_EOL;$suspension->suspend();print '++ Script end' . PHP_EOL;
在執行上面的例子時,你應該看到這樣的輸出:
++ Suspending to event loop...++ Executing callback created by EventLoop::repeat()++ Executing callback created by EventLoop::repeat()++ Executing callback created by EventLoop::repeat()++ Executing callback created by EventLoop::repeat()++ Executing callback created by EventLoop::delay()++ Suspension::resume() is async!++ Script end
這個輸出說明了事件循環內部發生的事情就像它自己獨立的程序一樣。您的腳本將不會繼續通過 $suspension->suspend() 點,除非掛起點通過 $suspension->resume() 或 $suspension->throw() 恢復。
雖然一個應用程序可以而且經常幾乎完全在事件循環的范圍內發生,但我們也可以使用事件循環來做一些事情,比如下面的例子,它為交互式控制臺輸入施加了一個短暫的超時:
<?phprequire __DIR__ . '/vendor/autoload.php';use Revolt/EventLoop;if (/stream_set_blocking(STDIN, false) !== true) { /fwrite(STDERR, "Unable to set STDIN to non-blocking" . PHP_EOL); exit(1);}print "Write something and hit enter" . PHP_EOL;$suspension = EventLoop::getSuspension();$readableId = EventLoop::onReadable(STDIN, function ($id, $stream) use ($suspension): void { EventLoop::cancel($id); $chunk = /fread($stream, 8192); print "Read " . /strlen($chunk) . " bytes" . PHP_EOL; $suspension->resume(null);});$timeoutId = EventLoop::delay(5, function () use ($readableId, $suspension) { EventLoop::cancel($readableId); print "Timeout reached" . PHP_EOL; $suspension->resume(null);});$suspension->suspend();EventLoop::cancel($readableId);EventLoop::cancel($timeoutId);
顯然,我們可以在這個例子中簡單地同步使用 fgets(STDIN) 。我們只是在演示可以根據需要進出事件循環,以混合同步任務和非阻塞任務。
事件循環公開了幾種調度計時器的方法。
Deferred 回調
案例
<?php/** * @author Tinywan(ShaoBo Wan) * @email 756684177@qq.com * @date 2024/1/31 18:24 */require 'vendor/autoload.php';use Revolt/EventLoop;echo "line 1/n";EventLoop::defer(function (): void { echo "line 3/n";});echo "line 2/n";EventLoop::run();
輸出
line 1line 2line 3
Delayed 回調
案例
<?php/** * @author Tinywan(ShaoBo Wan) * @email 756684177@qq.com * @date 2024/1/31 18:24 */require 'vendor/autoload.php';use Revolt/EventLoop;EventLoop::delay(3, function (): void { print '3 seconds passed';});EventLoop::run();
3秒后輸出
3 seconds passed
Periodic 定期回調
案例
<?php/** * @author Tinywan(ShaoBo Wan) * @email 756684177@qq.com * @date 2024/1/31 18:49 */require 'vendor/autoload.php';use Revolt/EventLoop;EventLoop::repeat(0.1, function ($callbackId): void { static $i = 0; if ($i++ < 3) { echo "tick/n"; } else { EventLoop::cancel($callbackId); }});EventLoop::run();
輸出
tickticktick
定時器偏差
重復計時器基本上是簡單的延遲計時器,在觸發適當的處理程序之前會自動重新調度。它們受定時器漂移的影響。多個計時器可能會堆疊在一起,以防它們作為協程執行。
Revolt被設計為可以很好地與纖維一起工作。所有事件回調都在單獨的纖程中運行,并且可以隨時掛起它。如果在事件回調中沒有掛起,則纖程將被重用于將來的事件回調以保存資源。
掛起允許通過掛起當前執行上下文來等待事件,直到所討論的事件發生。它們將掛起當前纖程并返回到事件循環,或者如果從纖程外部(即從 {main} )調用,則開始運行事件循環。
應使用 Revolt/EventLoop/Suspension API暫停和恢復光纖。Suspension 對象可以使用 Revolt/EventLoop::getSuspension() 創建。在獲得 Suspension 對象之后,可以注冊事件回調以調度當前纖程的恢復。$suspension->suspend() 將掛起當前的執行上下文,直到它通過 $suspension->resume() 或 $suspension->throw()恢復。
案例:讓我們暫停主執行上下文,直到有數據從 STDIN 讀取或超時到期:
<?phprequire __DIR__ . '/vendor/autoload.php';use Revolt/EventLoop;if (/stream_set_blocking(STDIN, false) !== true) { /fwrite(STDERR, "Unable to set STDIN to non-blocking" . PHP_EOL); exit(1);}print "Write something and hit enter" . PHP_EOL;$suspension = EventLoop::getSuspension();$readableId = EventLoop::onReadable(STDIN, function ($id, $stream) use ($suspension): void { EventLoop::cancel($id); $chunk = /fread($stream, 8192); print "Read " . /strlen($chunk) . " bytes" . PHP_EOL; $suspension->resume(null);});$timeoutId = EventLoop::delay(5, function () use ($readableId, $suspension) { EventLoop::cancel($readableId); print "Timeout reached" . PHP_EOL; $suspension->resume(null);});$suspension->suspend();EventLoop::cancel($readableId);EventLoop::cancel($timeoutId);
自動超時輸出
Write something and hit enterTimeout reached
按Enter鍵盤輸出
Write something and hit enterRead 1 bytes
信號是類Unix操作系統中的標準化消息。
EventLoop::onSignal() 可用于對發送到進程的信號作出反應。
<?phprequire __DIR__ . '/vendor/autoload.php';use Revolt/EventLoop;// Let's tick off output once per second, so we can see activity.EventLoop::repeat(1, function (): void { echo "tick: ", date('c'), "/n";});// What to do when a SIGINT signal is receivedEventLoop::onSignal(SIGINT, function (): void { echo "Caught SIGINT! exiting .../n"; exit;});EventLoop::run();
SIGINT 信號: 當用戶按某些終端鍵時, 引發終端產生的信號. 如Ctrl+C鍵, 這將產生中斷信號SIGINT. 它將停止一個已失去控制的程序。
Ctrl+C 輸出
tick: 2024-01-31T11:54:03+00:00tick: 2024-01-31T11:54:04+00:00tick: 2024-01-31T11:54:05+00:00tick: 2024-01-31T11:54:06+00:00tick: 2024-01-31T11:54:07+00:00tick: 2024-01-31T11:54:08+00:00tick: 2024-01-31T11:54:09+00:00tick: 2024-01-31T11:54:10+00:00tick: 2024-01-31T11:54:11+00:00tick: 2024-01-31T11:54:12+00:00^CCaught SIGINT! exiting ...
從基本原理中可以清楚地看到,信號回調可以像任何其他事件回調一樣被啟用、禁用和取消。一般來說,如果所有回調都消失了,只有信號回調仍然存在,那么您希望退出事件循環,除非您沒有主動等待該事件發生。
ext-uv 暴露 UV::SIG* 常量用于可觀察信號。使用 EventDriver 的應用程序在注冊信號回調或依賴 ext-pcntl 時需要手動指定適當的整數信號編號。
本文鏈接:http://www.www897cc.com/showinfo-26-70393-0.htmlPHP 高性能的事件循環庫 Revolt
聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com
上一篇: 異步Rust:構建實時消息代理服務器