改名
This commit is contained in:
+6
-17
@@ -9,12 +9,15 @@ use HttpServer\Service\Http;
|
|||||||
use HttpServer\Service\Packet;
|
use HttpServer\Service\Packet;
|
||||||
use HttpServer\Service\Receive;
|
use HttpServer\Service\Receive;
|
||||||
use HttpServer\Service\Websocket;
|
use HttpServer\Service\Websocket;
|
||||||
|
use JetBrains\PhpStorm\Pure;
|
||||||
|
use ReflectionException;
|
||||||
use Rpc\Service;
|
use Rpc\Service;
|
||||||
use Server\Constant;
|
use Server\Constant;
|
||||||
use Server\ServerManager;
|
use Server\ServerManager;
|
||||||
use Snowflake\Abstracts\Config;
|
use Snowflake\Abstracts\Config;
|
||||||
use Snowflake\Error\LoggerProcess;
|
use Snowflake\Error\LoggerProcess;
|
||||||
use Snowflake\Exception\ConfigException;
|
use Snowflake\Exception\ConfigException;
|
||||||
|
use Snowflake\Exception\NotFindClassException;
|
||||||
use Snowflake\Process\Biomonitoring;
|
use Snowflake\Process\Biomonitoring;
|
||||||
use Snowflake\Snowflake;
|
use Snowflake\Snowflake;
|
||||||
use Swoole\Runtime;
|
use Swoole\Runtime;
|
||||||
@@ -84,8 +87,8 @@ class Server extends HttpService
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $rpcService
|
* @param $rpcService
|
||||||
* @throws \ReflectionException
|
* @throws ReflectionException
|
||||||
* @throws \Snowflake\Exception\NotFindClassException
|
* @throws NotFindClassException
|
||||||
*/
|
*/
|
||||||
private function rpcListener($rpcService)
|
private function rpcListener($rpcService)
|
||||||
{
|
{
|
||||||
@@ -183,23 +186,9 @@ class Server extends HttpService
|
|||||||
/**
|
/**
|
||||||
* @return \Swoole\Http\Server|\Swoole\Server|\Swoole\WebSocket\Server|null
|
* @return \Swoole\Http\Server|\Swoole\Server|\Swoole\WebSocket\Server|null
|
||||||
*/
|
*/
|
||||||
public function getServer(): \Swoole\Http\Server|\Swoole\Server|\Swoole\WebSocket\Server|null
|
#[Pure] public function getServer(): \Swoole\Http\Server|\Swoole\Server|\Swoole\WebSocket\Server|null
|
||||||
{
|
{
|
||||||
return $this->manager->getServer();
|
return $this->manager->getServer();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param $name
|
|
||||||
* @param $callback
|
|
||||||
* @throws Exception
|
|
||||||
*/
|
|
||||||
public function onBindCallback($server, $name, $callback)
|
|
||||||
{
|
|
||||||
// if ($server->getCallback($name) !== null) {
|
|
||||||
// return;
|
|
||||||
// }
|
|
||||||
$server->on($name, $callback);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -55,6 +55,7 @@ class ServerManager extends Abstracts\Server
|
|||||||
*/
|
*/
|
||||||
public function getServer(): Server|WServer|HServer|null
|
public function getServer(): Server|WServer|HServer|null
|
||||||
{
|
{
|
||||||
|
var_dump($this->server);
|
||||||
return $this->server;
|
return $this->server;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user