Spring Cloud Feign 整合 Sentinel 实现服务降级与熔断保护

在微服务架构中,服务之间的调用往往依赖 Feign,而服务调用的稳定性又至关重要。本文将介绍如何将 Feign 与 Sentinel 结合使用,实现服务的容错保护(如降级与熔断),提升系统的健壮性与可用性。


一、引入依赖

我们创建一个新的微服务,作为 Feign 调用方。pom.xml 中添加如下依赖:

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId><version>2.2.1.RELEASE</version>
</dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId><version>2.2.1.RELEASE</version>
</dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId><version>2.2.2.RELEASE</version>
</dependency>

二、配置 application.yml

在配置文件中开启 Feign 对 Sentinel 的支持,并配置基本信息:

server:port: 8380feign:sentinel:enabled: true  # 开启 Sentinel 对 Feign 的支持spring:application:name: feigncloud:sentinel:transport:dashboard: localhost:8080  # Sentinel 控制台地址nacos:discovery:server-addr: 127.0.0.1:8848  # Nacos 注册中心地址

三、创建 Feign 接口

我们通过 Feign 调用名为 provider 的服务:

package com.southwind.feign;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;@FeignClient("provider")
public interface ProviderFeign {@GetMapping("/index")String index();
}

四、编写 Controller

通过注入 Feign 接口,实现接口调用:

package com.southwind.controller;import com.southwind.feign.ProviderFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class FeignController {@Autowiredprivate ProviderFeign providerFeign;@GetMapping("/index")public String index(){return providerFeign.index();}
}

五、自定义 Fallback 实现服务降级

当服务不可用或 Sentinel 触发熔断时,我们希望返回友好的降级提示,这就需要自定义 fallback 类:

1. 创建 fallback 实现类

package com.southwind.fallback;import com.southwind.feign.ProviderFeign;
import org.springframework.stereotype.Component;@Component
public class ProviderFeignFallback implements ProviderFeign {@Overridepublic String index() {return "index-fallback";}
}

2. 修改 FeignClient 注解,指定 fallback

package com.southwind.feign;import com.southwind.fallback.ProviderFeignFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;@FeignClient(value = "provider", fallback = ProviderFeignFallback.class)
public interface ProviderFeign {@GetMapping("/index")String index();
}

Spring Cloud Feign 整合 Sentinel 实现服务降级与熔断保护

在微服务架构中,服务之间的调用往往依赖 Feign,而服务调用的稳定性又至关重要。本文将介绍如何将 Feign 与 Sentinel 结合使用,实现服务的容错保护(如降级与熔断),提升系统的健壮性与可用性。


一、引入依赖

我们创建一个新的微服务,作为 Feign 调用方。pom.xml 中添加如下依赖:

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId><version>2.2.1.RELEASE</version>
</dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId><version>2.2.1.RELEASE</version>
</dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId><version>2.2.2.RELEASE</version>
</dependency>

二、配置 application.yml

在配置文件中开启 Feign 对 Sentinel 的支持,并配置基本信息:

server:port: 8380feign:sentinel:enabled: true  # 开启 Sentinel 对 Feign 的支持spring:application:name: feigncloud:sentinel:transport:dashboard: localhost:8080  # Sentinel 控制台地址nacos:discovery:server-addr: 127.0.0.1:8848  # Nacos 注册中心地址

三、创建 Feign 接口

我们通过 Feign 调用名为 provider 的服务:

package com.southwind.feign;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;@FeignClient("provider")
public interface ProviderFeign {@GetMapping("/index")String index();
}

四、编写 Controller

通过注入 Feign 接口,实现接口调用:

package com.southwind.controller;import com.southwind.feign.ProviderFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class FeignController {@Autowiredprivate ProviderFeign providerFeign;@GetMapping("/index")public String index(){return providerFeign.index();}
}

五、自定义 Fallback 实现服务降级

当服务不可用或 Sentinel 触发熔断时,我们希望返回友好的降级提示,这就需要自定义 fallback 类:

1. 创建 fallback 实现类

package com.southwind.fallback;import com.southwind.feign.ProviderFeign;
import org.springframework.stereotype.Component;@Component
public class ProviderFeignFallback implements ProviderFeign {@Overridepublic String index() {return "index-fallback";}
}

2. 修改 FeignClient 注解,指定 fallback

package com.southwind.feign;import com.southwind.fallback.ProviderFeignFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;@FeignClient(value = "provider", fallback = ProviderFeignFallback.class)
public interface ProviderFeign {@GetMapping("/index")String index();
}

3.启动类添加@EnableFeignClients注解

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

六、运行与测试

  1. 启动 Sentinel Dashboard(默认端口为 8080)。
  2. 启动被调用服务 provider
  3. 启动当前项目 feign
  4. 浏览器访问:http://localhost:8380/index
  5. 停止 provider 服务,再次访问,即返回 fallback 内容:index-fallback

七、总结

模块说明
Feign简化 HTTP 请求调用
Sentinel实现限流、熔断与降级保护
fallback实现服务不可用时的降级逻辑
配置关键点开启 feign.sentinel.enabled=true 并配置 fallback

通过本文的实践,我们实现了 Feign + Sentinel 的无缝集成,使服务调用具备更强的容错能力。建议大家在生产环境中为每个 Feign 接口都配置 fallback,防止服务雪崩。


如有帮助,欢迎点赞、评论、收藏!
后续将分享更多微服务高可用相关内容,敬请关注。

六、运行与测试

  1. 启动 Sentinel Dashboard(默认端口为 8080)。
  2. 启动被调用服务 provider
  3. 启动当前项目 feign
  4. 浏览器访问:http://localhost:8380/index
  5. 停止 provider 服务,再次访问,即返回 fallback 内容:index-fallback

七、总结

模块说明
Feign简化 HTTP 请求调用
Sentinel实现限流、熔断与降级保护
fallback实现服务不可用时的降级逻辑
配置关键点开启 feign.sentinel.enabled=true 并配置 fallback

通过本文的实践,我们实现了 Feign + Sentinel 的无缝集成,使服务调用具备更强的容错能力。建议大家在生产环境中为每个 Feign 接口都配置 fallback,防止服务雪崩。


如有帮助,欢迎点赞、评论、收藏!
后续将分享更多微服务高可用相关内容,敬请关注。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/diannao/88805.shtml
繁体地址,请注明出处:http://hk.pswp.cn/diannao/88805.shtml
英文地址,请注明出处:http://en.pswp.cn/diannao/88805.shtml

如若内容造成侵权/违法违规/事实不符,请联系英文站点网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

宠物医院系统的设计与实现(springBoot版)

一、开题报告 一、本选题研究的意义和背景&#xff08;理论与现实意义&#xff09;&#xff1a; 背景&#xff1a;随着人们生活水平的提高&#xff0c;宠物饲养愈发普遍&#xff0c;宠物医院的需求也日益增长。挂号方式主要依赖现场挂号&#xff0c;导致宠物主人需要长时间排队…

SOCKSv5 协议通信的完整阶段与报文格式详解

SOCKSv5 协议的通信通常分为以下几个主要阶段&#xff1a; 方法协商阶段 (Method Negotiation)方法依赖的子协商阶段 (Method-Dependent Sub-negotiation) - 本例为用户名/密码认证请求发送阶段 (Request Sending)请求回复阶段 (Request Reply)数据传输阶段 (Data Transfer) …

​​Git提交代码Commit消息企业级规范

​​Git Commit 类型完整指南​​ 类型用途示例​​feat​​新增功能&#xff08;面向用户的功能性变更&#xff09;git commit -m "feat: 添加用户登录功能"​​fix​​修复 Bug&#xff08;解决代码中的问题&#xff09;git commit -m "fix: 修复首页加载崩溃…

TiDB AUTO_RANDOM 超大主键前端精度丢失排查:JavaScript Number 限制与解决方案

前端长整型主键“失踪”记 ——一次 ArrayIndexOutOfBoundsException 的排查全过程 一、事故现场 最近在维护 SMS-OFFICE 后台系统时&#xff0c;运维同事反馈&#xff1a; 点击「短信详情」或「邮箱账号详情」时&#xff0c;偶尔弹窗空白、日志报错&#xff1a; java.lang.A…

在postgresql使用mybatis动态创建数据库分区表

在postgresql使用mybatis动态创建数据库分区表 1. 整体描述2. 前期准备2.1 创建主表语句2.2 创建分表语句2.3 xxl-job 3. 代码实现3.1 mapper.xml层3.2 mapper.java层3.3 service接口层3.4 service实现层3.5 controller层 4. 总结 1. 整体描述 在java下实现&#xff1a;创建分…

Python网安-zip文件暴力破解

目录 源码在这里 需要的模块 准备一个密码本和需要破解的ZIP文件 一行一行地从密码文件中读取每个密码。 核心部分 注意&#xff0c;需要修改上段代码注释里的这段具有编码问题的代码&#xff1a; 源码在这里 https://github.com/Wist-fully/Attack/tree/cracker 需要的…

聊聊Golang开发工程师

诞生背景 Go由Google三位顶尖工程师&#xff08;Ken Thompson、Rob Pike、Robert Griesemer&#xff09;设计&#xff0c;目标是解决两大行业痛点&#xff1a; 硬件利用率不足&#xff1a;多核CPU普及&#xff0c;但C/C等语言难以高效利用并发能力&#xff1b; 开发效率低下&a…

机器学习6——线性分类函数

线性分类函数 分类问题的两种决策方法&#xff1a; 概率方法&#xff1a;通过计算后验概率进行分类。优点是在概率分布已知的情况下可以得到最优解&#xff0c;缺点是实际中概率密度通常未知&#xff0c;需要通过大量数据估计。判别方法&#xff1a;假设判别函数的形式已知&…

Sentinel(三):Sentinel熔断降级

一、Sentinel熔断概念介绍 官方文档网址&#xff1a;circuit-breaking | Sentinel 1、Sentinel熔断基本介绍 除了流量控制以外&#xff0c;对调用链路中不稳定的资源进行熔断降级也是保障高可用的重要措 施之一。一个服务常常会调用别的模块&#xff0c;可能是另外的一个远程服…

PostgreSQL 主从集群搭建

下面是 PostgreSQL 主从复制&#xff08;Streaming Replication&#xff09;环境的安装与配置指南&#xff0c;适合在两台或多台服务器之间构建一主一从&#xff08;或一主多从&#xff09;的高可用读写分离系统。 环境准备 角色主机名/IP说明主库192.168.1.10可读写&#xff…

STM32安全固件升级:使用自定义 bootloader 实现SD卡固件升级,包含固件加密

前言 在 STM32 嵌入式开发中&#xff0c;Bootloader 是一个不可或缺的模块。ST 公司为 STM32 提供了功能完备的官方 Bootloader&#xff0c;支持多种通信接口&#xff08;如 USART、USB DFU、I2C、SPI 等&#xff09;&#xff0c;适用于标准的固件更新方案。 然而&#xff0c…

一步部署APache编译安装脚本

接下来我来介绍以下编译安装的好处 编译安装的优点与缺点 一、优点 高度可定制 可根据实际需求启用或关闭特性&#xff08;如 Apache 的模块、MySQL 的引擎等&#xff09;。 灵活控制编译参数、优化性能&#xff08;如 --enable-xxx、--with-xxx&#xff09;。 更高的性能…

[Linux]mmap()函数内存映射原理及用法

一、内存映射 内存映射&#xff0c;简而言之就是将用户空间的一段内存区域映射到内核空间&#xff0c;映射成功后&#xff0c;用户对这段内存区域的修改可以直接反映到内核空间&#xff0c;同样&#xff0c;内核空间对这段区域的修改也直接反映用户空间。那么对于内核空间和用…

通信无BUG,ethernet ip转profinet网关,汽车焊接设备通信有心机

在运用“激光钎焊”对汽车车顶、侧面板、后行李箱盖等位置进行接合时&#xff0c;必须配备能够沿着复杂车身线条&#xff0c;对细窄焊接线实施高精度快速检测及模仿控制的“焊缝跟踪控制”。 那么汽车生产线的系统升级改造迫在眉睫&#xff0c;当西门子PLC和库卡机器人无法通信…

python脚本ETH获取最新发行版本并将是否更新信息发送到钉钉

import requests import json import time import hmac import hashlib import base64 import urllib.parse# 1. 配置钉钉机器人 webhook "https://oapi.dingtalk.com/robot/send?access_tokenXXX" secret "XXX" # 如果没有加签验证&#xff0c;请设…

【Docker基础】Docker容器管理:docker ps及其参数详解

目录 1 docker ps命令概述 1.1 命令定位与作用 1.2 命令基本语法 2 基础参数详解 2.1 默认输出解析 2.2 核心参数解析 2.2.1 -a, --all 2.2.2 -q, --quiet 2.2.3 --no-trunc 3 高级过滤与格式化 3.1 过滤器(--filter)详解 3.1.1 常用过滤条件 3.1.2 实际应用示例 …

应急响应-感染Neshta病毒

病毒确定&#xff1a; 根据感染现象确定为Virus/Win32.Neshta家族病毒 病毒表现&#xff1a; 该病毒为感染式病毒。该病毒会在系统%SystemRoot%目录下释放svchost.com文件&#xff0c;并通过添加注册表的方式确保每个exe文件执行的时候都会先执行这个文件。该病毒还会收集系统信…

Hyperledger Fabric 入门笔记(二十)Fabric V2.5 测试网络进阶之Tape性能测试

文章目录 前言一、介绍二、架构三、安装说明四、使用方法4.1. 修改配置文件4.2. 启动测试网络4.3. 运行测试 前言 本文介绍由Hyperledger中国技术工作组提供的另一款区块链网络性能测试工具Tape的架构、安装和在Fabric测试网络中的使用。 一、介绍 Tape是一款轻量级的、可以快…

怎样在 VS Code 中快速创建 Vue 单文件组件(SFC)的基础模板结构?

问题 在Vue项目的开发中&#xff0c;我们经常遇到一个问题&#xff0c;创建新组件时要自己输入基本的框架&#xff0c;比如&#xff1a; <template><div class"page-box"></div> </template><script> export default {name: ,data()…

高防IP在服务器中的作用都有哪些?

高防IP作为一种通过技术手段让用户网络服务更加安全的一种IP地址&#xff0c;有着更高的防御能力&#xff0c;有着强大的流量清洗中心和防御系统&#xff0c;帮助企业实时监控网络流量&#xff0c;将恶意的用户请求识别并过滤掉&#xff0c;保护目标服务器不会受到网络攻击&…