You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
|
6 years ago | |
---|---|---|
src | 6 years ago | |
.gitignore | 6 years ago | |
LICENSE | 6 years ago | |
README.md | 6 years ago | |
composer.json | 6 years ago |
README.md
Workerman-Amp
概述
Amp 是一个事件驱动的 PHP 框架,与 ReactPHP 类似。
本项目用于将 Amp 的 event-loop 应用于 Workerman,从而可以在 Workerman 中使用基于 Amp 的高性能组件,例如异步 MySQL,异步 Redis,异步 HTTP 客户端等。
笔者修改了本项目的源码,使其兼容原生 Amp。现在无需修改 Amp 的源码就可以在项目中使用其所有组件。以后笔者可能会发布一些 Demo。
使用说明
- 使用 composer 将
Workerman\Events\Amp
加载到项目中。
composer require cismonx/workerman-amp
- 将 Amp 设置为 Workerman 所使用的 event-loop。如下:
Worker::$eventLoopClass = '\\Workerman\\Events\\Amp';
兼容 Amp 协程
在 Amp 中,协程是一个十分重要的特性。对 Workerman 的源码稍加修改,将 watcher 回调中的同步调用(call_user_func
)改为异步调用(yield \Amp\call()
),即可在 Workerman 的事件回调函数中直接使用 Amp 协程。
以下几点需要注意:
-
以上提到的对 Workerman 源码的修改在 src 目录下的 coroutine-compatibility.patch 中。这个补丁对 Workerman-3.4.5-stable 有效。
-
目前只能在
onConnect
onSslHandshake
onMessage
这三个事件回调函数中使用 Amp 协程。
以下是使用 Amp 协程的示例(测试的时候同时多发几条请求,可以看出效果)
use Workerman\Worker;
Worker::$eventLoopClass = '\\Workerman\\Events\\Amp';
$worker = new Worker('http://[::]:20080');
function subtractToZero($init, $interval) {
$value = $init;
$emitter = new Amp\Emitter;
$id = \Workerman\Lib\Timer::add($interval, function () use ($emitter, &$value, &$id) {
if ($value > 0)
$emitter->emit(--$value);
else {
$emitter->complete();
\Workerman\Lib\Timer::del($id);
}
});
return $emitter->iterate();
}
$worker->onMessage = function ($connection) {
$iterator = subtractToZero(10, 1);
while (yield $iterator->advance())
var_dump($iterator->getCurrent());
$connection->send('ok');
};
Worker::runAll();