fastd / swoole
FastD swoole.
Installs: 28 286
Dependents: 10
Suggesters: 0
Security: 0
Stars: 76
Watchers: 11
Forks: 17
Open Issues: 0
Requires
- php: >=5.6
- fastd/http: ^3.0
- fastd/packet: ^1.4
- symfony/console: ^3.0
Requires (Dev)
- phpunit/phpunit: ^5.0
- dev-master
- 5.0.x-dev
- v2.3.1
- v2.3.0
- v2.2.2
- v2.2.1
- v2.2.0
- v2.2.0-beta4
- v2.2.0-beta3
- v2.2.0-beta2
- v2.2.0-beta1
- v2.1.0
- 2.0.x-dev
- v2.0.4
- v2.0.3
- v2.0.2
- v2.0.1
- v2.0.0
- v2.0.0-rc1
- v2.0.0-beta3
- v2.0.0-beta2
- v2.0.0-beta1
- 1.1.x-dev
- 1.0.x-dev
- v1.0.5
- v1.0.4
- v1.0.3
- v1.0.2
- v1.0.1
- v1.0.0
- v1.0.0-rc1
- v1.0.0-beta3
- v1.0.0-beta2
- v1.0.0-beta1
- v1.0.0-alpha2
- v1.0.0-alpha1
- dev-develop
This package is auto-updated.
Last update: 2024-10-13 12:20:46 UTC
README
高性能网络服务组件. 提供底层服务封装, 基础管理及客户端调用功能. 使用 composer
进行管理, 可在此基础上进行封装整合.
环境要求
- Linux (不考虑windows)
- PHP >= 5.6
- swoole >= 1.9.6
源码地址: swoole
pecl 安装
pecl install swoole
可选扩展
如果 PHP >= 7.0 的安装 2.0 版本.
源码地址: inotify
pecl 安装
pecl install inotify
安装
composer require fastd/swoole
文档
使用
服务继承 FastD\Swoole\Server
, 实现 doWork
方法, 服务器在接收信息 onReceive
回调中会调用 doWork
方法, doWork
方法接受一个封装好的请求对象。
具体逻辑在 doWork
方法中实现, doWork
方法中返回响应客户端的数据, 格式为: 字符串
Swoole 配置通过实现 configure
方法进行配置,具体配置参数请参考: Swoole 配置选项
TCP Server
class DemoServer extends \FastD\Swoole\Server\Tcp { public function doWork(swoole_server $server, $fd, $data, $from_id) { echo $data . PHP_EOL; return 'hello tcp'; } } DemoServer::createServer('tcp swoole', 'tcp://0.0.0.0:9527')->start();
UDP Server
class DemoServer extends \FastD\Swoole\Server\Udp { public function doPacket(swoole_server $server, $data, $client_info) { echo $data . PHP_EOL; return 'hello tcp'; } } DemoServer::createServer('udp swoole', 'udp://127.0.0.1:9527')->start;
HTTP Server
同理, Http
服务器扩展 Server
类, 实现 doRequest
方法,实现具体逻辑。
class Http extends \FastD\Swoole\Server\Http { public function doRequest(ServerRequest $serverRequest) { return new JsonResponse([ 'msg' => 'hello world', ]); } } Http::createServer('http', 'http://0.0.0.0:9527')->start();
目前 Http 服务支持 Session 存储,而 Session 存储是基于浏览器 cookie,或者可以自定义实现存储方式。
目前由 FastD/Session 提供 session 支持以及 swoole_http_request 对象解释。
WebSocket Server
class WebSocket extends \FastD\Swoole\Server\WebSocket { public function doOpen(swoole_websocket_server $server, swoole_http_request $request) { echo "server: handshake success with fd{$request->fd}\n"; } public function doMessage(swoole_server $server, swoole_websocket_frame $frame) { echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n"; $server->push($frame->fd, "this is server"); } } WebSocket::createServer('ws', 'ws://0.0.0.0:9527')->start();
多端口支持
class Server extends \FastD\Swoole\Server\Tcp { public function doWork(swoole_server $server, $fd, $data, $from_id) { return 'hello server1'; } } class Server2 extends \FastD\Swoole\Server\Tcp { public function doWork(swoole_server $server, $fd, $data, $from_id) { return 'hello server2'; } } $server = new Server('tcp server', 'tcp://127.0.0.1:9527'); $server->listen(new Server2('tcp server2', 'tcp://127.0.0.1:9528')); $server->start();
服务管理
class DemoServer extends \FastD\Swoole\Server\Tcp { public function doWork(swoole_server $server, $fd, $data, $from_id) { echo $data . PHP_EOL; return 'hello tcp'; } } $server = DemoServer::createServer('tcp swoole', 'tcp://0.0.0.0:9527'); $argv = $_SERVER['argv']; $argv[1] = isset($argv[1]) ? $argv[1] : 'status'; switch ($argv[1]) { case 'start': $server->start(); break; case 'stop': $server->shutdown(); break; case 'reload': $server->reload(); break; case 'status': default: $server->status(); }
File Listener
因为 swoole 是常驻内存,程序通过首次启动就自动预载到内存当中,所以每次修改都需要重启服务。
所以这里提供监听文件变化来到自动重启服务(建议开发环境中使用)
class DemoServer extends \FastD\Swoole\Server\Tcp { public function doWork(swoole_server $server, $fd, $data, $from_id) { return 'hello tcp'; } } $server = new DemoServer('watch server', 'tcp://0.0.0.0:9527'); // $server = DemoServer::createServer('watch server', 'tcp://0.0.0.0:9527'); $server->watch([__DIR__ . '/listen_files']);
Sync Client
Client 通过 resolve 执行,通过不同的方法设置不同的回调,同步、异步均使用通用的方法。
$client = new \FastD\Swoole\Client\Sync\SyncClient('tcp://11.11.11.11:9527'); $client ->connect(function ($client) { $client->send('hello world'); }) ->receive(function ($client, $data) { echo $data . PHP_EOL; $client->close(); }) ->resolve() ;
Async Client
$client = new \FastD\Swoole\Client\Async\AsyncClient('tcp://11.11.11.11:9527'); $client ->connect(function ($client) { $client->send('hello world'); }) ->receive(function ($client, $data) { echo $data . PHP_EOL; }) ->error(function ($client) { print_r($client); }) ->close(function ($client) {}) ->resolve() ;
Process
$process = new Process('single', function () { timer_tick(1000, function ($id) { static $index = 0; $index++; echo $index . PHP_EOL; if ($index === 10) { timer_clear($id); } }); }); $process->start(); $process->wait(function ($ret) { echo 'PID: ' . $ret['pid']; });
Multi Process
$process = new Process('multi', function () { timer_tick(1000, function ($id) { static $index = 0; $index++; echo $index . PHP_EOL; if ($index === 10) { timer_clear($id); } }); }); $process->fork(5); $process->wait(function ($ret) { echo 'PID: ' . $ret['pid'] . PHP_EOL; });
Queue
$queue = new \FastD\Swoole\Queue('queue', function ($worker) { while (true) { $recv = $worker->pop(); echo "From Master: $recv\n"; } }); $queue->start(); while (true) { $queue->push('hello'); sleep(1); } $queue->wait(function ($ret) { echo 'PID: ' . $ret['pid']; });
贡献
非常欢迎感兴趣,愿意参与其中,共同打造更好PHP生态,Swoole生态的开发者。
如果你乐于此,却又不知如何开始,可以试试下面这些事情:
- 在你的系统中使用,将遇到的问题 反馈。
- 有更好的建议?欢迎联系 bboyjanhuang@gmail.com 或 新浪微博:编码侠。
联系
如果你在使用中遇到问题,请联系: bboyjanhuang@gmail.com. 微博: 编码侠