博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)
阅读量:6938 次
发布时间:2019-06-27

本文共 2448 字,大约阅读时间需要 8 分钟。

hot3.png

动手试一试

在开始使用Spring Cloud Hystrix实现断路器之前,我们先拿之前实现的一些内容作为基础,其中包括:

  • eureka-server工程:服务注册中心,端口:1001
  • eureka-client工程:服务提供者,两个实例启动端口分别为2001

下面我们可以复制一下之前实现的一个服务消费者:eureka-consumer-ribbon,命名为eureka-consumer-ribbon-hystrix。下面我们开始对其进行改在:

第一步:pom.xml的dependencies节点中引入spring-cloud-starter-hystrix依赖:

org.springframework.cloud
spring-cloud-starter-hystrix

第二步:在应用主类中使用@EnableCircuitBreaker@EnableHystrix注解开启Hystrix的使用:

@EnableCircuitBreaker@EnableDiscoveryClient@SpringBootApplicationpublic class Application {	@Bean	@LoadBalanced	public RestTemplate restTemplate() {		return new RestTemplate();	}	public static void main(String[] args) {		new SpringApplicationBuilder(Application.class).web(true).run(args);	}}

注意:这里我们还可以使用Spring Cloud应用中的@SpringCloudApplication注解来修饰应用主类,该注解的具体定义如下所示。我们可以看到该注解中包含了上我们所引用的三个注解,这也意味着一个Spring Cloud标准应用应包含服务发现以及断路器。

@Target({ElementType.TYPE})@Retention(RetentionPolicy.RUNTIME)@Documented@Inherited@SpringBootApplication@EnableDiscoveryClient@EnableCircuitBreakerpublic @interface SpringCloudApplication {}

第三步:改造服务消费方式,新增ConsumerService类,然后将在Controller中的逻辑迁移过去。最后,在为具体执行逻辑的函数上增加@HystrixCommand注解来指定服务降级方法,比如:

@RestControllerpublic class DcController {    @Autowired    ConsumerService consumerService;    @GetMapping("/consumer")    public String dc() {        return consumerService.consumer();    }    class ConsumerService {        @Autowired        RestTemplate restTemplate;        @HystrixCommand(fallbackMethod = "fallback")        public String consumer() {            return restTemplate.getForObject("http://eureka-client/dc", String.class);        }        public String fallback() {            return "fallback";        }    }}

下面我们来验证一下上面Hystrix带来的一些基础功能。我们先把涉及的服务都启动起来,然后访问localhost:2101/consumer,此时可以获取正常的返回,比如:Services: [eureka-consumer-ribbon-hystrix, eureka-client]

为了触发服务降级逻辑,我们可以将服务提供者eureka-client的逻辑加一些延迟,比如:

@GetMapping("/dc")public String dc() throws InterruptedException {    Thread.sleep(5000L);    String services = "Services: " + discoveryClient.getServices();    System.out.println(services);    return services;}

重启eureka-client之后,再尝试访问localhost:2101/consumer,此时我们将获得的返回结果为:fallback。我们从eureka-client的控制台中,可以看到服务提供方输出了原本要返回的结果,但是由于返回前延迟了5秒,而服务消费方触发了服务请求超时异常,服务消费者就通过HystrixCommand注解中指定的降级逻辑进行执行,因此该请求的结果返回了fallback。这样的机制,对自身服务起到了基础的保护,同时还为异常情况提供了自动的服务降级切换机制。

Spring Cloud大型企业分布式微服务云架构源码请加企鹅求求:一七九一七四三三八零

转载于:https://my.oschina.net/u/3826344/blog/3016999

你可能感兴趣的文章
MongoDB 更新文档
查看>>
JavaScript创建对象(六)——寄生构造函数模式
查看>>
用C#创建Windows服务(Windows Services)
查看>>
C++ 指针的算术运算
查看>>
golang客户端sarama通过SSL连接Kafka配置
查看>>
SpringBoot之Admin监控系统
查看>>
javaweb Servlet开发
查看>>
电信网络拓扑图自动布局之曲线布局
查看>>
Netty源码分析 服务器端1
查看>>
Activity之生命周期
查看>>
HIVE 常见报错之 设置mysql数据库权限
查看>>
python 字典内建方法
查看>>
Python统计数据的频率
查看>>
如何启动/停止/重启MySQL
查看>>
使用chrome浏览器查看当前网页的http头信息
查看>>
MYSQL对外键的约束要求
查看>>
Linux虚拟机压缩
查看>>
git push 报non-fast-forward updates were rejected 错误
查看>>
Golang安装配置
查看>>
详细地演示gb18030到unicode|utf8的转码过程(RUST语言)
查看>>