SpringCloud 2020.0.4 系列之服务降级

2024-05-31 23:58

本文主要是介绍SpringCloud 2020.0.4 系列之服务降级,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

1. 概述

2. 接口报错的服务降级

3. 接口超时的服务降级

4. 综述

5. 个人公众号


1. 概述

老话说的好:做人要正直,做事要正派,胸怀坦荡、光明磊落,才会赢得他人的信赖与尊敬。

言归正传,之前聊了服务间通信的组件 Feign,今天我们来聊聊服务降级。

服务降级简单的理解就是给一个备选方案,当服务调用报错或者超时时,能终止远程调用,并很快的返回备选的结果,避免引发服务雪崩。

今天我们用两个例子,模拟一下 接口报错 和 接口超时 的服务降级实现。

我们使用 hystrix 实现服务降级,虽然从 Spring Cloud 2020.0 版本开始,移除了 hystrix 组件,但并不影响我们对他的使用。

闲话不多说,直接上代码。

2. 接口报错的服务降级

2.1 被调用服务

2.1.1 接口代码

    @GetMapping("/exception")String exception() throws Exception;

2.1.2 实现类代码

    @Overridepublic String exception() throws Exception {if(1==1) {throw new Exception("模拟异常");}return null;}

2.2 调用服务

2.2.1 主要依赖

        <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- 健康检查 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId><version>2.2.9.RELEASE</version></dependency>

这里 hystrix 使用目前的最新版本 2.2.9.RELEASE。

2.2.2 主要配置

feign:circuitbreaker:enabled: true   # 开启 feign 的断路器hystrix:command:default:fallback:enabled: true     # 开启服务降级

2.2.3 降级工厂类的开发

@Component
public class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {@Overridepublic EurekaClientService create(Throwable cause) {return new EurekaClientService() {@Overridepublic String exception() throws Exception {System.out.println("exception方法 降级");return "exception方法 降级";}};}
}

2.2.4 在 Feign 接口配置降级工厂类

@FeignClient(name = "my-eureka-client", fallbackFactory = MyEurekaClientServiceFactory.class)  // name为 调用服务的名称
@RequestMapping("/api")
public interface EurekaClientService {@GetMapping("/exception")String exception() throws Exception;}

2.2.5 启动类增加 @EnableHystrix 注解

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
@EnableHystrix
public class MyFeignApplication {public static void main(String[] args) {SpringApplication.run(MyFeignApplication.class, args);}
}

2.2.6 启动服务测试

可以正常进入降级方法。

3. 接口超时的服务降级

3.1 被调用服务

3.1.1 接口代码

    @GetMapping("/timeout")String timeout(@RequestParam Integer timeoutSecond);

3.1.2 实现类代码

    @Overridepublic String timeout(Integer timeoutSecond) {System.out.println("调用timeout方法");try {Thread.sleep(timeoutSecond * 1000L);} catch (InterruptedException e) {e.printStackTrace();}return "success:" + port;}

3.2 调用服务

3.2.1 主要配置

feign:client:config:# 全局配置default:connectTimeout: 1000   # 连接超时时间,单位msreadTimeout: 3000         # 获取Response响应超时时间,单位ms# 针对 my-eureka-client 的 feign 配置,优先级高于全局配置my-eureka-client:connectTimeout: 300   # 连接超时时间,单位msreadTimeout: 5000         # 获取Response响应超时时间,单位mscircuitbreaker:enabled: true   # 开启 feign 的断路器hystrix:command:default:fallback:enabled: true     # 开启服务降级execution:timeout:enabled: true   # 全局超时配置isolation:thread:timeoutInMilliseconds: 3000    # 超时时间配置interruptOnTimeout: true       # 超时后是否终止线程interruptOnFutureCancel: true  # 取消后是否终止线程

注意:feign 的 readTimeout 属性和 hystrix 的 timeoutInMilliseconds 属性会同时生效,以超时时间最短的为准。

3.2.2 降级工厂类的开发

@Component
public class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {@Overridepublic EurekaClientService create(Throwable cause) {return new EurekaClientService() {@Overridepublic String exception() throws Exception {System.out.println("exception方法 降级");return "exception方法 降级";}@Overridepublic String timeout(Integer timeoutSecond) {return "timeout方法 降级";}};}
}

3.2.3 启动服务测试

可以正常进入降级方法。

4. 综述

今天聊了一下 服务降级 的相关知识,希望可以对大家的工作有所帮助。

欢迎帮忙点赞、评论、转发、加关注 :)

关注追风人聊Java,每天更新Java干货。

5. 个人公众号

追风人聊Java,欢迎大家关注

这篇关于SpringCloud 2020.0.4 系列之服务降级的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

SpringBoot整合Flowable实现工作流的详细流程

《SpringBoot整合Flowable实现工作流的详细流程》Flowable是一个使用Java编写的轻量级业务流程引擎,Flowable流程引擎可用于部署BPMN2.0流程定义,创建这些流程定义的... 目录1、流程引擎介绍2、创建项目3、画流程图4、开发接口4.1 Java 类梳理4.2 查看流程图4

一文详解如何在idea中快速搭建一个Spring Boot项目

《一文详解如何在idea中快速搭建一个SpringBoot项目》IntelliJIDEA作为Java开发者的‌首选IDE‌,深度集成SpringBoot支持,可一键生成项目骨架、智能配置依赖,这篇文... 目录前言1、创建项目名称2、勾选需要的依赖3、在setting中检查maven4、编写数据源5、开启热

Java对异常的认识与异常的处理小结

《Java对异常的认识与异常的处理小结》Java程序在运行时可能出现的错误或非正常情况称为异常,下面给大家介绍Java对异常的认识与异常的处理,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参... 目录一、认识异常与异常类型。二、异常的处理三、总结 一、认识异常与异常类型。(1)简单定义-什么是

SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志

《SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志》在SpringBoot项目中,使用logback-spring.xml配置屏蔽特定路径的日志有两种常用方式,文中的... 目录方案一:基础配置(直接关闭目标路径日志)方案二:结合 Spring Profile 按环境屏蔽关

Java使用HttpClient实现图片下载与本地保存功能

《Java使用HttpClient实现图片下载与本地保存功能》在当今数字化时代,网络资源的获取与处理已成为软件开发中的常见需求,其中,图片作为网络上最常见的资源之一,其下载与保存功能在许多应用场景中都... 目录引言一、Apache HttpClient简介二、技术栈与环境准备三、实现图片下载与保存功能1.

SpringBoot排查和解决JSON解析错误(400 Bad Request)的方法

《SpringBoot排查和解决JSON解析错误(400BadRequest)的方法》在开发SpringBootRESTfulAPI时,客户端与服务端的数据交互通常使用JSON格式,然而,JSON... 目录问题背景1. 问题描述2. 错误分析解决方案1. 手动重新输入jsON2. 使用工具清理JSON3.

java中long的一些常见用法

《java中long的一些常见用法》在Java中,long是一种基本数据类型,用于表示长整型数值,接下来通过本文给大家介绍java中long的一些常见用法,感兴趣的朋友一起看看吧... 在Java中,long是一种基本数据类型,用于表示长整型数值。它的取值范围比int更大,从-922337203685477

java Long 与long之间的转换流程

《javaLong与long之间的转换流程》Long类提供了一些方法,用于在long和其他数据类型(如String)之间进行转换,本文将详细介绍如何在Java中实现Long和long之间的转换,感... 目录概述流程步骤1:将long转换为Long对象步骤2:将Longhttp://www.cppcns.c

SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程

《SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程》LiteFlow是一款专注于逻辑驱动流程编排的轻量级框架,它以组件化方式快速构建和执行业务流程,有效解耦复杂业务逻辑,下面给大... 目录一、基础概念1.1 组件(Component)1.2 规则(Rule)1.3 上下文(Conte

SpringBoot服务获取Pod当前IP的两种方案

《SpringBoot服务获取Pod当前IP的两种方案》在Kubernetes集群中,SpringBoot服务获取Pod当前IP的方案主要有两种,通过环境变量注入或通过Java代码动态获取网络接口IP... 目录方案一:通过 Kubernetes Downward API 注入环境变量原理步骤方案二:通过