服务定义

每一个Rpc服务都应继承自 EasySwoole\Rpc\AbstractService 类。该类的具体代码如下：

  1. namespace EasySwoole\Rpc;
  4. use EasySwoole\Component\TableManager;
  5. use Swoole\Coroutine;
  7. abstract class AbstractService
  8. {
  9.     private $allowMethods = [];
  10.     private $requests = [];
  11.     private $responses = [];
  12.     private $sockets = [];
  13.     private $actions = [];
  14.     /*
  15.      * 禁止重写该方法，防止在构造函数中抛出异常
  16.      */
  17.     final public function __construct()
  18.     {
  19.         //支持在子类控制器中以private，protected来修饰某个方法不可见
  20.         $list = [];
  21.         $ref = new \ReflectionClass(static::class);
  22.         $public = $ref->getMethods(\ReflectionMethod::IS_PUBLIC);
  23.         foreach ($public as $item) {
  24.             array_push($list, $item->getName());
  25.         }
  26.         $this->allowMethods = array_diff($list,
  27.             [
  28.                 '__hook', '__destruct',
  29.                 '__clone', '__construct', '__call',
  30.                 '__callStatic', '__get', '__set',
  31.                 '__isset', '__unset', '__sleep',
  32.                 '__wakeup', '__toString', '__invoke',
  33.                 '__set_state', '__clone', '__debugInfo',
  34.                 'serviceName','version','onTick','actionList'
  35.             ]
  36.         );
  37.     }
  39.     protected function onRequest(?string $action):?bool
  40.     {
  41.         return true;
  42.     }
  44.     protected function afterAction(?string $action)
  45.     {
  47.     }
  49.     abstract public function serviceName():string ;
  50.     /*
  51.      * 每秒会执行一次，请自己实现间隔需求
  52.      */
  53.     public function onTick(Config $config)
  54.     {
  56.     }
  58.     protected function onException(\Throwable $throwable)
  59.     {
  60.         throw $throwable;
  61.     }
  63.     protected function request():Request
  64.     {
  65.         return $this->requests[Coroutine::getCid()];
  66.     }
  68.     protected function response():Response
  69.     {
  70.         return $this->responses[Coroutine::getCid()];
  71.     }
  73.     protected function socket():Coroutine\Socket
  74.     {
  75.         return $this->sockets[Coroutine::getCid()];
  76.     }
  78.     protected function action(): ?string
  79.     {
  80.         return $this->actions[Coroutine::getCid()];
  81.     }
  83.     protected function actionNotFound(?string $action)
  84.     {
  85.         $this->response()->setStatus(Response::STATUS_SERVICE_ACTION_NOT_FOUND);
  86.     }
  88.     public function version():string
  89.     {
  90.         return '1.0';
  91.     }
  93.     public function actionList():array
  94.     {
  95.         return $this->allowMethods;
  96.     }
  98.     public function __hook(Request $request, Response $response, Coroutine\Socket $client)
  99.     {
  100.         $this->requests[Coroutine::getCid()] = $request;
  101.         $this->responses[Coroutine::getCid()] = $response;
  102.         $this->sockets[Coroutine::getCid()] = $client;
  103.         $this->actions[Coroutine::getCid()] = $request->getAction();
  104.         $actionName = $this->action();
  105.         try {
  106.             if ($this->onRequest($this->action()) !== false) {
  107.                 if (in_array($actionName, $this->allowMethods)) {
  108.                     $actionName = $this->action();
  109.                     $this->$actionName();
  110.                 } else {
  111.                     $this->actionNotFound($this->action());
  112.                 }
  113.             }
  114.         } catch (\Throwable $throwable) {
  115.             //若没有重构onException，直接抛出给上层
  116.             $this->onException($throwable);
  117.         } finally {
  118.             try {
  119.                 $this->afterAction($this->action());
  120.             } catch (\Throwable $throwable) {
  121.                 $this->onException($throwable);
  122.             }
  123.             unset( $this->requests[Coroutine::getCid()]);
  124.             unset( $this->responses[Coroutine::getCid()]);
  125.             unset( $this->actions[Coroutine::getCid()]);
  126.             unset( $this->sockets[Coroutine::getCid()]);
  127.         }
  128.         if($response->getStatus() === Response::STATUS_OK){
  129.             TableManager::getInstance()->get($this->serviceName())->incr($actionName,'success');
  130.         }else{
  131.             TableManager::getInstance()->get($this->serviceName())->incr($actionName,'fail');
  132.         }
  133.     }
  134. }

注意，全部请求都会复用该实例。因此成员属性的修改访问是不安全的。请用上下文管理器实现变量存储。