協程
協程是一種比線程更輕量級的用戶級並行機制,能夠在進程中實現多任務調度。它透過手動控制掛起和恢復來實現協程間的切換,避免了進程上下文切換的開銷。
workerman提供了一個通用的協程接口,底層自動兼容Swoole/Swow/Fiber驅動。
提示
此特性需要 workerman>=5.1.0
注意
- 協程僅支持
SwooleSwowFiber驅動 - 如果使用
Fiber驅動時需要安裝composer require revolt/event-loop Swoole或者Swow驅動可以實現PHP阻塞函數自動協程化,從而實現原來的同步代碼異步執行- 但
Fiber無法像Swoole和Swow那樣自動協程化,遇到PHP自帶的阻塞函數時會阻塞整個進程,並不會發生協程切換 - 當使用
SwooleSwowFiber驅動時,workerman每次運行onWorkerStartonMessageonConnectonClose等回調時會自動創建一個協程來執行 - 可以利用
$worker->eventLoop=xxx;給不同worker設置不同的協程驅動
<?php
use Workerman\Connection\TcpConnection;
use Workerman\Coroutine;
use Workerman\Events\Swoole;
use Workerman\Events\Fiber;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';
$worker1 = new Worker('http://0.0.0.0:8001');
$worker1->eventLoop = Swoole::class; // 使用Swoole協程
$worker1->onMessage = function (TcpConnection $connection, Request $request) {
Coroutine::create(function () {
echo file_get_contents("http://www.example.com/event/notify");
});
$connection->send('ok');
};
$worker2 = new Worker('http://0.0.0.0:8001');
$worker2->eventLoop = Fiber::class; // 使用自帶的Fiber協程
$worker2->onMessage = function (TcpConnection $connection, Request $request) {
Coroutine::create(function () {
echo file_get_contents("http://www.example.com/event/notify");
});
$connection->send('ok');
};
Worker::runAll();
協程提供的接口
interface CoroutineInterface
{
/**
* 創建協程並立即執行
*/
public static function create(callable $callable, ...$data): CoroutineInterface;
/**
* 開始協程運行
*/
public function start(mixed ...$args): mixed;
/**
* 恢復協程運行
*/
public function resume(mixed ...$args): mixed;
/**
* 獲取協程id
*/
public function id(): int;
/**
* 設置協程銷毀時的回調
*/
public static function defer(callable $callable): void;
/**
* 暫停當前協程
*/
public static function suspend(mixed $value = null): mixed;
/**
* 獲取當前協程
*/
public static function getCurrent(): CoroutineInterface|Fiber|SwowCoroutine|static;
/**
* 判斷當前是否是協程環境
*/
public static function isCoroutine(): bool;
}
關於協程
優勢
PHP引入協程後最大的作用就是可以用同步的方式編寫異步代碼,避免了回調地獄,提高了代碼的可讀性和可維護性。
協程能大幅度提升IO密集型業務的彈性,可以用較少的進程提供更大的吞吐量。
劣勢
但是引入協程後開發者需要時刻注意全局變量污染、資源競爭、第三方庫改造等問題,開發維護成本增大,心智負擔明顯增加。
引入協程後產生了協程創建、調度、銷毀、連接池等額外開銷。
通過大量壓測數據來看,在充分利用CPU的情況下,引入協程後極限性能比阻塞式IO下降約10%-20%。