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

2022年12月1日08:28:30

前言

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

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

第一节 Feign如何整合Sentinel实现服务容错

  1. 引入依赖
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>
  1. 开启feign对sentinel的支持
feign:sentinel:enabled:true#开启feign对sentinel的支持
  1. 设置容错的类@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);}

springcloudalibaba架构(12):Feign整合Sentinel实现服务容错
4. 实现容错方法(当远程服务不可用时,进行服务容错,进入fallback指定的类的同名方法)

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

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

  1. 修改controller,当pid为-1表示下单失败。
    springcloudalibaba架构(12):Feign整合Sentinel实现服务容错

  2. 启动order和product对应的微服务,发起请求测试,正常情况下可以查询到 Product的信息。
    springcloudalibaba架构(12):Feign整合Sentinel实现服务容错
    当将product微服务停止了,再次请求下单接口。
    springcloudalibaba架构(12):Feign整合Sentinel实现服务容错

第二节 使用FallbackFactory容错获取异常

从第一节的内容,我们可以看到,当调用外部微服务发生异常时,我们并不能看到发生了什么异常,这导致我们很难进行问题排查。使用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;}};}}
  1. 指定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);}
  1. 只启动order微服务进行请求测试,可以发现能看到Feign调用的异常信息。
    springcloudalibaba架构(12):Feign整合Sentinel实现服务容错

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

  • 作者:逆水行舟没有退路
  • 原文链接:https://lengcz.blog.csdn.net/article/details/126249459
    更新时间:2022年12月1日08:28:30 ,共 2277 字。