//高性能HTTP服务器 $http = new Swoole\Http\Server("127.0.0.1", 9501); $http->on("start", function ($server) { echo "Swoole http server is started at http://127.0.0.1:9501

"; }); $http->on("request", function ($request, $response) { $response->header("Content-Type", "text/plain"); $response->end("Hello World

"); }); $http->start();

$server = new Swoole\Websocket\Server("127.0.0.1", 9502); $server->on('open', function($server, $req) { echo "connection open: {$req->fd}

"; }); $server->on('message', function($server, $frame) { echo "received message: {$frame->data}

"; $server->push($frame->fd, json_encode(["hello", "world"])); }); $server->on('close', function($server, $fd) { echo "connection close: {$fd}

"; }); $server->start();

$server = new Swoole\Server("127.0.0.1", 9503); $server->on('connect', function ($server, $fd){ echo "connection open: {$fd}

"; }); $server->on('receive', function ($server, $fd, $reactor_id, $data) { $server->send($fd, "Swoole: {$data}"); $server->close($fd); }); $server->on('close', function ($server, $fd) { echo "connection close: {$fd}

"; }); $server->start();

$server = new Swoole\Server("127.0.0.1", 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP); $server->on('Packet', function ($server, $data, $clientInfo) { $server->sendTo($clientInfo['address'], $clientInfo['port'], "Server ".$data); var_dump($clientInfo); }); $server->start();

$server = new Swoole\Server("127.0.0.1", 9502); $server->set(array('task_worker_num' => 4)); $server->on('receive', function($server, $fd, $reactor_id, $data) { $task_id = $server->task("Async"); echo "Dispatch AsyncTask: [id=$task_id]

"; }); $server->on('task', function ($server, $task_id, $reactor_id, $data) { echo "New AsyncTask[id=$task_id]

"; $server->finish("$data -> OK"); }); $server->on('finish', function ($server, $task_id, $data) { echo "AsyncTask[$task_id] finished: {$data}

"; }); $server->start();

//此行代码后，文件操作，sleep，Mysqli，PDO，streams等都变成异步IO，见文档"一键协程化"章节 Swoole\Runtime::enableCoroutine(); // 10k pdo and mysqli read Co\Run(function() { for ($c = 50; $c--;) { go(function () { $pdo = new PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8', 'root', 'root'); $statement = $pdo->prepare('SELECT * FROM `user`'); for ($n = 100; $n--;) { $statement->execute(); assert(count($statement->fetchAll()) > 0); } }); } for ($c = 50; $c--;) { go(function () { $mysqli = new mysqli('127.0.0.1', 'root', 'root', 'test'); $statement = $mysqli->prepare('SELECT `id` FROM `user`'); for ($n = 100; $n--;) { $statement->bind_result($id); $statement->execute(); $statement->fetch(); assert($id > 0); } }); } });

//此行代码后，文件操作，sleep，Mysqli，PDO，streams等都变成异步IO，见文档"一键协程化"章节 Swoole\Runtime::enableCoroutine(); // UDP server & client with 12.8k requests in single process Co\run(function() { go(function () { $socket = new Swoole\Coroutine\Socket(AF_INET, SOCK_DGRAM, 0); $socket->bind('127.0.0.1', 9503); $client_map = []; for ($c = 128; $c--;) { for ($n = 0; $n < 100; $n++) { $recv = $socket->recvfrom($peer); $client_uid = "{$peer['address']}:{$peer['port']}"; $id = $client_map[$client_uid] = ($client_map[$client_uid] ?? -1) + 1; assert($recv === "Client: Hello #{$id}!"); $socket->sendto($peer['address'], $peer['port'], "Server: Hello #{$id}!"); } } $socket->close(); }); for ($c = 128; $c--;) { go(function () { $fp = stream_socket_client("udp://127.0.0.1:9503", $errno, $errstr, 1); if (!$fp) { echo "$errstr ($errno)

"; return; } for ($n = 0; $n < 100; $n++) { fwrite($fp, "Client: Hello #{$n}!"); $recv = fread($fp, 1024); list($address, $port) = explode(':', (stream_socket_get_name($fp, true))); assert($address === '127.0.0.1' && (int)$port === 9503); assert($recv === "Server: Hello #{$n}!"); } fclose($fp); }); } });

//此行代码后，文件操作，sleep，Mysqli，PDO，streams等都变成异步IO，见文档"一键协程化"章节 Swoole\Runtime::enableCoroutine(); // php_stream tcp server & client with 12.8k requests in single process function tcp_pack(string $data): string { return pack('n', strlen($data)) . $data; } function tcp_length(string $head): int { return unpack('n', $head)[1]; } Co\run(function() { go(function () { $ctx = stream_context_create(['socket' => ['so_reuseaddr' => true, 'backlog' => 128]]); $socket = stream_socket_server( 'tcp://0.0.0.0:9502', $errno, $errstr, STREAM_SERVER_BIND | STREAM_SERVER_LISTEN, $ctx ); if (!$socket) { echo "$errstr ($errno)

"; } else { $i = 0; while ($conn = stream_socket_accept($socket, 1)) { stream_set_timeout($conn, 5); for ($n = 100; $n--;) { $data = fread($conn, tcp_length(fread($conn, 2))); assert($data === "Hello Swoole Server #{$n}!"); fwrite($conn, tcp_pack("Hello Swoole Client #{$n}!")); } if (++$i === 128) { fclose($socket); break; } } } }); for ($c = 128; $c--;) { go(function () { $fp = stream_socket_client("tcp://127.0.0.1:9502", $errno, $errstr, 1); if (!$fp) { echo "$errstr ($errno)

"; } else { stream_set_timeout($fp, 5); for ($n = 100; $n--;) { fwrite($fp, tcp_pack("Hello Swoole Server #{$n}!")); $data = fread($fp, tcp_length(fread($fp, 2))); assert($data === "Hello Swoole Client #{$n}!"); } fclose($fp); } }); } });

//此行代码后，文件操作，sleep，Mysqli，PDO，streams等都变成异步IO，见文档"一键协程化"章节 Swoole\Runtime::enableCoroutine(); Co\run(function() { // i just want to sleep... for ($c = 100; $c--;) { go(function () { for ($n = 100; $n--;) { usleep(1000); } }); } // 10k file read and write for ($c = 100; $c--;) { go(function () use ($c) { $tmp_filename = "/tmp/test-{$c}.php"; for ($n = 100; $n--;) { $self = file_get_contents(__FILE__); file_put_contents($tmp_filename, $self); assert(file_get_contents($tmp_filename) === $self); } unlink($tmp_filename); }); } });