grpc断路器之sentinel

柔情只为你懂 2023-07-18 02:51 113阅读 0赞

### 背景 ###

为了防止下游服务雪崩，这里考虑使用断路器

### 技术选型 ###

由于是springboot服务且集成了istio，这里考虑三种方案

*  istio
 *  hystrix
 *  sentinel

这里分别有这几种方案的对比  
[微服务断路器模式实现：Istio vs Hystrix][Istio vs Hystrix]  
[Sentinel 与 Hystrix 的对比][Sentinel _ Hystrix]

首先考虑的是istio，但是在使用istio进行熔断、分流时，流量不稳定，并且返回状态以及数据达不到预取效果，后面考虑到sentinel自动集成了grpc，所以这里使用sentinel。

### 步骤 ###

#### 1、增加相关依赖 ####

<dependencies>
      <dependency>
               <groupId>com.alibaba.cloud</groupId>
               <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
           </dependency>
           <dependency>
               <groupId>com.alibaba.csp</groupId>
               <artifactId>sentinel-grpc-adapter</artifactId>
               <version>1.7.1</version>
           </dependency>
       </dependencies>
    
    <dependencyManagement>
           <dependencies>
               <dependency>
                   <groupId>com.alibaba.cloud</groupId>
                   <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                   <version>2.0.1.RELEASE</version>
                   <type>pom</type>
                   <scope>import</scope>
               </dependency>
              </dependencies>
       </dependencyManagement>

#### 2、增加配置类 ####

方案一：增加全局拦截器

/**
     * @Auther: lipeng
     * @Date: 2020/3/23 17:24
     * @Description:
     */
    @Order(Ordered.LOWEST_PRECEDENCE)
    @Configuration
    @Slf4j
    public class SentinelConfig {
        @Bean
        public ClientInterceptor sentinelGrpcClientInterceptor(){
            return new SentinelGrpcClientInterceptor();
        }
        @Bean
        public GlobalClientInterceptorConfigurer globalInterceptorConfigurerAdapter(ClientInterceptor sentinelGrpcClientInterceptor) {
            return registry -> registry.addClientInterceptors(sentinelGrpcClientInterceptor);
        }
    }

方案二：调用时增加拦截器  
当然这里也可以换一种方式增加拦截器，如下，在启动类中增加

@Bean
        public ClientInterceptor sentinelGrpcClientInterceptor(){
            return new SentinelGrpcClientInterceptor();
        }

然后在调用类中增加依赖

@Autowired
        private ClientInterceptor sentinelGrpcClientInterceptor;
    
       public void doXXX(){
             XXXGrpc.XXXBlockingStub stub = XXXGrpc.newBlockingStub(serverChannel).withInterceptors(sentinelGrpcClientInterceptor);
             XXXApi.XXXResponse response = stub.withDeadlineAfter(grpcTimeout, TimeUnit.MILLISECONDS).doXXX(request);
    
    }

#### 3、增加sentinel dashboard配置 ####

spring:
      cloud:
        sentinel:
          transport:
            port: 8719
            dashboard: localhost:7080

#### 4、部署sentinel dashboard ####

部署参考下面链接：

[Sentinel 控制台][Sentinel]

启动后访问下相关链接，grpc自动集成上去了，效果如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xwMTk4NjExMjY_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xwMTk4NjExMjY_size_16_color_FFFFFF_t_70 1]

详细配置可以参考官方wiki：https://github.com/alibaba/Sentinel/wiki/%E5%A6%82%E4%BD%95%E4%BD%BF%E7%94%A8

[Istio vs Hystrix]: https://www.servicemesher.com/blog/istio-vs-hystrix-circuit-breaker/
[Sentinel _ Hystrix]: https://github.com/alibaba/Sentinel/wiki/Sentinel-%E4%B8%8E-Hystrix-%E7%9A%84%E5%AF%B9%E6%AF%94
[Sentinel]: https://github.com/alibaba/Sentinel/wiki/%E6%8E%A7%E5%88%B6%E5%8F%B0
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xwMTk4NjExMjY_size_16_color_FFFFFF_t_70]: /images/20230528/21d4e5501d384cb0a5dd55987abe1742.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xwMTk4NjExMjY_size_16_color_FFFFFF_t_70 1]: /images/20230528/f77dbc4dd0cf41158c999f1110338f3f.png