TypePHP 编译器
https://swoole.com/aot/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
43 lines
1.2 KiB
43 lines
1.2 KiB
<?php
|
|
function getpid($serv)
|
|
{
|
|
return $serv->mode === SWOOLE_THREAD ? \Swoole\Thread::getId() : posix_getpid();
|
|
}
|
|
|
|
function main()
|
|
{
|
|
$serv = new Swoole\Server("0.0.0.0", 9501);
|
|
$serv->set([
|
|
'worker_num' => 2,
|
|
'task_worker_num' => 3,
|
|
]);
|
|
|
|
$serv->on('workerStart', function ($serv, $worker_id) {
|
|
echo "[#" . getpid($serv) . "]\tWorker#{$worker_id} is started.\n";
|
|
});
|
|
|
|
$serv->on('workerStop', function ($serv, $worker_id) {
|
|
echo "[#" . getpid($serv) . "]\tWorker#{$worker_id} is stopped.\n";
|
|
});
|
|
|
|
$serv->on('connect', function ($serv, $fd, $reactor_id) {
|
|
echo "[#" . getpid($serv) . "]\tClient@[$fd:$reactor_id]: Connect.\n";
|
|
});
|
|
|
|
$serv->on('receive', function (Swoole\Server $serv, $fd, $reactor_id, $data) {
|
|
echo "[#" . $serv->worker_id . "]\tClient[$fd] receive data: $data\n";
|
|
if (!$serv->send($fd, "hello {$data}\n")) {
|
|
echo "error\n";
|
|
}
|
|
});
|
|
|
|
$serv->on('close', function ($serv, $fd, $reactor_id) {
|
|
echo "[#" . getpid($serv) . "]\tClient@[$fd:$reactor_id]: Close.\n";
|
|
});
|
|
|
|
$serv->on('task', function ($serv, $src_worker_id, $task) {
|
|
var_dump($task);
|
|
});
|
|
|
|
$serv->start();
|
|
}
|
|
|