熔断器 java_SpringCloud之熔断器Hystrix的实现
前言
SpringCloud 是微服务中的翘楚,最佳的落地方案。
在微服务架构中多层服务之间会相互调用,如果其中有一层服务故障了,可能会导致一层服务或者多层服务
故障,从而导致整个系统故障。这种现象被称为服务雪崩效应。
SpringCloud 中的 Hystrix 组件就可以解决此类问题,Hystrix 负责监控服务之间的调用情况,连续多次失败的
情况进行熔断保护。保护的方法就是使用 Fallback,当调用的服务出现故障时,就可以使用 Fallback 方法的
返回值;Hystrix 间隔时间会再次检查故障的服务,如果故障服务恢复,将继续使用服务。
源码
环境
JDK 1.8.0 +
Maven 3.0 +
SpringBoot 2.0.3
SpringCloud Finchley.RELEASE
开发工具
IntelliJ IDEA
正文
commons 工程
commons 工程 - POM 文件
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
com.zwc
springcloud-hystrix-commons
1.0
springcloud-hystrix-commons
公用工程
jar
UTF-8
1.8
Cairo-SR3
Finchley.RELEASE
io.spring.platform
platform-bom
${platform-bom.version}
pom
import
org.springframework.cloud
spring-cloud-dependencies
${spring-cloud-dependencies.version}
pom
import
org.springframework.boot
spring-boot-maven-plugin
配置一些共用依赖
commons 工程 - 项目结构
service 工程
① 此工程下有四个模块:一个注册中心以及服务 A、B、C
② A 提供服务并且调用服务 B、B 提供服务并且调用服务 C 以及 C 提供服务
registry-service(注册中心)
registry-service - POM 文件
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
com.zwc
springcloud-hystrix-service
1.0
com.zwc
springcloud-hystrix-registry-service
1.0
springcloud-hystrix-registry-service
注册中心
jar
com.zwc
springcloud-hystrix-commons
1.0
org.springframework.cloud
spring-cloud-starter-netflix-eureka-server
org.springframework.boot
spring-boot-maven-plugin
主要是加入 spring-cloud-starter-netflix-eureka-server 依赖registry-service - application.yml 配置文件
# 端口
server:
port: 8761
# 应用名称
spring:
application:
name: eurka-server
eureka:
instance:
# 使用 ip 代替实例名
prefer-ip-address: true
# 实例的主机名
hostname: ${spring.cloud.client.ip-address}
# 实例的 ID 规则
instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}
client:
# 是否向注册中心注册自己
registerWithEureka: false
# 是否向注册中心获取注册信息
fetchRegistry: false
serviceUrl:
# 注册中心地址
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
这里使用了默认的 8761 端口,当然也可以更改,不过在发现调用服务端的注册中心地址端口要与它一致
registry-service - 启动类
package com.zwc;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication
@EnableEurekaServer
public class SpringcloudHystrixRegistryServiceApplication {
public static void main(String[] args) {
SpringApplication.run(SpringcloudHystrixRegistryServiceApplication.class, args);
}
}
在启动类中添加 @EnableEurekaServer 注解表示此工程是注册中心
registry-service - 启动项目
1. 项目启动成功后访问 http://localhost:8761/ 即可看到 eureka-server 主页面
服务工程 A(提供者和消费者)
服务工程 A - POM 文件
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
com.zwc
springcloud-hystrix-a-service
1.0
com.zwc
springcloud-hystrix-a-service-core
1.0
springcloud-hystrix-a-service-core
服务工程 - A 核心
jar
com.zwc
springcloud-hystrix-commons
1.0
com.zwc
springcloud-hystrix-a-service-api
1.0
org.springframework.cloud
spring-cloud-starter-netflix-eureka-client
org.springframework.cloud
spring-cloud-starter-openfeign
org.springframework.boot
spring-boot-maven-plugin
加入 spring-cloud-starter-netflix-eureka-client 依赖
还需要加入 Feign 的起步依赖 spring-cloud-starter-openfeign
服务工程 A - application.yml 配置文件
# 端口
server:
port: 8090
# 应用名称
spring:
application:
name: hystrix-a
eureka:
instance:
# 使用 ip 代替实例名
prefer-ip-address: true
# 实例的主机名
hostname: ${spring.cloud.client.ip-address}
# 实例的 ID 规则
instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}
client:
serviceUrl:
# 注册中心地址
defaultZone: http://${eureka.instance.hostname}:8761/eureka/
注意此处配置注册中心地址的端口为 8761 也就是上面注册中心工程配置的端口
spring.application.name:应用名称,被消费者调用时需要用到,它在消费的同时也可以被消费
这里除注册中心工程以外的三个工程都与此配置相似,不一样的地方就是端口和应用名称,不再赘述
服务工程 A - application.properties(注意)
# 开启断路器
feign.hystrix.enabled=true
断路器要主动开启,服务调用失败时才会熔断
此处有一个坑,把此配置写到 application.yml 中熔断不会生效
A 和 B 工程都有此配置,此次搭建中 C 工程只提供服务,没有消费服务。所以 C 工程不用该配置
application.properties 和 bootstrap.yml 二选一就行
服务工程 A - bootstrap.yml(注意)
feign:
hystrix:
# 开启断路器
enabled: true
断路器要主动开启,服务调用失败时才会熔断
此处有一个坑,把此配置写到 application.yml 中熔断不会生效
application.properties 和 bootstrap.yml 二选一就行
服务工程 A - controller 前端控制器(提供服务)
package com.zwc.a.controller;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/*
* @ClassName ASayHelloController
* @Desc TODO Say Hello
* @Date 2019/5/20 23:24
* @Version 1.0
*/
@RestController
public class ASayHelloController {
/*
* @ClassName ASayHelloController
* @Desc TODO 读取配置文件中的端口
* @Date 2019/5/20 23:24
* @Version 1.0
*/
@Value("${server.port}")
private String port;
/*
* @ClassName ASayHelloController
* @Desc TODO Say Hello
* @Date 2019/5/20 23:24
* @Version 1.0
*/
@RequestMapping("/a")
public String a(){
return "Hello!I'm a. port:" + port;
}
}
提供一个服务:输出 Hello 和端口
服务工程 A - 服务调用
package com.zwc.a.api.feign;
import com.zwc.a.api.impl.FeignApiFallBack;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
/*
* @ClassName FeignApi
* @Desc TODO 使用 Feign 调用 b - 接口
* @Date 2019/5/20 23:21
* @Version 1.0
*/
@FeignClient(value = "hystrix-b" , fallback = FeignApiFallBack.class)
public interface FeignApi {
/*
* @ClassName FeignApi
* @Desc TODO 通过 hystrix-b 服务名调用 b() 方法
* @Date 2019/5/20 23:21
* @Version 1.0
*/
@RequestMapping("/b")
String b();
}
通过 @FeignClient 注解中 value = "hystrix-b" 来指定调用哪个服务
hystrix-b 就是提供者的 spring.application.name:应用名称
通过 @FeignClient 注解中 fallback = FeignApiFallBack.class 来指定熔断时调用的方法
FeignApiFallBack 就是此类(FeignApi)的实现类,对应的实现方法就是此类的熔断时调用的方法
b():此方法是 B 工程中提供的服务,在这里定义成接口
注意要与提供者具有相同返回值,相同方法名以及相同参数
服务工程 A - Fallback(FeignApiFallBack)
package com.zwc.a.api.impl;
import com.zwc.a.api.feign.FeignApi;
import org.springframework.stereotype.Component;
/*
* @ClassName FeignApi
* @Desc TODO fallback
* @Date 2019/5/20 23:21
* @Version 1.0
*/
@Component
public class FeignApiFallBack implements FeignApi {
/*
* @ClassName FeignApiFallBack
* @Desc TODO 调用 hystrix-b 服务中的 b() 方法失败时执行
* @Date 2019/5/20 23:31
* @Version 1.0
*/
@Override
public String b() {
return "Hello!aUseB fail";
}
}
使用 @Component 注解把此类交给 Spring 管理
实现了 FeignApi 接口,提供熔断时对应的方法
服务工程 A - controller 前端控制器(消费服务)
package com.zwc.a.controller;
import com.zwc.a.api.feign.FeignApi;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/*
* @ClassName AUseBFeignController
* @Desc TODO 使用 Feign 调用 b - 前端控制器
* @Date 2019/5/20 23:23
* @Version 1.0
*/
@RestController
public class AUseBFeignController {
@Autowired(required = false)
private FeignApi feignApi;
/*
* @ClassName FeignController
* @Desc TODO 通过 hystrix-b 服务名调用 b() 方法
* @Date 2019/5/20 23:13
* @Version 1.0
*/
@RequestMapping("/aUseB")
public String aUseB(){
return feignApi.b();
}
}
使用 @Autowired 注解装配 Bean,通过此 Bean 中的方法调用服务
此类对外暴露接口,调用的实则是提供者的服务
服务工程 A - 启动类
package com.zwc;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class SpringcloudHystrixAServiceCoreApplication {
public static void main(String[] args) {
SpringApplication.run(SpringcloudHystrixAServiceCoreApplication.class, args);
}
}
添加 @EnableEurekaClient 注解表示此工程可以向注册中心提供服务
添加 @EnableFeignClients 注解表示开启 Feign 功能进行远程调用
服务工程 A - 启动项目
1. 项目启动成功后访问:http://localhost:8090/a (调用自己的服务)
2. 输出内容:'Hello!I'm a. port:8090'
3. 刷新 http://localhost:8761/(注册中心)可以看到服务已经被注册进来了
4. 访问地址:http://localhost:8090/aUseB (调用 B 工程的服务)
5. 输出内容:'Hello!aUseB fail' (此时因为 B 工程还未启动,所以调用了 fallback 中的方法)
6. 启动服务工程 B,项目启动成功后再次访问:http://localhost:8090/aUseB (调用 B 工程的服务)
7. 输出内容:'Hello!I'm b. port:8091' (如果还未调用成功,等待一会再刷新试试)
8. 此时就证明熔断成功
9. 访问地址:http://localhost:8091/b (调用自己的服务)
10. 输出内容:'Hello!I'm b. port:8091'
11. 再次刷新 http://localhost:8761/(注册中心),发现 B 工程服务也注册进来了
service 工程 - 项目结构
把多工程项目使用 IntelliJ IDEA 打开
把项目从 GitHub 中下载到你的本地
打开 IntelliJ IDEA
点击 File -> Open
打开你下载到本地的项目目录
springcloud-hystrix -> springcloud-hystrix-service(选择打开此工程)
打开 service 工程后
再次点击 File -> Project Structrue
选择 Modules,点击 '+' 符号
点击 Import Module
还是打开你下载到本地的项目目录
springcloud-hystrix -> springcloud-hystrix-commons -> pom.xml
点击 OK
点击 Next,Finish
点击 Apply,OK
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
熔断器 java_SpringCloud之熔断器Hystrix的实现相关推荐
- 熔断器 java_SpringCloud之熔断器使用(Hystrix)
前言 熔断器(Hystrix)的作用就是为了保护被调用方.自身不会因为某一个服务请求超时或者某个服务不可用而导致整个请求链路挂掉,防止雪崩效应导致这个系统不可用.同时在熔断器的实现中可以很好的实现服务 ...
- 微服务(四) 【手摸手带你搭建Spring Cloud】 Hystrix 熔断器 什么是熔断器? 什么是Hystrix?为什么要熔断器 Hystrix用来做什么? 作用是什么?
上一章我们讲了负载均衡 文章目录 前言 一.Hystrix是什么? 二.Hystrix的作用是什么?Hystrix具体要保护什么? 2.1什么是微服务-雪崩效应 2.1服务熔断原理 三.实践 前言 一 ...
- java 熔断器模式_Spring Cloud Hystrix——熔断器
1.雪崩效应 在微服务架构中通常会有多个服务层调用,基础服务的故障可能会导致级联故障,进而造成整个系统不可用的情况,这种现象被称为服务雪崩效应.服务雪崩效应是一种因"服务提供者"的 ...
- 防雪崩利器:熔断器 Hystrix 的原理与使用
1.概述 分布式系统中经常会出现某个基础服务不可用造成整个系统不可用的情况, 这种现象被称为服务雪崩效应. 为了应对服务雪崩, 一种常见的做法是手动服务降级. 而Hystrix的出现,给我们提供了另一 ...
- 防雪崩利器:熔断器 Hystrix 的原理与使用--转
原文地址:https://segmentfault.com/a/1190000005988895 前言 分布式系统中经常会出现某个基础服务不可用造成整个系统不可用的情况, 这种现象被称为服务雪崩效应. ...
- 熔断器 Hystrix 的原理与使用
前言 分布式系统中经常会出现某个基础服务不可用造成整个系统不可用的情况, 这种现象被称为服务雪崩效应. 为了应对服务雪崩, 一种常见的做法是手动服务降级. 而Hystrix的出现,给我们提供了另一种选 ...
- 《深入理解 Spring Cloud 与微服务构建》第九章 熔断器 Hystrix
<深入理解 Spring Cloud 与微服务构建>第九章 熔断器 Hystrix 文章目录 <深入理解 Spring Cloud 与微服务构建>第九章 熔断器 Hystrix ...
- 关于熔断器Hystrix替代方案的调研报告
关于熔断器Hystrix替代方案的调研报告 一.背景 Netflix宣布停止Hystrix熔断器的开发,目前进入了维护模式.同时,也指出了Hystrix 1.5.18版本足够满足现阶段的应用(详细请参 ...
- 【SpringCloud技术专题】「Hystrix」(9)熔断器的原理和实现机制
熔断器(Circuit Breaker)介绍 熔断器,现实生活中有一个很好的类比,就是家庭电路中都会安装一个保险盒,当电流过大的时候保险盒里面的保险丝会自动断掉,来保护家里的各种电器及电路. Hyst ...
- Hystrix熔断器的理解
Hystrix熔断器的理解 什么是熔断器 为什么要使用熔断器 熔断器工作原理![在这里插入图片描述](https://img-blog.csdnimg.cn/20200823210834884.png ...
最新文章
- Struts中用bean:size和bean:write的使用,用于显示集合的总记录数
- u盘插在linux电脑上没有反应,U盘插在自己电脑上没有反应,别人电脑有反应的解决方法...
- 如何理解产品经理的核心竞争力
- JVM学习-类文件结构
- 有多少人乘坐公交车时用NFC付钱?
- JVM-绘图展现字节码执行引擎执行过程
- 网络基础知识(黑马教程笔记)-5-路由
- Java【递归及过滤器】
- Bluedroid 函数分析:BTA_GATTC_Open
- MP4、 MPEG-4区别
- 一个屌丝程序猿的人生(五)
- 幻14 2021 R9 5900HS RTX3060 AX210装ubuntu18.04.5笔记
- c语言中用户验证程序,C语言用户登录系统账户密码比对
- yacs、yaml进行实验参数配置详解
- 问道神兵天降服务器维护,《问道》手游安卓/IOS服务器10月27日5:30维护公告
- Django + Pytest搭建在线自动化测试平台
- 深入Vue2.x的虚拟DOM diff原理
- 2022.5.16-5.22 AI行业周刊(第98期):人生路上的打怪升级
- 【C语言】C语言外部变量和内部变量
- matlab三维集装3D container箱装箱优化【matlab优化算法七】
热门文章
- 用计算机弹起风了乐谱,光遇起风了乐谱简谱弹奏攻略 光遇怎么弹奏起风了
- Mushroom Classification(蘑菇分类数据集)
- 2019强网杯upload
- 记录每天背的单词,准备考研。(2月21日)
- 系统集成项目管理师和高级项目管理师考试心得
- 快速复制浏览器F12中的请求到Postman/或者生成相关语言的对应代码
- Android最新技术-Android11周
- 笔记本电脑上html怎样运行,手提电脑如何进入BIOS|笔记本电脑进入BIOS按哪个键...
- 收藏!!!不同品牌笔记本/台式机进入BIOS按键
- xp系统计算机蓝屏,XP电脑蓝屏错误代码0*0000007E该怎么解决?