springcloudalibaba架构(12):Feign整合Sentinel实现服务容错

Feign远程调用，Sentinel限流。
如何将Feign整合Sentinel实现服务容错？
如何获取Feign远程调用时的异常进行问题排查？

本章代码已分享至Gitee:https://gitee.com/lengcz/springcloudalibaba01.git

1. 引入依赖

<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>

2. 开启feign对sentinel的支持

feign:sentinel:enabled:true#开启feign对sentinel的支持

3. 设置容错的类@FeignClient(value=“server-product”,fallback = ProductServiceFallback.class)

/**  * value用于指定调用的nacos下哪个微服务<br>  * fallback用于指定当前feign接口容错类  */@FeignClient(value="server-product",fallback=ProductServiceFallback.class)publicinterfaceProductService{@RequestMapping("/product/{pid}")ProductfindById(@PathVariableInteger pid);}

4. 实现容错方法（当远程服务不可用时，进行服务容错，进入fallback指定的类的同名方法）

/**  * 容错类,需要实现Feign所在的接口，并去实现接口中的所有方法,一旦Feign远程调用出现问题了，就会进入当前类的同名方法，执行容错逻辑  */@ServicepublicclassProductServiceFallbackimplementsProductService{@OverridepublicProductfindById(Integer pid){Product product=newProduct();         product.setPid(-1);         product.setPname("远程调用微服务异常，进入容错");return product;}}

注:容错类的方法的返回值、方法名、参数必须和原来保持一致。

5. 修改controller，当pid为-1表示下单失败。
   

6. 启动order和product对应的微服务，发起请求测试，正常情况下可以查询到 Product的信息。
   
   当将product微服务停止了，再次请求下单接口。
   

从第一节的内容，我们可以看到，当调用外部微服务发生异常时，我们并不能看到发生了什么异常，这导致我们很难进行问题排查。使用FacllbackFactory接口，就可以获取到Feign远程调用时发生的异常了。如何操作呢？对第一节的demo进行小小的改动。

1. 实现FallbackFactory

/**  * 容错类,需要实现Feign所在的接口，并去实现接口中的所有方法,一旦Feign远程调用出现问题了，就会进入当前类的同名方法，执行容错逻辑  */@Service@Slf4jpublicclassProductServiceFallbackFactoryimplementsFallbackFactory<ProductService>{@OverridepublicProductServicecreate(Throwable throwable){         log.error("======"+throwable.getMessage());returnnewProductService(){@OverridepublicProductfindById(Integer pid){Product product=newProduct();                 product.setPid(-1);                 product.setPname("FallbackFactory远程调用微服务异常，进入容错");return product;}};}}

2. 指定fallbackFactory=ProductServiceFallbackFactory

/**  * value用于指定调用的nacos下哪个微服务<br>  * fallback用于指定当前feign接口容错类  *///@FeignClient(value="server-product",fallback = ProductServiceFallback.class)@FeignClient(value="server-product",fallbackFactory=ProductServiceFallbackFactory.class)publicinterfaceProductService{@RequestMapping("/product/{pid}")ProductfindById(@PathVariableInteger pid);}

3. 只启动order微服务进行请求测试，可以发现能看到Feign调用的异常信息。
   

通过实现FallbackFactory<要实现的接口类>，我们可以捕获到发生的异常进行记录和处理，进行问题排查。