This commit is contained in:
as2252258@163.com
2021-08-04 01:47:26 +08:00
parent e3f81d83b1
commit 76e3308edd
4 changed files with 38 additions and 81 deletions
+2
View File
@@ -426,6 +426,8 @@ class Request extends HttpService
Context::setContext(\Swoole\Http\Request::class, $request); Context::setContext(\Swoole\Http\Request::class, $request);
Context::setContext(Response::class, new Response());
return Snowflake::getDi()->get(Request::class); return Snowflake::getDi()->get(Request::class);
} }
+15 -54
View File
@@ -55,26 +55,10 @@ class Response extends HttpService
*/ */
public function setFormat($format): static public function setFormat($format): static
{ {
/** @var SResponse $response */ $this->format = $format;
$response = Context::getContext(SResponse::class);
if ($format == self::HTML) {
$response->header('Content-Type', 'text/html;charset=utf-8');
} else if ($format == self::XML) {
$response->header('Content-Type', 'application/xml;charset=utf-8');
} else {
$response->header('Content-Type', 'application/json;charset=utf-8');
}
return $this; return $this;
} }
/**
* 清理无用数据
*/
public function clear(): void
{
$this->fd = 0;
$this->format = null;
}
/** /**
* @param $content * @param $content
@@ -83,11 +67,6 @@ class Response extends HttpService
public function toHtml($content): string public function toHtml($content): string
{ {
$this->format = self::HTML; $this->format = self::HTML;
/** @var SResponse $response */
$response = Context::getContext(SResponse::class);
$response->header('Content-Type', 'text/html;charset=utf-8');
return (string)$content; return (string)$content;
} }
@@ -99,11 +78,6 @@ class Response extends HttpService
public function toJson($content): string|bool public function toJson($content): string|bool
{ {
$this->format = self::JSON; $this->format = self::JSON;
/** @var SResponse $response */
$response = Context::getContext(SResponse::class);
$response->header('Content-Type', 'application/json;charset=utf-8');
return json_encode($content, JSON_UNESCAPED_UNICODE); return json_encode($content, JSON_UNESCAPED_UNICODE);
} }
@@ -115,24 +89,10 @@ class Response extends HttpService
public function toXml($content): mixed public function toXml($content): mixed
{ {
$this->format = self::XML; $this->format = self::XML;
/** @var SResponse $response */
$response = Context::getContext(SResponse::class);
$response->header('Content-Type', 'application/xml;charset=utf-8');
return $content; return $content;
} }
/**
* @return mixed
* @throws Exception
*/
public function sender(): mixed
{
return $this->send(func_get_args());
}
/** /**
* @param $key * @param $key
* @param $value * @param $value
@@ -140,9 +100,7 @@ class Response extends HttpService
*/ */
public function addHeader($key, $value): static public function addHeader($key, $value): static
{ {
/** @var SResponse $response */ $this->headers[$key] = $value;
$response = Context::getContext(SResponse::class);
$response->header($key, $value);
return $this; return $this;
} }
@@ -160,28 +118,31 @@ class Response extends HttpService
*/ */
public function addCookie($name, $value = null, $expires = null, $path = null, $domain = null, $secure = null, $httponly = null, $samesite = null, $priority = null): static public function addCookie($name, $value = null, $expires = null, $path = null, $domain = null, $secure = null, $httponly = null, $samesite = null, $priority = null): static
{ {
/** @var SResponse $response */ $this->cookies[] = func_get_args();
$response = Context::getContext(SResponse::class);
$response->cookie(...func_get_args());
return $this; return $this;
} }
/**
* @param $statusCode
*/
public function setStatusCode($statusCode)
{
$this->statusCode = $statusCode;
}
/** /**
* @param mixed $context * @param mixed $context
* @param int $statusCode * @param int $statusCode
* @return bool * @return bool
* @throws Exception * @throws Exception
*/ */
public function send(mixed $context = '', int $statusCode = 200): mixed public function send(mixed $context, int $statusCode, SResponse $response): mixed
{ {
$sendData = $this->parseData($context); $sendData = $this->parseData($context);
/** @var SResponse|null $response */
$response = Context::getContext(SResponse::class);
if ($response === null) {
return $this->printResult($sendData);
}
$response->setStatusCode($statusCode); $response->setStatusCode($statusCode);
if (!isset($response->header['Content-Type'])) { if (!isset($response->header['Content-Type'])) {
$response->header('Content-Type', 'application/json;charset=utf-8'); $response->header('Content-Type', 'application/json;charset=utf-8');
+14 -7
View File
@@ -6,6 +6,7 @@ use Annotation\Inject;
use Exception; use Exception;
use HttpServer\Http\Context; use HttpServer\Http\Context;
use HttpServer\Http\Request as HSRequest; use HttpServer\Http\Request as HSRequest;
use HttpServer\Route\Node;
use HttpServer\Route\Router; use HttpServer\Route\Router;
use Server\Events\OnAfterRequest; use Server\Events\OnAfterRequest;
use Snowflake\Event; use Snowflake\Event;
@@ -39,6 +40,7 @@ class HTTPServerListener extends Abstracts\Server
public \HttpServer\Http\Response $response; public \HttpServer\Http\Response $response;
/** @var EventDispatch */ /** @var EventDispatch */
#[Inject(EventDispatch::class)] #[Inject(EventDispatch::class)]
public EventDispatch $eventDispatch; public EventDispatch $eventDispatch;
@@ -90,15 +92,20 @@ class HTTPServerListener extends Abstracts\Server
public function onRequest(Request $request, Response $response) public function onRequest(Request $request, Response $response)
{ {
try { try {
Context::setContext(Response::class, $response); $node = $this->router->find_path(HSRequest::create($request));
if (!($node instanceof Node)) {
HSRequest::create($request); $this->response->setFormat(\HttpServer\Http\Response::HTML);
// $this->router->dispatch(HSRequest::create($request)); $data = '<h2>HTTP 404 Not Found</h2><hr><i>Powered by Swoole</i>';
} else {
$data= $node->dispatch();
}
} catch (Error | Throwable $exception) { } catch (Error | Throwable $exception) {
// $this->response->send(jTraceEx($exception), 500); $data = jTraceEx($exception);
} finally { } finally {
$response->status(200); if (Context::hasContext(Response::class)) {
$response->end('ok'); return;
}
Context::getContext(Response::class)->send($data,200, $response);
$this->eventDispatch->dispatch(new OnAfterRequest()); $this->eventDispatch->dispatch(new OnAfterRequest());
} }
} }
+4 -17
View File
@@ -4,6 +4,7 @@ defined('APP_PATH') or define('APP_PATH', realpath(__DIR__ . '/../../'));
use Annotation\Annotation; use Annotation\Annotation;
use HttpServer\Http\Context;
use HttpServer\Http\HttpParams; use HttpServer\Http\HttpParams;
use HttpServer\Http\Request; use HttpServer\Http\Request;
use HttpServer\Http\Response; use HttpServer\Http\Response;
@@ -594,24 +595,10 @@ if (!function_exists('response')) {
*/ */
function response(): Response|stdClass function response(): Response|stdClass
{ {
return Snowflake::getDi()->get(Response::class); if (!Context::hasContext(Response::class)){
return Context::setContext(Response::class, new Response());
} }
return Context::getContext(Response::class);
}
if (!function_exists('send')) {
/**
* @param $context
* @param int $statusCode
* @return mixed
* @throws Exception
*/
function send($context, int $statusCode = 404): mixed
{
if (is_array($context)) $context = Json::encode($context);
return \response()->send($context, $statusCode);
} }
} }