使用实例

使用比较简单，类似注入普通一个类的实例一样，唯一区别是会有额外的参数。

注解

@Reference

  • name 定义引用那个服务的接口，缺省使用类名，一般都需要定义
  • version 使用该服务的那个版本，用于区别不同版本
  • pool 定义使用哪个连接池，如果不为空，不会根据name配置的名称去查找连接池，而是直接使用配置的连接池。
  • breaker 定义使用哪个熔断器，如果不为空，不会根据name配置的名称去查找熔断器，而是直接使用配置的熔断器
  • packer RPC服务调用，会有一个默认的数据解包器，此参数是指定其它的数据解包器，不使用默认的。

实例

  2. /**
  3.  * rpc controller test
  4.  *
  5.  * @Controller(prefix="rpc")
  6.  */
  7. class RpcController
  8. {
  10.     /**
  11.      * @Reference("user")
  12.      *
  13.      * @var DemoInterface
  14.      */
  15.     private $demoService;
  17.     /**
  18.      * @Reference(name="user", version="1.0.1")
  19.      *
  20.      * @var DemoInterface
  21.      */
  22.     private $demoServiceV2;
  24.     /**
  25.      * @Reference("user")
  26.      * @var \App\Lib\MdDemoInterface
  27.      */
  28.     private $mdDemoService;
  30.     /**
  31.      * @RequestMapping(route="call")
  32.      * @return array
  33.      */
  34.     public function call()
  35.     {
  36.         $version  = $this->demoService->getUser('11');
  37.         $version2 = $this->demoServiceV2->getUser('11');
  39.         return [
  40.             'version'  => $version,
  41.             'version2' => $version2,
  42.         ];
  43.     }
  45.     /**
  46.      * Defer call
  47.      */
  48.     public function defer(){
  49.         $defer1 = $this->demoService->deferGetUser('123');
  50.         $defer2 = $this->demoServiceV2->deferGetUsers(['2', '3']);
  51.         $defer3 = $this->demoServiceV2->deferGetUserByCond(1, 2, 'boy', 1.6);
  53.         $result1 = $defer1->getResult();
  54.         $result2 = $defer2->getResult();
  55.         $result3 = $defer3->getResult();
  57.         return [$result1, $result2, $result3];
  58.     }
  59. }

@Reference 注解可以任何Bean实例的类中使用，不仅仅是controller，这里只是测试。如果要使用延迟收包或并发，必须使用deferXxx方法。

非 Swoft 框架

如果服务端采用 JSON 协议，非 Swoft 框架可以按照下面的 demo 格式封装调用

  1. $result = call('App\Lib\DemoInterface', '1.0.1', 'getUsers', [['1','2']]);
  2. var_dump($result);
  4. function call(string $interface, string $version, string $method, array $params = [])
  5. {
  6.     $fp = stream_socket_client('tcp://127.0.0.1:8099', $errno, $errstr);
  7.     if (!$fp) {
  8.         throw new Exception("stream_socket_client fail errno={$errno} errstr={$errstr}");
  9.     }
  11.     $data = [
  12.         'interface' => $interface,
  13.         'version'   => $version,
  14.         'method'    => $method,
  15.         'params'    => $params,
  16.         'logid'     => uniqid(),
  17.         'spanid'    => 0,
  18.     ];
  20.     $data = json_encode($data, JSON_UNESCAPED_UNICODE);
  21.     fwrite($fp, $data);
  22.     $result = fread($fp, 1024);
  23.     fclose($fp);
  24.     return $result;
  25. }

如果服务端rpc 配置了 package_eof = "\r\n", 客户端则需要在发送的data后追加 \r\n