StringCloud_Hystrix熔断器和Feign (组件)-阿南达文事网

StringCloud_Hystrix熔断器和Feign (组件)

文章目录

1.Hystrix熔断器-保证程序健壮、高可用
- 1.1.简介
- 1.2.熔断器的工作机制：
- 1.3.动手实践
- - 1.3.1.引入依赖
  - 1.3.2.开启熔断
  - 1.3.2.改造消费者
  - 1.3.3.改造服务提供者
  - 1.3.4.启动测试
  - 1.3.5.优化-设置熔断时间
2.Feign
- 2.1.简介
- 2.2.快速入门（掌握）
- - 2.2.1.导入依赖
  - 2.2.2.开启Feign功能
  - 2.2.3.Feign的客户端
  - 2.2.4.启动测试：
- 2.3.负载均衡
- 2.4.Hystix支持
- 2.5.请求压缩(了解)

回顾：
微服务 组件，SpringCloud技术

1 Eureka：注册中心，服务提供方将ip地址端口信息注册到eureka中，服务消费方从eureka拉取服务，服务提供方每隔30s自动续约，服务消费方每隔30自动拉取服务--------------类似滴滴
2 Ribbon：负载均衡器。SpringCloud中的负载均衡器，默认随机和轮询的负载均衡算法。
为了保证服务的高可用，在搭建集群之后，集群中的某个节点挂了，默认情况下，系统可能会出问题，我们需要设置ribbon的重试信息

1.Hystrix熔断器-保证程序健壮、高可用

在高并发领域，在分布式系统中，可能因为一个小小的功能扛不住压力，宕机了，导致其他服务也跟随宕机，最终导致整个系统宕机，所以在SpringCloud中采用Hystrix进行处理。

1.1.简介

Hystrix，即熔断器。

主页：/

Hystrix是Netflix开源的一个延迟和容错库，用于隔离访问远程服务、第三方库，防止出现级联失败。

1.2.熔断器的工作机制：

正常工作的情况下，客户端请求调用服务API接口：

当有服务出现异常时，直接进行失败回滚，服务降级处理：

当服务繁忙时，如果服务出现异常，不是粗暴的直接报错，而是返回一个友好的提示，虽然拒绝了用户的访问，但是会返回一个结果。

这就好比去买鱼，平常超市买鱼会额外赠送杀鱼的服务。等到逢年过节，超市繁忙时，可能就不提供杀鱼服务了，这就是服务的降级。

系统特别繁忙时，一些次要服务暂时中断，优先保证主要服务的畅通，一切资源优先让给主要服务来使用，在双十一、618时，京东天猫都会采用这样的策略。

结论：Hystrix熔断器，避免某个小服务宕机，导致整个系统级联宕机，从而导致整个系统挂了，可以有效保护其他服务正常提供服务

1.3.动手实践

1.3.1.引入依赖

首先在user-consumer（服务消费者）中引入Hystix依赖：

<!--引入熔断器Hystix依赖-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

1.3.2.开启熔断

1.3.2.改造消费者

我们改造user-consumer，添加一个用来访问的user服务的DAO，并且声明一个失败时的回滚处理函数：

/*** 发起远程调用类*/
@Component
public class UserDao {@Autowiredprivate RestTemplate restTemplate;/*** 当服务器异常，此时熔断，熔断的时候调用  回调方法  queryUserByIdFallback此方法返回的数据是错误的，但是他可以暂时的保护其他服务不受影响150s左右才收到服务挂了的消息，熔断的时间（服务无响应的时间）默认1s*/// HystrixCommand 调用回调方法@HystrixCommand(fallbackMethod = "queryUserByIdFallback")public User queryUserById(Long id){long begin = System.currentTimeMillis();String url = "http://user-service/user/" + id;User user = this.restTemplate.getForObject(url, User.class);long end = System.currentTimeMillis();// 记录访问用时：System.out.println("访问用时:"+(end-begin));return user;}/*** 调用回调方法*/public User queryUserByIdFallback(Long id){User user = new User();user.setId(id);user.setName("用户信息查询出现异常！");return user;}
}

1.3.3.改造服务提供者

User-service 改造服务提供者，随机休眠一段时间，以触发熔断：

@Service
public class UserService {@Autowiredprivate UserMapper userMapper;public User queryById(Long id) throws InterruptedException {// 为了演示超时现象，我们在这里然线程休眠,时间随机 0~2000毫秒Thread.sleep(new Random().nextInt(2000));return this.userMapper.selectByPrimaryKey(id);}
}

1.3.4.启动测试

User-consumer 运行
http://localhost:8081/consume?ids=1,2
id为1,2的访问时间：

因此，只有12是正常访问，其它都会触发熔断，我们来查看结果：

1.3.5.优化-设置熔断时间

虽然熔断实现了，但是我们的重试机制似乎没有生效，是这样吗？

其实这里是因为我们的Ribbon超时时间设置的是1000ms:
user-consumer

而Hystix的超时时间默认也是1000ms，因此重试机制没有被触发，而是先触发了熔断。

所以，Ribbon的超时时间一定要小于Hystix的超时时间。

我们可以通过hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds来设置Hystrix超时时间。

hystrix:command:default:execution:isolation:thread:timeoutInMilliseconds: 6000 # 设置hystrix的超时时间为6000ms

2.Feign

为什么要学习Feign？

答：简化远程代码调用

在前面的学习中，我们使用了Ribbon的负载均衡功能，大大简化了远程调用时的代码：

String baseUrl = "http://user-service/user/";
User user = this.restTemplate.getForObject(baseUrl + id, User.class)

如果就学到这里，你可能以后需要编写类似的大量重复代码，格式基本相同，无非参数不一样。有没有更优雅的方式，来对这些代码再次优化呢？

这就是我们接下来要学的Feign的功能了。

2.1.简介

为什么叫伪装？

Feign可以把Rest的请求进行隐藏，伪装成类似SpringMVC的Controller一样。你不用再自己拼接url，拼接参数等等操作，一切都交给Feign去做。
项目主页：

2.2.快速入门（掌握）

2.2.1.导入依赖

user-consumer

<!--pom.xml:导入Feign依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency>

2.2.2.开启Feign功能

我们在启动类上，添加注解，开启Feign功能

你会发现RestTemplate的注册被我删除了。Feign中已经自动集成了Ribbon负载均衡，因此我们不需要自己定义RestTemplate了

2.2.3.Feign的客户端

@FeignClient("user-service")
public interface UserFeignClient {@GetMapping("/user/{id}")User queryUserById(@PathVariable("id") Long id);
}

首先这是一个接口，Feign会通过动态代理，帮我们生成实现类。
@FeignClient，声明这是一个Feign客户端，类似@Mapper注解。同时通过value属性指定服务名称
接口中的定义方法，完全采用SpringMVC的注解，Feign会根据注解帮我们生成URL，并访问获取结果

改造原来的调用逻辑，修改UserDao：

 @Autowiredprivate UserFeighClient userFeighClient;@HystrixCommand(fallbackMethod = "queryUserByIdFallback")public User queryUserById(Long id){long begin = System.currentTimeMillis();User user = this.userFeighClient.queryById(id);long end = System.currentTimeMillis();System.out.println("用时:"+(begin-end));return user;}/*** 调用回调方法*/public User queryUserByIdFallback(Long id){//熔断机制 给个假数据User user = new User();user.setId(id);user.setName("用户信息查询出现异常！");return user;}

2.2.4.启动测试：

访问接口： http://localhost:8081/consume?ids=1,2

2.3.负载均衡

Feign中本身已经集成了Ribbon依赖和自动配置：

因此我们不需要额外引入依赖，也不需要再注册RestTemplate对象。

另外，我们可以像上节课中讲的那样去配置Ribbon，可以通过ribbon.xx来进行全局配置。也可以通过服务名.ribbon.xx来对指定服务配置：

全局配置：对所有服务都生效

# user-consumer (yaml配置)
ribbon:ConnectTimeout: 250 # 连接超时时间(ms)ReadTimeout: 1000 # 通信超时时间(ms)OkToRetryOnAllOperations: true # 是否对所有操作重试MaxAutoRetriesNextServer: 1 # 同一服务不同实例的重试次数MaxAutoRetries: 1 # 同一实例的重试次数

局部配置：只对当前服务生效

# user-consumer (yaml配置)
user-service:ribbon:ConnectTimeout: 250 # 连接超时时间(ms)ReadTimeout: 1000 # 通信超时时间(ms)OkToRetryOnAllOperations: true # 是否对所有操作重试MaxAutoRetriesNextServer: 1 # 同一服务不同实例的重试次数MaxAutoRetries: 1 # 同一实例的重试次数

2.4.Hystix支持

Feign默认也有对Hystrix的集成：

只不过，默认情况下是关闭的。我们需要通过下面的参数来开启：

feign:hystrix:enabled: true # 开启Feign的熔断功能

但是，Feign中的Fallback配置不像Ribbon中那样简单了。

1）首先，我们要定义一个类，实现刚才编写的UserFeignClient，作为fallback的处理类

@Component
public class UserFeignClientFallback implements UserFeignClient {@Overridepublic User queryUserById(Long id) {User user = new User();user.setId(id);user.setName("用户查询出现异常！");return user;}
}

2）然后在UserFeignClient中，指定刚才编写的实现类

@FeignClient(value = "user-service", fallback = UserFeignClientFallback.class)
public interface UserFeignClient {@GetMapping("/user/{id}")User queryUserById(@PathVariable("id") Long id);
}

3）重启测试：
关闭user-service服务，然后在页面访问：

2.5.请求压缩(了解)

GZIP压缩：

Spring Cloud Feign 支持对请求和响应进行GZIP压缩，以减少通信过程中的性能损耗。通过下面的参数即可开启请求与响应的压缩功能：

user-consumer

feign:compression:request:enabled: true # 开启请求压缩response:enabled: true # 开启响应压缩

同时，我们也可以对请求的数据类型，以及触发压缩的大小下限进行设置：

feign:compression:request:enabled: true # 开启请求压缩mime-types: text/html,application/xml,application/json # 设置压缩的数据类型min-request-size: 2048 # 设置触发压缩的大小下限

注：上面的数据类型、压缩大小下限均为默认值。