springCloud - 第5篇 - 断路器 Hystrix ( Feign 、Ribbon )

2024-06-04 13:58

本文主要是介绍springCloud - 第5篇 - 断路器 Hystrix ( Feign 、Ribbon ),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到教程。

一、为什么要有熔断

在微服务架构中,根据业务来拆分成一个个的服务,服务与服务之间可以相互调用(RPC),在Spring Cloud可以用RestTemplate+Ribbon和Feign来调用。为了保证其高可用,单个服务通常会集群部署。由于网络原因或者自身的原因,服务并不能保证100%可用,如果单个服务出现问题,调用这个服务就会出现线程阻塞,此时若有大量的请求涌入,Servlet容器的线程资源会被消耗完毕,导致服务瘫痪。服务与服务之间的依赖性,故障会传播,会对整个微服务系统造成灾难性的严重后果,这就是服务故障的 “雪崩” 效应。

为了解决这个问题,业界提出了断路器模型 。

以上出自:https://blog.csdn.net/forezp/article/details/81040990 

二、熔断实现

1. 首先 启动 注册中心 eureka 工程、服务生产者 see-param 工程(8803端口)、

                     服务消费者 feign 工程(8702端口)、服务消费者 ribbon 工程(8701 端口)。

(生产者和消费者这 2 个概念是相对的。在不同的业务场景中,2 者身份可互换。或多服务时,同一服务可兼具 2 个身份。)

分别访问 生产者:

2. feign 中熔断器实现。

配置文件中开启熔断:

# 开启断熔器: ( Feign 自带断路器,但默认为不开启: false)
feign.hystrix.enabled=true

在 SeeParamService 类中 @FeignClient 注解中加上参数 fallback ,并指明熔断方法实现类。

书写 熔断方法实现类:

package com.feign.servicefeign;import org.springframework.stereotype.Component;/*** @author yujiang* @description 迷断回调方法类* @date 2019/7/24 9:39*/// 注入IOC容器中,把本类交给 spring 管理
@Component
public class SeeParamError implements SeeParamService {@Overridepublic String seeParam(String param) {return " 乖乖加班吧,服务挂了,搬砖,搬砖 ... ";}}

此时, 关闭服务生产者 see-param 工程,并再访问其服务:

至此,feign  熔断生效 。

3. ribbon 中熔断器实现。

ribbon 并不自带迷断功能,故要引入依赖:

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

工程启动类加注解  @EnableHystrix ,开启熔断。

SeeParamService 类中,在要实现熔断的方法上加注解:@HystrixCommand(fallbackMethod = "熔断实现方法名"),如:
package com.ribbon.serviceribbon;import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;/*** @author yujiang* @description* @date 2019/7/22 11:45*/
@Service
public class SeeParamService {@AutowiredRestTemplate restTemplate;/*** 注解 @HystrixCommand :* 开启熔断器,指定熔断时回调方法为 seeParamError** @param param* @return*/@HystrixCommand(fallbackMethod = "seeParamError")public String seeService(String param) {return restTemplate.getForObject("http://see-param/seeParam?param=" + param, String.class);}/*** 熔断 调用此方法** @return*/public String seeParamError(String param) {return " 哎,别瞅了,别瞅了,服务已经 go die ...";}}

此时, 关闭服务生产者 see-param 工程,并再访问其服务:

至此,ribbon  熔断生效 。

--------------------------------------------------------------

下一篇:springCloud - 第6篇 - 网关的实现:ZUUL

源码见:https://gitee.com/FJ_WoMenDeShiJie/springcloud-feign

              https://gitee.com/FJ_WoMenDeShiJie/springcloud-ribbon

--------------------------------------------------------------

PS:这个系列不定时更新,只是个人的学习分享,

内容全程参考书目:

《Spring Cloud 与 Docker 微服务架构空实战 》、

《Spring Cloud 微服务实战》及此书作者博客:http://blog.didispace.com/spring-cloud-learning/

《深入理解 Spring Cloud 与微服务构建》及此书作者博客:https://blog.csdn.net/forezp/article/details/70148833
--------------------------------------------------------------

这篇关于springCloud - 第5篇 - 断路器 Hystrix ( Feign 、Ribbon )的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1030273

相关文章

Spring Boot集成/输出/日志级别控制/持久化开发实践

《SpringBoot集成/输出/日志级别控制/持久化开发实践》SpringBoot默认集成Logback,支持灵活日志级别配置(INFO/DEBUG等),输出包含时间戳、级别、类名等信息,并可通过... 目录一、日志概述1.1、Spring Boot日志简介1.2、日志框架与默认配置1.3、日志的核心作用

破茧 JDBC:MyBatis 在 Spring Boot 中的轻量实践指南

《破茧JDBC:MyBatis在SpringBoot中的轻量实践指南》MyBatis是持久层框架,简化JDBC开发,通过接口+XML/注解实现数据访问,动态代理生成实现类,支持增删改查及参数... 目录一、什么是 MyBATis二、 MyBatis 入门2.1、创建项目2.2、配置数据库连接字符串2.3、入

Springboot项目启动失败提示找不到dao类的解决

《Springboot项目启动失败提示找不到dao类的解决》SpringBoot启动失败,因ProductServiceImpl未正确注入ProductDao,原因:Dao未注册为Bean,解决:在启... 目录错误描述原因解决方法总结***************************APPLICA编

深度解析Spring Security 中的 SecurityFilterChain核心功能

《深度解析SpringSecurity中的SecurityFilterChain核心功能》SecurityFilterChain通过组件化配置、类型安全路径匹配、多链协同三大特性,重构了Spri... 目录Spring Security 中的SecurityFilterChain深度解析一、Security

SpringBoot多环境配置数据读取方式

《SpringBoot多环境配置数据读取方式》SpringBoot通过环境隔离机制,支持properties/yaml/yml多格式配置,结合@Value、Environment和@Configura... 目录一、多环境配置的核心思路二、3种配置文件格式详解2.1 properties格式(传统格式)1.

Apache Ignite 与 Spring Boot 集成详细指南

《ApacheIgnite与SpringBoot集成详细指南》ApacheIgnite官方指南详解如何通过SpringBootStarter扩展实现自动配置,支持厚/轻客户端模式,简化Ign... 目录 一、背景:为什么需要这个集成? 二、两种集成方式(对应两种客户端模型) 三、方式一:自动配置 Thick

Spring WebClient从入门到精通

《SpringWebClient从入门到精通》本文详解SpringWebClient非阻塞响应式特性及优势,涵盖核心API、实战应用与性能优化,对比RestTemplate,为微服务通信提供高效解决... 目录一、WebClient 概述1.1 为什么选择 WebClient?1.2 WebClient 与

Java.lang.InterruptedException被中止异常的原因及解决方案

《Java.lang.InterruptedException被中止异常的原因及解决方案》Java.lang.InterruptedException是线程被中断时抛出的异常,用于协作停止执行,常见于... 目录报错问题报错原因解决方法Java.lang.InterruptedException 是 Jav

深入浅出SpringBoot WebSocket构建实时应用全面指南

《深入浅出SpringBootWebSocket构建实时应用全面指南》WebSocket是一种在单个TCP连接上进行全双工通信的协议,这篇文章主要为大家详细介绍了SpringBoot如何集成WebS... 目录前言为什么需要 WebSocketWebSocket 是什么Spring Boot 如何简化 We

java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)

《java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)》:本文主要介绍java中pdf模版填充表单踩坑的相关资料,OpenPDF、iText、PDFBox是三... 目录准备Pdf模版方法1:itextpdf7填充表单(1)加入依赖(2)代码(3)遇到的问题方法2:pd