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