SpringCloud 使用Feign调用接口、Hystrix实现服务容错保护

2022-08-06 10:09:25

文章目录

SpringCloud 使用Feign结合Hystrix实现服务容错保护

前言

Hystrix 容错保护，实现代码在调用的时候是+号拼接，实现方式有点不优雅，如下图所示。

Hystrix 兜底降级

@HystrixCommand(fallbackMethod="fallback1")public UsergetUser1(int id){//user微服务的名字 用来想此服务发送请求
        String  servceId="user-server";

        String url="http://"+ servceId+"/getUser?id="+ id;
        System.out.println(url+" =  "+  url);
        User forObject= restTemplate.getForObject(url, User.class);return forObject;}

Hystrix 降级方法

/**
     * 使用@HystrixCommand注解指定当该方法发生异常时调用的方法
     * @param id id
     * @return 通过id查询到的用户
     */public Userfallback1(int id){returnnewUser(id,"test 用户 ","查询用户异常！","1");}
/**
     * 使用Feign 客户端进行容错
     */@HystrixCommand(fallbackMethod="fallback2")public UsergetUser2(int id){
        System.out.println(2);return userFeginInterface.getUser(id);}

错误信息代码

public Userfallback2(int id){returnnewUser(id,"test 用户 ","查询用户异常！","1");}

Hystrix特性

1.断路器机制

断路器很好理解, 当Hystrix Command请求后端服务失败数量超过一定比例(默认50%), 断路器会切换到开路状态(Open). 这时所有请求会直接失败而不会发送到后端服务. 断路器保持在开路状态一段时间后(默认5秒), 自动切换到半开路状态(HALF-OPEN). 这时会判断下一次请求的返回情况, 如果请求成功, 断路器切回闭路状态(CLOSED), 否则重新切换到开路状态(OPEN). Hystrix的断路器就像我们家庭电路中的保险丝, 一旦后端服务不可用, 断路器会直接切断请求链, 避免发送大量无效请求影响系统吞吐量, 并且断路器有自我检测并恢复的能力.

2.Fallback

Fallback相当于是降级操作. 对于查询操作, 我们可以实现一个fallback方法, 当请求后端服务出现异常的时候, 可以使用fallback方法返回的值. fallback方法的返回值一般是设置的默认值或者来自缓存.

3.资源隔离

在Hystrix中, 主要通过线程池来实现资源隔离. 通常在使用的时候我们会根据调用的远程服务划分出多个线程池. 例如调用产品服务的Command放入A线程池, 调用账户服务的Command放入B线程池. 这样做的主要优点是运行环境被隔离开了. 这样就算调用服务的代码存在bug或者由于其他原因导致自己所在线程池被耗尽时, 不会对系统的其他服务造成影响. 但是带来的代价就是维护多个线程池会对系统带来额外的性能开销. 如果是对性能有严格要求而且确信自己调用服务的客户端代码不会出问题的话, 可以使用Hystrix的信号模式(Semaphores)来隔离资源.

Feign（声明式调用） + Hystrix（熔断）

因为熔断只是作用在服务调用这一端，服务端可以参考上一篇的两个服务点击到达

Feign是Netflix开发的⼀个轻量级RESTful的HTTP服务客户端（⽤它来发起请求，远程调⽤的），是以Java接⼝注解的⽅式调⽤Http请求，⽽不⽤像Java中通过封装HTTP请求报⽂的⽅式直接调⽤，Feign被⼴泛应⽤在Spring Cloud 的解决⽅案中。

  • Feign可帮助我们更加便捷，优雅的调⽤HTTP API：不需要我们去拼接url然后呢调⽤restTemplate的api，在SpringCloud中，使⽤Feign⾮常简单，创建⼀个接⼝（在消费者–服务调⽤⽅这⼀端），并在接⼝上添加⼀些注解，代码就完成了

  • SpringCloud对Feign进⾏了增强，使Feign⽀持了SpringMVC注解（OpenFeign）

首先导入Maven依赖

<!-- 整合hystrix --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-hystrix</artifactId><version>1.4.7.RELEASE</version></dependency><!--    feign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-feign</artifactId><version>1.4.7.RELEASE</version></dependency>

或者引入这个Feign = RestTemplate+Ribbon+Hystrix

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency>

Feign声明客户端接口

简单调用

@FeignClient(value="cloud-eureka-client-8081")publicinterfaceUserFeginInterface{//此处的url 必须和 @FeignClient 注解中指定的服务中访问的url一样@RequestMapping(value="/getUser",method= RequestMethod.GET)
    UsergetUser(@RequestParam("id")int id);}

调用 + 熔断

//@RequestMapping的url前缀限定、改成配置在@FeignClient的path属性中// path 中表示controller的前缀url  即 /api/test  path = "/api"//fallback 关联回退方法，指定回退的类@FeignClient(value="user-server",fallback= HelloServiceImpl.class)publicinterfaceUserFeginInterface{//此处的url 必须和 @FeignClient 注解中指定的服务中访问的url一样@RequestMapping(value="/getUser",method= RequestMethod.GET)
    UsergetUser(@RequestParam("id")int id);}

Controller控制

@RestControllerpublicclassGetUserController{@Autowiredprivate UserService userService;// 调用@RequestMapping("get1")public UsergetUser1(int id){return userService.getUser1(id);}//fegin +  Hystrix 熔断@RequestMapping("get2")public UsergetUser2(int id){return userService.getUser2(id);}}

Service业务层

@ServicepublicclassUserService{@Autowired
    RestTemplate restTemplate;//服务发现对象@Autowired
    DiscoveryClient discoveryClient;@Autowiredprivate UserFeginInterface userFeginInterface;/**
     * 使用 Hystrix  进行容错
     * @param id
     * @return
     */@HystrixCommand(fallbackMethod="fallback1")public UsergetUser1(int id){//user微服务的名字 用来想此服务发送请求
        String  servceId="user-server";

        String url="http://"+ servceId+"/getUser?id="+ id;
        System.out.println(url+" =  "+  url);
        User forObject= restTemplate.getForObject(url, User.class);return forObject;}/**
     * 使用Hystrix 客户端进行容错
     */@HystrixCommand(fallbackMethod="fallback2")public UsergetUser2(int id){
        System.out.println(2);return userFeginInterface.getUser(id);}/**
     * 使用@HystrixCommand注解指定当该方法发生异常时调用的方法
     * @param id id
     * @return 通过id查询到的用户
     */public Userfallback1(int id){returnnewUser(id,"test 用户 ","查询用户异常！","1");}public Userfallback2(int id){returnnewUser(id,"test 用户 ","查询用户异常！","1");}}

feign 日志配置

FeignConfig

// Feign的⽇志级别（Feign请求过程信息）// NONE：默认的，不显示任何⽇志----性能最好// BASIC：仅记录请求⽅法、URL、响应状态码以及执⾏时间----⽣产问题追踪// HEADERS：在BASIC级别的基础上，记录请求和响应的header// FULL：记录请求和响应的header、body和元数据----适⽤于开发及测试环境定位问题@ConfigurationpublicclassFeignConfig{/**
     * 日志配置
     * @return
     */@Bean
    Logger.LevelfeignLevel(){return Logger.Level.FULL;}}

yml中配置

# 开启Feign的熔断功能feign:compression:request:enabled:true# 开启请求压缩mime-types: text/html,application/xml,application/json# 设置压缩的数据类型，此处也是默认值min-request-size:2048# 设置触发压缩的⼤⼩下限，此处也是默认值hystrix:enabled:true#开启Feign的熔断功能logging:level:# Feign⽇志只会对⽇志级别为debug的做出响应com.feign.FeignIntface: debug#针对的被调⽤⽅微服务名称,不加就是全局⽣效server_pruduce_8081:# 实例名称ribbon:#请求连接超时时间 也就是feign的超时时长设置# ConnectTimeout: 2000#请求处理超时时间ReadTimeout:15000#对所有操作都进⾏重试OkToRetryOnAllOperations:true####根据如上配置，当访问到故障请求的时候，它会再尝试访问⼀次当前实例（次数由MaxAutoRetries配置），####如果不⾏，就换⼀个实例进⾏访问，如果还不⾏，再换⼀次实例访问（更换次数由MaxAutoRetriesNextServer配置），####如果依然不⾏，返回失败信息。MaxAutoRetries:0#对当前选中实例重试次数，不包括第⼀次调⽤MaxAutoRetriesNextServer:0#切换实例的重试次数NFLoadBalancerRuleClassName:
      com.netflix.loadbalancer.RoundRobinRule#负载策略调整#当前有两个超时时间设置（Feign/hystrix），熔断的时候是根据这两个时间的最⼩值来进⾏的，# 配置熔断策略：hystrix:command:default:execution:isolation:thread:##########################################Hystrix的超时时⻓设置# 默认是1stimeoutInMilliseconds:16000

注
当前有两个超时时间设置（Feign/hystrix），熔断的时候是根据这两个时间的最⼩值来进⾏的。

Main方法开启Fegin熔断开关

@EnableFeignClients

启动测试

测试的时候停止一个服务

正常访问
在这里插入图片描述
异常访问

在这里插入图片描述

代码地址传送门

  • 作者：Flechazo`
  • 原文链接：https://pilgrim.blog.csdn.net/article/details/103229367
    更新时间：2022-08-06 10:09:25