feat:

1、服务类不存在
2、服务方法不存在
3、自定义异常状态码和错误消息

src/Protocol/RpcTextProtocol.php

@@ -15,18 +15,33 @@ class RpcTextProtocol
 {
     /**
      * @param TcpConnection $connection
-     * @param $data
+     * @param string $data
+     * @return bool|null
      */
-    public function onMessage(TcpConnection $connection, $data)
+    public function onMessage(TcpConnection $connection, string $data): ?bool
     {
         static $instances = [];
         $data = json_decode($data, true);
-        $class = config('plugin.tinywan.rpc.app.rpc.namespace').$data['class'];
+        $config = config('plugin.tinywan.rpc.app');
+        $class = $config['rpc']['namespace'].$data['class'];
+        if (!class_exists($class)) {
+            return $connection->send(json_encode([
+                'code' => $config['response']['class']['code'],
+                'msg' => $class. $config['response']['class']['msg']
+            ]));
+        }
+
         $method = $data['method'];
+        if (!method_exists($class,(string) $method)) {
+            return $connection->send(json_encode([
+                'code' => $config['response']['method']['code'],
+                'msg' => $method. $config['response']['method']['msg']
+            ]));
+        }
         $args = $data['args'];
         if (!isset($instances[$class])) {
             $instances[$class] = new $class();
         }
-        $connection->send(call_user_func_array([$instances[$class], $method], $args));
+        return $connection->send(call_user_func_array([$instances[$class], $method], $args));
     }
 }

src/config/plugin/tinywan/rpc/app.php

@@ -5,5 +5,16 @@
     'rpc' => [
         'namespace'=> 'service\\', // 自定义服务命名空间
         'listen_text_address' => 'text://0.0.0.0:9512', // 自定义Text协议地址
+    ],
+    // 异常响应码和消息定义
+    'response' => [
+        'class'=> [
+            'code' => 404,
+            'msg' => '服务类不存在',
+        ],
+        'method'=> [
+            'code' => 404,
+            'msg' => '服务类方法不存在',
+        ],
     ]
 ];