as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-03-24 16:12:02 +08:00
parent a86d648360
commit 61cd5433cc
1 changed files with 17 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Rpc/Service.php
+17 -30
View File
@@ -5,21 +5,17 @@ namespace Rpc;
use Exception; use Exception;
use HttpServer\Http\Context; use HttpServer\Http\Context;
use HttpServer\Http\HttpHeaders;
use HttpServer\Http\HttpParams;
use HttpServer\Http\Request; use HttpServer\Http\Request;
use HttpServer\Service\Http; 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 Snowflake\Abstracts\Component; use Snowflake\Abstracts\Component;
use Snowflake\Abstracts\Config; use Snowflake\Abstracts\Config;
use Snowflake\Core\Json; use Snowflake\Core\Json;
use Snowflake\Event;
use Snowflake\Exception\ConfigException; use Snowflake\Exception\ConfigException;
use Snowflake\Exception\NotFindClassException;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Server;
/** /**
@@ -37,25 +33,10 @@ class Service extends Component
*/ */
public function instance(Packet|Websocket|Receive|null|Http $server): void public function instance(Packet|Websocket|Receive|null|Http $server): void
{ {
$services = Config::get('rpc.service', false, []); $service = Config::get('rpc.service', false, []);
if (empty($services)) { if (empty($services)) {
return; return;
} }
$router = Snowflake::app()->getRouter();
foreach ($services as $service) {
$this->addService($router, $server, $service);
}
}
/**
* @param $router
* @param $server
* @param $service
* @throws Exception
*/
private function addService($router, $server, $service)
{
$mode = $service['mode'] ?? SWOOLE_SOCK_TCP6; $mode = $service['mode'] ?? SWOOLE_SOCK_TCP6;
if (Snowflake::port_already($service['port'])) { if (Snowflake::port_already($service['port'])) {
@@ -64,23 +45,29 @@ class Service extends Component
$this->debug(Snowflake::listen($service)); $this->debug(Snowflake::listen($service));
$rpcServer = $server->addlistener($service['host'], $service['port'], $mode); $rpcServer = $server->addlistener($service['host'], $service['port'], $mode);
$rpcServer->set([ $rpcServer->set($service['setting'] ?? [
'open_tcp_keepalive' => true, 'open_tcp_keepalive' => true,
'tcp_keepidle' => 30, 'tcp_keepidle' => 30,
'tcp_keepinterval' => 10, 'tcp_keepinterval' => 10,
'tcp_keepcount' => 10, 'tcp_keepcount' => 10,
'open_http_protocol' => false, 'open_http_protocol' => false,
'open_websocket_protocol' => false, 'open_websocket_protocol' => false,
]); ]);
$this->listenPort($service, $mode); $this->listenPort($service, $mode);
} }
public function zookeeper()
{
}
/** /**
* @param $service * @param $service
* @return string * @return string
*/ */
private function already($service): string #[Pure] private function already($service): string
{ {
return sprintf('Port %s::%d is already.', $service['host'], $service['port']); return sprintf('Port %s::%d is already.', $service['host'], $service['port']);
} }