README

use EasySwoole\Socket\AbstractInterface\Controller; use EasySwoole\Socket\AbstractInterface\ParserInterface; use EasySwoole\Socket\Bean\Response; use EasySwoole\Socket\Bean\Caller; class C extends Controller{ private $hit = 0; protected $hitTime = 0; function __construct() { var_dump('controller create '.spl_object_hash($this)); parent::__construct(); } protected function onRequest(?string $actionName): bool { $this->hit++; $this->hitTime = time(); return true; } function test() { var_dump($this->hit,$this->hitTime); // co::sleep(10); $this->response()->setMessage('time:'.time()); } protected function gc() { parent::gc(); // TODO: Change the autogenerated stub var_dump('controller has ben gc'); } } class Parser implements ParserInterface{ public function decode($raw, $client): ?Caller { // TODO: Implement decode() method. $ret = new Caller(); $ret->setControllerClass(C::class); $ret->setAction('test'); return $ret; } /*  * 如果这里返回null，则不给客户端任何数据  */ public function encode(Response $response, $client): ?string { // TODO: Implement encode() method. return $response->__toString(); } } $server = new \Swoole\Server("127.0.0.1", 9501); $server->set([ 'worker_num'=>1 ]); $conf = new \EasySwoole\Socket\Config(); $conf->setType($conf::TCP); $conf->setParser(new Parser()); $conf->setOnExceptionHandler(function (\swoole_server $server,\Throwable $throwable,string $raw,$client,Response $response){ $response->setStatus('error'); $response->setStatus($response::STATUS_RESPONSE_AND_CLOSE); }); $dispatch = new \EasySwoole\Socket\Dispatcher($conf); $server->on('receive', function ($server, $fd, $reactor_id, $data)use($dispatch) { $dispatch->dispatch($server,$data,$fd,$reactor_id); }); $server->on('close', function ($server, $fd) { echo "connection close: {$fd}\n"; }); $server->start();