Swoole框架PHP 异步网络通信引擎swoole-v5.1.2.zip

<h2 align=center> <img width="200" height="120" alt="Swoole Logo" src="docs/swoole-logo.svg" /> <br /> Swoole is an event-driven, asynchronous, coroutine-based concurrency library with high performance for PHP. </h2> [](https://github.com/swoole/swoole-src/actions?query=workflow%3Alib-swoole) [](https://github.com/swoole/swoole-src/actions?query=workflow%3Aext-swoole) [](https://github.com/swoole/swoole-src/actions?query=workflow%3Atest-linux) [](https://github.com/swoole/swoole-src/actions/workflows/framework.yml) [](https://codecov.io/gh/swoole/swoole-src) [](https://twitter.com/phpswoole) [](https://discord.swoole.dev) [](https://github.com/swoole/swoole-src/releases/) [](https://github.com/swoole/swoole-src/blob/master/LICENSE) [](https://scan.coverity.com/projects/swoole-swoole-src) ## ⚙️ Quick Start Run Swoole program by [Docker](https://github.com/swoole/docker-swoole) ```bash docker run --rm phpswoole/swoole "php --ri swoole" ``` > For details on how to use it, see: [How to Use This Image](https://github.com/swoole/docker-swoole#how-to-use-this-image). ### HTTP Service ```php $http = new Swoole\Http\Server('127.0.0.1', 9501); $http->set(['hook_flags' => SWOOLE_HOOK_ALL]); $http->on('request', function ($request, $response) { $result = []; Co::join([ go(function () use (&$result) { $result['google'] = file_get_contents("https://www.google.com/"); }), go(function () use (&$result) { $result['taobao'] = file_get_contents("https://www.taobao.com/"); }) ]); $response->end(json_encode($result)); }); $http->start(); ``` ### Concurrency ```php Co\run(function() { Co\go(function() { while(1) { sleep(1); $fp = stream_socket_client("tcp://127.0.0.1:8000", $errno, $errstr, 30); echo fread($fp, 8192), PHP_EOL; } }); Co\go(function() { $fp = stream_socket_server("tcp://0.0.0.0:8000", $errno, $errstr, STREAM_SERVER_BIND | STREAM_SERVER_LISTEN); while(1) { $conn = stream_socket_accept($fp); fwrite($conn, 'The local time is ' . date('n/j/Y g:i a')); } }); Co\go(function() { $redis = new Redis(); $redis->connect('127.0.0.1', 6379); while(true) { $redis->subscribe(['test'], function ($instance, $channelName, $message) { echo 'New redis message: '.$channelName, "==>", $message, PHP_EOL; }); } }); Co\go(function() { $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $count = 0; while(true) { sleep(2); $redis->publish('test','hello, world, count='.$count++); } }); }); ``` ## Runtime Hook **Swoole hooks the blocking io function of PHP at the `bottom layer` and `automatically` converts it to a non-blocking function, so that these functions can be called concurrently in coroutines.** ### Supported extension/functions * `ext-curl` (Support `symfony` and `guzzle`) * `ext-redis` * `ext-mysqli` * `ext-pdo_mysql` * `ext-pdo_pgsql` * `ext-pdo_sqlite` * `ext-pdo_oracle` * `ext-pdo_odbc` * `stream functions` (e.g. `stream_socket_client`/`stream_socket_server`), Supports `TCP`/`UDP`/`UDG`/`Unix`/`SSL/TLS`/`FileSystem API`/`Pipe` * `ext-sockets` * `ext-soap` * `sleep`/`usleep`/`time_sleep_until` * `proc_open` * `gethostbyname`/`shell_exec`/`exec` * `fread`/`fopen`/`fsockopen`/`fwrite`/`flock` ## 🛠 Develop & Discussion + __IDE Helper & API__: <https://github.com/swoole/ide-helper> + __Twitter__: <https://twitter.com/phpswoole> + __Discord__: <https://discord.swoole.dev> + __中文文档__: <https://wiki.swoole.com> + __中文社区__: <https://wiki.swoole.com/#/other/discussion> ## 💎 Awesome Swoole Project [Awesome Swoole](https://github.com/swoole/awesome-swoole) maintains a curated list of awesome things related to Swoole, including * Swoole-based frameworks and libraries. * Packages to integrate Swoole with popular PHP frameworks, including Laravel, Symfony, Slim, and Yii. * Books, videos, and other learning materials about Swoole. * Debugging, profiling, and testing tools for developing Swoole-based applications. * Coroutine-friendly packages and libraries. * Other Swoole related projects and resources. ## ✨ Event-based The network layer in Swoole is event-based and takes full advantage of the underlying epoll/kqueue implementation, making it really easy to serve millions of requests. Swoole 4.x uses a brand new engine kernel and now it has a full-time developer team, so we are entering an unprecedented period in PHP history which offers a unique possibility for rapid evolution in performance. ## ⚡ Coroutine Swoole 4.x or later supports the built-in coroutine with high availability, and you can use fully synchronized code to implement asynchronous performance. PHP code without any additional keywords, the underlying automatic coroutine-scheduling. Developers can understand coroutines as ultra-lightweight threads, and you can easily create thousands of coroutines in a single process. ### MySQL Concurrency 10K requests to read data from MySQL takes only 0.2s! ```php $s = microtime(true); Co\run(function() { for ($c = 100; $c--;) { go(function () { $mysql = new Swoole\Coroutine\MySQL; $mysql->connect([ 'host' => '127.0.0.1', 'user' => 'root', 'password' => 'root', 'database' => 'test' ]); $statement = $mysql->prepare('SELECT * FROM `user`'); for ($n = 100; $n--;) { $result = $statement->execute(); assert(count($result) > 0); } }); } }); echo 'use ' . (microtime(true) - $s) . ' s'; ``` ### Mixed server You can create multiple services on the single event loop: TCP, HTTP, Websocket and HTTP2, and easily handle thousands of requests. ```php function tcp_pack(string $data): string { return pack('N', strlen($data)) . $data; } function tcp_unpack(string $data): string { return substr($data, 4, unpack('N', substr($data, 0, 4))[1]); } $tcp_options = [ 'open_length_check' => true, 'package_length_type' => 'N', 'package_length_offset' => 0, 'package_body_offset' => 4 ]; ``` ```php $server = new Swoole\WebSocket\Server('127.0.0.1', 9501, SWOOLE_BASE); $server->set(['open_http2_protocol' => true]); // http && http2 $server->on('request', function (Swoole\Http\Request $request, Swoole\Http\Response $response) { $response->end('Hello ' . $request->rawcontent()); }); // websocket $server->on('message', function (Swoole\WebSocket\Server $server, Swoole\WebSocket\Frame $frame) { $server->push($frame->fd, 'Hello ' . $frame->data); }); // tcp $tcp_server = $server->listen('127.0.0.1', 9502, SWOOLE_TCP); $tcp_server->set($tcp_options); $tcp_server->on('receive', function (Swoole\Server $server, int $fd, int $reactor_id, string $data) { $server->send($fd, tcp_pack('Hello ' . tcp_unpack($data))); }); $server->start(); ``` ### Coroutine clients Whether you DNS query or send requests or receive responses, all of