eee

Signed-off-by: 向林 <as2252258@163.com>

RpcJsonp.php

@@ -117,6 +117,9 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
             return $server->send($fd, $this->batchDispatch($data), $reactor_id);
         } catch (\Throwable $throwable) {
             $response = Json::encode($this->failure(-32700, $throwable->getMessage()));
+
+			$this->getLogger()->json_log($throwable);
+
             return $server->send($fd, $response, $reactor_id);
         }
     }

RpcProcess.php

@@ -3,11 +3,12 @@
 namespace Kiri\Rpc;
 
 use Kiri\Di\Context;
-use Kiri\Server\Abstracts\BaseProcess;
+use Kiri\Server\Processes\AbstractProcess;
 use Swoole\Coroutine;
 use Swoole\Process;
+use function pcntl_signal;
 
-class RpcProcess extends BaseProcess
+class RpcProcess extends AbstractProcess
 {
 
 
@@ -31,17 +32,9 @@ class RpcProcess extends BaseProcess
 
 
     /**
-     * @return $this
+     * @return void
      */
-    public function onSigterm(): static
+    public function onSigterm(): void
     {
-        // TODO: Implement onSigterm() method.
-        if (Context::inCoroutine()) {
-            Coroutine::create(fn() => $this->onShutdown(Coroutine::waitSignal(SIGTERM | SIGINT)));
-        } else {
-            \pcntl_signal(SIGTERM, [$this, 'onStop']);
-            \pcntl_signal(SIGINT, [$this, 'onStop']);
-        }
-        return $this;
     }
 }

composer.json

@@ -9,11 +9,11 @@
   ],
   "license": "MIT",
   "require": {
-    "php": ">=8.0",
+    "php": ">=8.5",
     "ext-json": "*",
     "ext-msgpack": "*",
     "start-point/etcd-php": "^1.1",
-    "game-worker/kiri-pool": "~v1.0",
+    "game-worker/kiri-pool": "^v1.0",
     "linkorb/etcd-php": "^1.6"
   },
   "replace": {

config.php

@@ -50,7 +50,7 @@ return [
 			"check"          => [
 				"node"        => "t2.320",
 				"checkId"     => "service:redis1",
-				"name"        => "Redis health check",
+				"name"        => "NoSql health check",
 				"Annotations" => "Script based health check",
 				"status"      => "passing",
 				"serviceID"   => "redis1",