SpringCloud系列（31）--使用Hystrix进行服务降级

news2024/11/15 10:45:46

前言：在上一章节中我们创建了服务消费者模块，而本节内容则是使用Hystrix对服务进行服务降级处理。

1、首先我们先对服务提供者的服务进行服务降级处理
(1)修改cloud-provider-hystrix-payment8001子模块的PaymentServiceImpl类

注：@HystrixProperty注解的更多key/value参数设置可以查看HystrixCommandProperties 类

package com.ken.springcloud.service.impl;

import com.ken.springcloud.service.PaymentService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Service
public class PaymentServiceImpl implements PaymentService {

    @Override
    public String paymentInfoOK(Integer id) {
        return "线程池：" + Thread.currentThread().getName() + "paymentInfoOK,id: " + id;
    }

    @Override
    //一旦调用服务方法失败并抛出了错误信息后，会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法，这里设置服务降级的条件为连接超时超过3秒，即3秒内走paymentInfoTimeOut方法内的业务逻辑，超过3秒走paymentInfoTimeOutHandler方法
    @HystrixCommand(fallbackMethod = "paymentInfoTimeOutHandler",commandProperties = {@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "3000")})
    public String paymentInfoTimeOut(Integer id) {
        int timeNumber = 5;
        try {
            TimeUnit.SECONDS.sleep(timeNumber);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "线程池：" + Thread.currentThread().getName() + "paymentInfoTimeOut,id: " + id + "耗时" + timeNumber + "秒";
    }

    public String paymentInfoTimeOutHandler(Integer id) {
        return "系统繁忙，请稍后再试";
    }

}
(2)修改cloud-provider-hystrix-payment8001子模块的PaymentHystrixMain8001启动类
package com.ken.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
//使用Feign，激活并开启
@EnableEurekaClient
//开启断路器功能
@EnableCircuitBreaker
public class PaymentHystrixMain8001 {

    public static void main(String[] args) {
        SpringApplication.run(PaymentHystrixMain8001.class, args);
    }

}
(3) 分别启动eureka-server7001、cloud-provider-hystrix-payment8001服务

效果图：

(4) 在浏览器的地址栏里分别输入http://localhost:8001/payment/hystrix/timeout/1通过调用这个接口查看服务提供者的服务降级功能是否正常运行

效果图：
​

由图可知服务提供者的服务降级成功，客户端连接cloud-provider-hystrix-payment8001服务超时后最后执行了paymentInfoTimeOutHandler方法，由paymentInfoTimeOutHandler方法进行兜底处理，而且值得注意的是正常调用服务使用到的线程池和服务降级时使用到的线程池不是同一个，这意味着hystrix用单独的一个线程池作服务降级处理，起到了隔离的效果

正常的：

​

降级处理的：

2、在上述的操作中我们对服务提供者的服务成功地进行了服务降级处理，接下来我们对服务消费者的服务同样进行服务降级处理
(1)修改cloud-consumer-feign-hystrix-order80子模块的application.yml文件，加上feign:hystrix:enabled:true的配置，使feign调用启用hystrix

关于feign:hystrix:enabled:true配置的相关官方文档，官方文档介绍如果配置feign.hystrix.Enabled=true，则Feign将使用断路器包装所有方法https://cloud.spring.io/spring-cloud-openfeign/reference/html/#spring-cloud-feign-hystrix-fallback

server:
  port: 8080
eureka:
  client:
    #表示是否将自己注册进Eureka Server里，默认为true
    register-with-eureka: false
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/

feign:
  client:
    config:
      default:
        #指的是建立连接所用的时间，适用于网络状况正常的情况下，两端连接所用的时间
        connect-timeout: 5000
        #指的是建立连接后从服务器读取到可用资源所用的时间
        read-timeout: 5000
  #feign调用启用hystrix，启用后feign调用可以使用hystrix的服务降级、服务熔断、服务隔离等，从上述的设置可知feign请求超过5s就会进行服务降级、服务熔断、服务隔离等相关操作
  hystrix:
    enabled: true

#设置命令执行的超时时间，默认1000ms，因为开启了feign:hystrix:enabled:true，这里要设置为5000ms，否则设置ribbon的超时时间也没用，ribbon的超时时间会被强制改为了1000ms
hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 5000
(2)修改cloud-consumer-feign-hystrix-order80子模块的OrderHystrixMain80启动类，开启断路器功能
package com.ken.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
//使用Feign，激活并开启
@EnableFeignClients
//开启断路器功能
@EnableCircuitBreaker
public class OrderHystrixMain80 {

    public static void main(String[] args) {
        SpringApplication.run(OrderHystrixMain80.class, args);
    }

}
(3)修改cloud-provider-hystrix-payment8001子模块的PaymentServiceImpl类，把睡眠时间调为2秒，模拟服务提供者正常运行
package com.ken.springcloud.service.impl;

import com.ken.springcloud.service.PaymentService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Service
public class PaymentServiceImpl implements PaymentService {

    @Override
    public String paymentInfoOK(Integer id) {
        return "线程池：" + Thread.currentThread().getName() + "paymentInfoOK,id: " + id;
    }

    @Override
    //一旦调用服务方法失败并抛出了错误信息后，会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法，这里设置服务降级的条件为连接超时超过3秒，即3秒内走paymentInfoTimeOut方法内的业务逻辑，超过3秒走paymentInfoTimeOutHandler方法
    @HystrixCommand(fallbackMethod = "paymentInfoTimeOutHandler",commandProperties = {@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "3000")})
    public String paymentInfoTimeOut(Integer id) {
        int timeNumber = 2;
        try {
            TimeUnit.SECONDS.sleep(timeNumber);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "线程池：" + Thread.currentThread().getName() + "paymentInfoTimeOut,id: " + id + "耗时" + timeNumber + "秒";
    }

    public String paymentInfoTimeOutHandler(Integer id) {
        return "线程池：" + Thread.currentThread().getName() + "系统繁忙，请稍后再试";
    }

}
(4)修改cloud-consumer-feign-hystrix-order80子模块的OrderHystrixController类，设置超时时间为1.5秒，这里是模拟服务消费者端的响应时间短但是服务提供者端返回资源的时间长，从而观察服务消费者端在超时后会作出什么反应
package com.ken.springcloud.controller;

import com.ken.springcloud.service.PaymentHystrixService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController
public class OrdertHystrixController {

    @Resource
    private PaymentHystrixService paymentHystrixService;

    @GetMapping("/consumer/payment/hystrix/ok/{id}")
    public String paymentInfoOK(@PathVariable("id") Integer id) {
        String result = paymentHystrixService.paymentInfoOK(id);
        return result;
    }

    @GetMapping("/consumer/payment/hystrix/timeout/{id}")
    //一旦调用服务方法失败并抛出了错误信息后，会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法，这里设置服务降级的条件为连接超时超过3秒，即3秒内走paymentInfoTimeOut方法内的业务逻辑，超过3秒走paymentInfoTimeOutHandler方法
    @HystrixCommand(fallbackMethod = "paymentInfoTimeOutHandler",commandProperties = {@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "1500")})
    public String paymentInfoTimeOut(@PathVariable("id") Integer id) {
        String result = paymentHystrixService.paymentInfoTimeOut(id);
        return result;
    }

    public String paymentInfoTimeOutHandler(Integer id) {
        return "服务提供者繁忙，请稍后再试";
    }

}
(5) 分别启动eureka-server7001、cloud-provider-hystrix-payment8001服务、cloud-consumer-feign-hystrix-order80服务

效果图：

(6) 在浏览器的地址栏里分别输入http://localhost:8080/consumer/payment/hystrix/timeout/1通过调用这个接口查看服务消费者的服务降级功能是否正常运行

由图可知服务消费者的服务降级成功，服务消费者连接服务提供者的服务超过1.5秒后超时，最后执行了paymentInfoTimeOutHandler方法，由paymentInfoTimeOutHandler方法进行兜底处理

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1715004.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Hadoop3：MapReduce之简介、WordCount案例源码阅读、简单功能开发

Hadoop3：MapReduce之简介、WordCount案例源码阅读、简单功能开发

一、概念 MapReduce是一个 分布式运算程序 的编程框架，是用户开发“基于 Hadoop的数据分析 应用”的核心框架。 MapReduce核心功能是将 用户编写的业务逻辑代码 和 自带默认组件 整合成一个完整的 分布式运算程序 ，并发运行在一个 Hadoop集群上。 1、M…
阅读更多...
软件架构设计属性之一：功能性属性浅析

软件架构设计属性之一：功能性属性浅析

引言 软件架构设计属性中的功能性属性是评估软件架构是否满足其预定功能需求的关键指标。功能性属性确保软件能够执行其设计中的任务，并提供所需的服务。以下是对软件架构设计中功能性属性的浅析： 一、定义 功能性属性是指软件系统所具备的功能特性&a…
阅读更多...
怎么将3D模型转换立面图---模大狮模型网

怎么将3D模型转换立面图---模大狮模型网

在建筑设计、室内设计以及产品建模等领域，经常需要将3D模型转换为立面图以进行展示、分析或交流。立面图能够清晰地呈现物体的外观和结构，是设计和施工中不可或缺的一部分。 一、导出3D模型 首先，需要将3D模型导出为CAD软件能够识别的格式。…
阅读更多...
如何配置才能连接远程服务器上的 redis server ？

如何配置才能连接远程服务器上的 redis server ？

文章目录 Intro修改点 Intro 以阿里云服为例。 首先，我在我买的阿里云服务器中以下载源码、手动编译的方式安装了 redis-server，操作流程见：Ubuntu redis 下载解压配置使用及密码管理 && 包管理工具联网安装。 接着，我…
阅读更多...
（函数）颠倒字符串顺序（C语言）

（函数）颠倒字符串顺序（C语言）

一、运行结果&#xff1b; 二、源代码&#xff1b; # define _CRT_SECURE_NO_WARNINGS # include <stdio.h> # include <string.h>//声明颠倒函数; void reverse(char a[]) {//初始化变量值&#xff1b;int i, j;char t;//循环颠倒&#xff1b;for (i 0, j strl…
阅读更多...
Iphone自动化指令每隔固定天数打开闹钟关闭闹钟(二)

Iphone自动化指令每隔固定天数打开闹钟关闭闹钟(二)

1.首先在搜索和操作里搜索“查找日期日程" 1.1.然后过滤条件开始日期选择”是今天“ 1.2.增加过滤条件&#xff0c;日历是这里选择”工作“ 1.3.增加过滤条件&#xff0c;选择标题&#xff0c;是这里选择”workDay“ 1.4选中限制&#xff0c;日历日程只要一个&#xff0c;…
阅读更多...
Vue3实战笔记（51）—Vue 3封装带均线的k线图

Vue3实战笔记（51）—Vue 3封装带均线的k线图

文章目录 前言带均线的k线图总结 前言 继续封装一个封装带均线的k线图 带均线的k线图 EChartsCandlestickSh.vue&#xff1a; <template><div ref"chartContainer" style"width: 100%; height: 500px"></div></template><scr…
阅读更多...
专业的力量-在成为专家的道路上前进

专业的力量-在成为专家的道路上前进

专业的力量-在成为专家的道路上前进 我是穿拖鞋的汉子&#xff0c;魔都中坚持长期主义的汽车电子工程师。 老规矩&#xff0c;分享一段喜欢的文字&#xff0c;避免自己成为高知识低文化的工程师&#xff1a; 现在稀缺的已不再是信息资源&#xff0c;而是运用信息的能力。过去…
阅读更多...
C#多线程同步lock、Mutex

C#多线程同步lock、Mutex

C#使用多线程可以通过System.Threading命名空间下的Thread类来实现 lock和Mutex用于实现线程同步的机制&#xff1a; 上代码&#xff1a; class People{public People(int idd){id idd;}public int id;public int age;}class TestHelper{public TestHelper() { }List<Peo…
阅读更多...
AVB协议分析(一) FQTSS协议介绍

AVB协议分析(一) FQTSS协议介绍

FQTSS协议介绍 一、AVB整体架构二、概述三、协议作用及作用对象四、协议的实现五、参考文献&#xff1a; 一、AVB整体架构 可见FQTSS位于MAC层的上面&#xff0c;代码看不懂&#xff0c;咱们就从最底层开始&#xff0c;逐层分析协议&#xff0c;逐个击破&#xff0c;慢就是快。…
阅读更多...
11.RedHat认证-Linux文件系统(中)

11.RedHat认证-Linux文件系统(中)

11.RedHat认证-Linux文件系统(中) Linux的文件系统 格式化分区(1道题) #对于Linux分区来说&#xff0c;只有格式化之后才能使用&#xff0c;不格式化是无法使用的。 #Linux分区格式化之后就会变成文件系统&#xff0c;格式化的过程相当于对分区做了一个文件系统。 #Linux常见…
阅读更多...
【简单介绍下idm有那些优势】

【简单介绍下idm有那些优势】

&#x1f3a5;博主&#xff1a;程序员不想YY啊 &#x1f4ab;CSDN优质创作者&#xff0c;CSDN实力新星&#xff0c;CSDN博客专家 &#x1f917;点赞&#x1f388;收藏⭐再看&#x1f4ab;养成习惯 ✨希望本文对您有所裨益&#xff0c;如有不足之处&#xff0c;欢迎在评论区提出…
阅读更多...
SQL刷题笔记day6-1

SQL刷题笔记day6-1

1从不订购的客户 分析&#xff1a;从不订购&#xff0c;就是购买订单没有记录&#xff0c;not in 我的代码&#xff1a; select c.name as Customers from Customers c where c.id not in (select o.customerId from Orders o) 2 部门工资最高的员工 分析&#xff1a;每个部…
阅读更多...
三十三、openlayers官网示例Drawing Features Style——在地图上绘制图形，并修改绘制过程中的颜色

三十三、openlayers官网示例Drawing Features Style——在地图上绘制图形，并修改绘制过程中的颜色

这篇讲的是使用Draw绘制图形时根据绘制形状设置不同颜色。 根据下拉框中的值在styles对象中取对应的颜色对象&#xff0c;new Draw的时候将其设置为style参数。 const styles {Point: {"circle-radius": 5,"circle-fill-color": "red",},LineS…
阅读更多...
代码随想录算法训练营Day22|235.二叉搜索树的最近公共祖先、701.二叉搜索树中的插入操作、450.删除二叉搜索树中的节点

代码随想录算法训练营Day22|235.二叉搜索树的最近公共祖先、701.二叉搜索树中的插入操作、450.删除二叉搜索树中的节点

二叉搜索树的最近公共祖先 不考虑二叉搜索树这一条件的话&#xff0c;普通的二叉搜索树搜索最近的公共祖先就是昨日的做法&#xff0c;这种做法也能解决二叉搜索树的最近公共祖先。 class Solution { public:TreeNode* lowestCommonAncestor(TreeNode* root, TreeNode* p, Tr…
阅读更多...
基于Visual Studio版本的AI编程助手

基于Visual Studio版本的AI编程助手

Visual Studio 是一个出色的 IDE,可用于构建适用于 Windows、Mac、Linux、iOS 和 Android 的丰富、精美的跨平台应用程序。 使用一系列技术(例如 WinForms、WPF、WinUI、MAUI 或 Xamarin)构建丰富。 1、安装 点击上方工具栏拓展选项，选择管理拓展选项 接着在联机页面中搜索&q…
阅读更多...
基于transformers框架实践Bert系列6-完形填空

基于transformers框架实践Bert系列6-完形填空

本系列用于Bert模型实践实际场景&#xff0c;分别包括分类器、命名实体识别、选择题、文本摘要等等。&#xff08;关于Bert的结构和详细这里就不做讲解&#xff0c;但了解Bert的基本结构是做实践的基础&#xff0c;因此看本系列之前&#xff0c;最好了解一下transformers和Bert…
阅读更多...
网络故障与排除

网络故障与排除

一、Router-ID冲突导致OSPF路由环路 路由器收到相同Router-ID的两台设备发送的LSA&#xff0c;所以查看路由表看到的OSPF缺省路由信息就会不断变动。而当C1的缺省路由从C2中学到&#xff0c;C2的缺省路由又从C1中学到时&#xff0c;就形成了路由环路&#xff0c;因此出现路由不…
阅读更多...
如何找出真正的交易信号？Anzo Capital昂首资本总结7个

如何找出真正的交易信号？Anzo Capital昂首资本总结7个

匕首是一种新兴的价格走势形态&#xff0c;虽然不常见&#xff0c;但具有较高的统计可靠性。它通常预示着趋势的持续发展。该模式涉及到同时参考两个不同的时间周期进行交易&#xff0c;一个是短期&#xff0c;另一个是长期&#xff0c;比如一周时间框架与一天时间框架、一天时…
阅读更多...
【微机原理及接口技术】可编程计数器/定时器8253

【微机原理及接口技术】可编程计数器/定时器8253

【微机原理及接口技术】可编程计数器/定时器8253 文章目录 【微机原理及接口技术】可编程计数器/定时器8253前言一、8253的内部结构和引脚二、8253的工作方式三、8253的编程总结 前言 本篇文章就8253芯片展开&#xff0c;详细介绍8253的内部结构和引脚&#xff0c;8253的工作方…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023