控制器聚合调用

  1. namespace App\HttpController;
  4. use EasySwoole\Http\AbstractInterface\Controller;
  5. use EasySwoole\Rpc\Response;
  6. use EasySwoole\Rpc\Rpc;
  8. class Index extends Controller
  9. {
  11.     function index()
  12.     {
  13.         $ret = [];
  14.         $client = Rpc::getInstance()->client();
  15.         /*
  16.          * 调用商品列表
  17.          */
  18.         $client->addCall('goods','list',['page'=>1])
  19.             ->setOnSuccess(function (Response $response)use(&$ret){
  20.                 $ret['goods'] = $response->toArray();
  21.             })->setOnFail(function (Response $response)use(&$ret){
  22.                 $ret['goods'] = $response->toArray();
  23.             });
  24.         /*
  25.          * 调用信箱公共
  26.          */
  27.         $client->addCall('common','mailBox')
  28.             ->setOnSuccess(function (Response $response)use(&$ret){
  29.                 $ret['mailBox'] = $response->toArray();
  30.             })->setOnFail(function (Response $response)use(&$ret){
  31.                 $ret['mailBox'] = $response->toArray();
  32.             });
  33.         /*
  34.         * 获取系统时间
  35.         */
  36.         $client->addCall('common','serverTime')
  37.             ->setOnSuccess(function (Response $response)use(&$ret){
  38.                 $ret['serverTime'] = $response->toArray();
  39.             });
  41.         $client->exec(2.0);
  43.         $this->writeJson(200,$ret);
  44.     }
  45. }

注意，控制器中可以这样调用，是因为服务端章节中，在EasySwoole的全局启动事件已经对当前的Rpc实例定义注册了节点管理器。因此在控制器中调用的时候 该Rpc实例可以找到对应的节点。一般来说，在做聚合网关的节点，是不需要注册服务进去的，仅需注册节点管理器即可。