|
|
|
<?php
|
|
|
|
namespace Jiaoyin;
|
|
|
|
use Swoole\Http\Request;
|
|
|
|
use Swoole\Http\Response;
|
|
|
|
use Swoole\Coroutine\Http\Server;
|
|
|
|
|
|
|
|
class SimpleServerCoroutine
|
|
|
|
{
|
|
|
|
private Server $httpServer;
|
|
|
|
public function __construct($host, $port, $ssl = false)
|
|
|
|
{
|
|
|
|
$this->httpServer = new Server($host, $port, $ssl);
|
|
|
|
}
|
|
|
|
public function router($path, $callback){
|
|
|
|
$this->httpServer->handle($path, function (Request $request, Response $response) use ($callback) {
|
|
|
|
$requestInfo = [
|
|
|
|
'path' => $request->server['path_info'],
|
|
|
|
'uri' => $request->server['request_uri'],
|
|
|
|
'get' => $request->get ?: [],
|
|
|
|
'post' => $request->post ?: [],
|
|
|
|
'method' => $request->getMethod(),
|
|
|
|
'header' => $request->header ?: [],
|
|
|
|
'cookie' => $request->cookie ?: [],
|
|
|
|
];
|
|
|
|
$simpleRequest = new SimpleRequest($requestInfo);
|
|
|
|
$res = call_user_func($callback, $simpleRequest);
|
|
|
|
if(!$res){
|
|
|
|
$response->end();
|
|
|
|
}else{
|
|
|
|
$response->end($res);
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
public function start(){
|
|
|
|
$this->httpServer->start();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
...
|
...
|
|