協程
從 4.0
版本開始 Swoole
提供了完整的協程(Coroutine
)+ 通道(Channel
)特性,帶來全新的 CSP 編程模型
。應用層可使用完全同步的編程方式,底層自動實現異步IO。
協程可以理解為純用戶態的線程,其通過協作而不是搶占來進行切換。相對于進程或者線程,協程所有的操作都可以在用戶態完成,創建和切換的消耗更低。Swoole
可以為每一個請求創建對應的協程,根據 IO
的狀態來合理的調度協程,這會帶來了以下優勢:
- 開發者可以無感知的用同步的代碼編寫方式達到
異步IO
的效果和性能,避免了傳統異步回調所帶來的離散的代碼邏輯和陷入多層回調中導致代碼無法維護; - 同時由于底層封裝了協程,所以對比傳統的
PHP
層協程框架,開發者不需要使用yield
關鍵詞來標識一個協程IO操作
,所以不再需要對yield
的語義進行深入理解以及對每一級的調用都修改為yield
,這極大地提高了開發效率; - 可以滿足大部分開發者的需求。對于私有協議,開發者可以使用協程的
TCP
或者UDP
接口去方便的封裝。
注意事項
- 全局變量:協程使得原有的異步邏輯同步化,但是在協程中的切換是隱式發生的,所以在協程中切換的前后不能保證
全局變量
以及static 變量
的一致性。 -
swoole
協程與xdebug、xhprof、blackfire
等zend
擴展不兼容,例如不能使用xhprof
對協程 server
進行性能分析采樣。
在 EasySwoole 中使用和創建協程
當提示類似 PHP Fatal error: Uncaught Swoole\Error: API must be called in the coroutine in /root/easyswoole/test_coroutine.php:7
錯誤時,說明該 API
必須在協程環境下使用。那該如何創建協程環境呢?其實很簡單,我們只需要這樣寫 \Swoole\Coroutine::create(function () { // 這里面就是協程環境 });
或 \Swoole\Coroutine\run(function() { // 這里面就是協程環境 });
或 go(function() { // 這里面就是協程環境});
,上述提到的三種方式均可用于創建協程環境。只需把調用代碼寫在匿名閉包函數里即可調用上述錯誤提到的 API
。
在 EasySwoole
框架主進程中使用協程
這里所說的主進程主要指的是在 EasySwoole
服務啟動前調用協程 API
的需求,包括在 EasySwoole
的 bootstrap 事件
、initialize 事件
、mainServerCreate 事件
中使用協程。關于前文提到的事件詳細請看 全局事件
簡單使用示例如下:
<?php
$scheduler = new \Swoole\Coroutine\Scheduler();
$scheduler->add(function() {
/* 調用協程API */
// 用戶可以在這里調用上述協程 API
});
$scheduler->start();
// 清除全部定時器
\Swoole\Timer::clearAll();
在 EasySwoole
框架 Worker
進程中使用協程
這里所說的 Worker
進程是指 EasySwoole
服務啟動之后的進程中調用協程 API
的需求,主要包括在 自定義進程
等進程中調用協程 API
。注意:在 Http 控制器
中如果是處于 api
接口環境下就已經是協程環境了。可以簡單理解為當一個請求進來的時候 swoole
底層就自動創建了一個協程去處理這個請求,所以這個請求里的處理邏輯其實已經是在協程環境下了。
簡單使用示例如下:
<?php
\Swoole\Coroutine::create(function () {
/* 調用協程API */
// 用戶可以在這里調用上述協程 API
});
// 或者使用如下:
go(function() {
/* 調用協程API */
// 用戶可以在這里調用上述協程 API
});