This commit is contained in:
2021-03-08 16:31:30 +08:00
parent fb62ba3f6c
commit f065b1c3b1
3 changed files with 4 additions and 4 deletions
+1 -1
View File
@@ -36,7 +36,7 @@ class OnPacket extends Callback
public function onHandler(Server $server, string $data, array $clientInfo): mixed public function onHandler(Server $server, string $data, array $clientInfo): mixed
{ {
try { try {
$request = Request::createListenRequest($clientInfo, $server, $data); $request = Request::createListenRequest($clientInfo, $this->port, $server, $data);
[$host, $port] = [$clientInfo['address'], $clientInfo['port']]; [$host, $port] = [$clientInfo['address'], $clientInfo['port']];
+1 -1
View File
@@ -36,7 +36,7 @@ class OnReceive extends Callback
public function onHandler(Server $server, int $fd, int $reID, string $data): mixed public function onHandler(Server $server, int $fd, int $reID, string $data): mixed
{ {
try { try {
$request = Request::createListenRequest($fd, $server, $data, $reID); $request = Request::createListenRequest($fd, $this->port, $server, $data, $reID);
$router = Snowflake::app()->getRouter(); $router = Snowflake::app()->getRouter();
if (($node = $router->find_path($request)) === null) { if (($node = $router->find_path($request)) === null) {
+2 -2
View File
@@ -496,7 +496,7 @@ class Request extends HttpService
* @throws NotFindClassException * @throws NotFindClassException
* @throws ReflectionException * @throws ReflectionException
*/ */
public static function createListenRequest($fd, Server $server, $data, $reID = 0): Request public static function createListenRequest($fd, $port, Server $server, $data, $reID = 0): Request
{ {
/** @var Request $sRequest */ /** @var Request $sRequest */
$sRequest = Snowflake::createObject(Request::class); $sRequest = Snowflake::createObject(Request::class);
@@ -511,7 +511,7 @@ class Request extends HttpService
$sRequest->params = new HttpParams(['body' => $data], [], []); $sRequest->params = new HttpParams(['body' => $data], [], []);
$sRequest->headers = new HttpHeaders([]); $sRequest->headers = new HttpHeaders([]);
$sRequest->headers->replace('request_method', 'listen'); $sRequest->headers->replace('request_method', 'listen');
$sRequest->headers->replace('request_uri', 'add-port-listen/port_' . $server->port); $sRequest->headers->replace('request_uri', 'add-port-listen/port_' . $port);
$sRequest->parseUri(); $sRequest->parseUri();
return Context::setContext('request', $sRequest); return Context::setContext('request', $sRequest);
} }