協(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)來合理的調(diào)度協(xié)程,這會帶來了以下優(yōu)勢:
- 開發(fā)者可以無感知的用同步的代碼編寫方式達到
異步IO的效果和性能,避免了傳統(tǒng)異步回調(diào)所帶來的離散的代碼邏輯和陷入多層回調(diào)中導致代碼無法維護; - 同時由于底層封裝了協(xié)程,所以對比傳統(tǒng)的
PHP層協(xié)程框架,開發(fā)者不需要使用yield關鍵詞來標識一個協(xié)程IO操作,所以不再需要對yield的語義進行深入理解以及對每一級的調(diào)用都修改為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)境下使用。
在 EasySwoole 框架主進程中使用協(xié)程
這里所說的主進程主要指的是在 EasySwoole 服務啟動前調(diào)用協(xié)程 API 的需求,包括在 EasySwoole 的 bootstrap 事件、initialize 事件、mainServerCreate 事件 中使用協(xié)程。關于前文提到的事件詳細請看 全局事件
簡單使用示例如下:
<?php
$scheduler = new \Swoole\Coroutine\Scheduler();
$scheduler->add(function() {
/* 調(diào)用協(xié)程API */
// 用戶可以在這里調(diào)用上述協(xié)程 API
});
$scheduler->start();
// 清除全部定時器
\Swoole\Timer::clearAll();在 EasySwoole 框架 Worker 進程中使用協(xié)程
這里所說的 Worker 進程是指 EasySwoole 服務啟動之后的進程中調(diào)用協(xié)程 API 的需求,主要包括在 Http 控制器、自定義進程 等進程中調(diào)用協(xié)程 API。
簡單使用示例如下:
<?php
\Swoole\Coroutine::create(function () {
/* 調(diào)用協(xié)程API */
// 用戶可以在這里調(diào)用上述協(xié)程 API
});
// 或者使用如下:
go(function() {
/* 調(diào)用協(xié)程API */
// 用戶可以在這里調(diào)用上述協(xié)程 API
});
