服务降级

服务降级，其实对功能的一种容错机制，这里指的是RPC调用服务降级和普通的服务降级。

普通服务降级

比如内部服务调用失败后，为不影响正常请求，可以实现 Fallback，实现对服务的降级。Fallback 定义有目前有三种形式。

  • 全局函数
  • 匿名函数
  • 可以调用的 Callback
  1. // 全局函数
  2. function method()
  3. {
  4.     // ..
  5. }
  7. // 匿名函数
  9. $fallback = function(){
  10.                 // ...
  11.             };
  13. // callback
  14. class xxx
  15. {
  16.   public function method()
  17.   {
  19.   }
  20. }

RPC服务降级

注解

@Fallback

定义RPC服务降级处理的接口实现。

  • name 降级功能名称，缺省使用类名

定义降级服务

  1. /**
  2.  * Fallback demo
  3.  *
  4.  * @Fallback("demoFallback")
  5.  * @method ResultInterface deferGetUsers(array $ids)
  6.  * @method ResultInterface deferGetUser(string $id)
  7.  * @method ResultInterface deferGetUserByCond(int $type, int $uid, string $name, float $price, string $desc = "desc")
  8.  */
  9. class DemoServiceFallback implements DemoInterface
  10. {
  11.     public function getUsers(array $ids)
  12.     {
  13.         return ['fallback', 'getUsers', func_get_args()];
  14.     }
  16.     public function getUser(string $id)
  17.     {
  18.         return ['fallback', 'getUser', func_get_args()];
  19.     }
  21.     public function getUserByCond(int $type, int $uid, string $name, float $price, string $desc = "desc")
  22.     {
  23.         return ['fallback', 'getUserByCond', func_get_args()];
  24.     }
  25. }
  • 需要使用注解定义defer函数，此处不做详细描述，请查看RPC客户单章节
  • DemoInterface 是RPC章节的lib接口，每个接口可以实现多个不用的降级服务
  • RPC服务调用失败后，就会调用实现的服务降级里面函数

使用实例

  1. /**
  2.  * rpc controller test
  3.  *
  4.  * @Controller(prefix="rpc")
  5.  */
  6. class RpcController
  7. {
  9.     /**
  10.      * @Reference(name="user", fallback="demoFallback")
  11.      *
  12.      * @var DemoInterface
  13.      */
  15.     /**
  16.      * @return array
  17.      */
  18.     public function fallback()
  19.     {
  20.         $result1  = $this->demoService->getUser('11');
  21.         $result2  = $this->demoService->getUsers(['1','2']);
  22.         $result3  = $this->demoService->getUserByCond(1, 2, 'boy', 1.6);
  24.         return [
  25.             $result1,
  26.             $result2,
  27.             $result3,
  28.         ];
  29.     }
  31.     /**
  32.      * @return array
  33.      */
  34.     public function deferFallback()
  35.     {
  36.         $result1  = $this->demoService->deferGetUser('11')->getResult();
  37.         $result2  = $this->demoService->deferGetUsers(['1','2'])->getResult();
  38.         $result3  = $this->demoService->deferGetUserByCond(1, 2, 'boy', 1.6)->getResult();
  40.         return [
  41.             'defer',
  42.             $result1,
  43.             $result2,
  44.             $result3,
  45.         ];
  46.     }
  47. }
  • @Reference注解，指定fallback服务降级实现，如果不是同一个接口实现，会抛出异常