Sentinel 容灾中心的使用

news2024/12/25 0:10:33

Sentinel 容灾中心的使用

往期文章

  1. Nacos环境搭建
  2. Nacos注册中心的使用
  3. Nacos配置中心的使用

熔断/限流结果

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

Jar

生产者

spring-cloud-alibaba：2021.0.4.0
spring-boot：2.6.8
spring-cloud-loadbalancer：3.1.3
sentinel：2021.0.4.0

<!-- 一定要放在前面 -->
<!--Sentinel -->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- sentinel-dashboard -->
<dependency>
	<groupId>com.alibaba.csp</groupId>
	<artifactId>sentinel-transport-simple-http</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
<!--Spring Cloud Alibaba Nacos Discovery-->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!--Spring Cloud Alibaba Nacos Config-->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!--LoadBalancer-->
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

消费者

<!-- 一定要放在前面 -->
<!--Sentinel -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!--Spring Cloud Alibaba Nacos Config-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!--LoadBalancer-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!--FastJSON-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
</dependency>

yml

生产者

server:
port: 8481
spring:
  application:
	name: nacos-provider
  cloud:
	nacos:
	  discovery:
		server-addr: localhost:8848
		username: devilvan
		password: 741258963hjkl
management:
  endpoints:
	web:
	  exposure:
		include: '*'

消费者

server:
  port: 8581
spring:
  application:
    name: nacos-consumer
  cloud:
    nacos:
      config:
        group: DEFAULT_GROUP
        server-addr: localhost:8848

熔断/流量控制（硬编码限流规则）

【资源】是sentinel限流、熔断的基本单位，可以设置每个资源的阈值。

@Service
public class NacosProviderServiceImpl implements NacosProviderService {
    private static final String[] RESOURCE_NAME_ARR = new String[]{"echo", "echo2"};

    /**
     * 初始化限流规则
     */
    @PostConstruct
    public void initFlowRules() {
        List<FlowRule> flowRules = new ArrayList<>();
        for (String resourceName : RESOURCE_NAME_ARR) {
            FlowRule flowRule = new FlowRule();
            // 设置受保护的资源
            flowRule.setResource(resourceName);
            // 设置流控规则 QPS
            flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
            // 设置受保护的资源阈值
            // Set limit QPS to 1.
            flowRule.setCount(1);
            flowRules.add(flowRule);
        }
        // 加载配置好的规则
        FlowRuleManager.loadRules(flowRules);
    }
}

控制层

其中echo方法使用注解形式定义sentinel资源，并通过自定义类的形式指定熔断和限流的方法。

/**
 * @Description Nacos生产者 控制层
 */
@RestController
@RequestMapping(value = "nacosProviderController")
public class NacosProviderController {
	@Resource(name = "nacosProviderServiceImpl")
	private NacosProviderService nacosProviderService;

	@GetMapping(value = "/echo/{str}")
	@SentinelResource(value = "echo", fallback = "echoFallback", fallbackClass = EchoFallback.class,
			blockHandler = "echoBlockHandler", blockHandlerClass = EchoFallback.class)
	public ResultMessage<String> echo(@PathVariable String str) {
		return nacosProviderService.echo(str);
	}

	@GetMapping(value = "/echo2/{str}")
	public ResultMessage<String> echo2(@PathVariable String str) {
		return nacosProviderService.echo2(str);
	}
}

echo方法对应限流/熔断处理类

/**
 * @Description echo方法 异常回调类
 */
public class EchoFallback {
	/**
	 * 遇到异常走的逻辑
	 *
	 * @param str 原方法的参数
	 * @param e   异常信息
	 * @return 异常回调方法返回值，和原方法返回值一致
	 */
	public static ResultMessage<String> echoFallback(String str, Throwable e) {
		ResultMessage<String> resultMessage = new ResultMessage<>();
		String message = "熔断-echo方法调用异常，str: " + str + "\n" + e;
		resultMessage.setMessage(message);
		return resultMessage;
	}

	/**
	 * 方法限流逻辑
	 *
	 * @param str 原方法的参数
	 * @param e   异常信息
	 * @return 限流回调方法返回值，和原方法返回值一致
	 */
	public static ResultMessage<String> echoBlockHandler(String str, BlockException e) {
		ResultMessage<String> resultMessage = new ResultMessage<>();
		String message = "限流-echo方法进行 限流，str: " + str + "\n" + e;
		resultMessage.setMessage(message);
		return resultMessage;
	}
}

业务逻辑层

echo2方法则使用官方案例的写法，先在初始化initFlowRules()方法中定义echo2资源，然后在实现类中编写对该资源熔断、限流的逻辑

/**
 * @Description Nacos生产者 业务逻辑实现类
 */
@Service
public class NacosProviderServiceImpl implements NacosProviderService {
	private static final String[] RESOURCE_NAME_ARR = new String[]{"echo", "echo2"};

	/**
	 * 初始化限流规则
	 */
	@PostConstruct
	public void initFlowRules() {
		List<FlowRule> flowRules = new ArrayList<>();
		for (String resourceName : RESOURCE_NAME_ARR) {
			FlowRule flowRule = new FlowRule();
			// 设置受保护的资源
			flowRule.setResource(resourceName);
			// 设置流控规则 QPS
			flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
			// 设置受保护的资源阈值
			// Set limit QPS to 1.
			flowRule.setCount(1);
			flowRules.add(flowRule);
		}
		// 加载配置好的规则
		FlowRuleManager.loadRules(flowRules);
	}

	/**
	 * 测试限流/熔断的方法
	 *
	 * @param str 原方法的参数
	 * @return 回调
	 */
	@Override
	public ResultMessage<String> echo(String str) {
		ResultMessage<String> resultMessage = new ResultMessage<>();
		if ("devilvan".equals(str)) {
			String msg = "Hello Nacos Discovery " + str;
			resultMessage.setMessage(msg);
		} else {
			throw new RuntimeException();
		}
		return resultMessage;
	}

	/**
	 * 测试sentinel设置资源并使用的方法
	 *
	 * @param str 入参字符串
	 * @return 回调
	 */
	@Override
	public ResultMessage<String> echo2(String str) {
		String resource = "echo2";
		ResultMessage<String> resultMessage = new ResultMessage<>();
		Entry entry = null;
		try {
			entry = SphU.entry(resource);
			if ("devilvan".equals(str)) {
				String msg = "Hello Nacos Discovery " + str;
				resultMessage.setMessage(msg);
			} else {
				throw new RuntimeException();
			}
		} catch (BlockException e) {
			String msg = "限流-echo2方法调用异常，str: " + str + "\n" + e;
			resultMessage.setMessage(msg);
		} catch (Exception e) {
			String msg = "熔断-echo2方法调用异常，str: " + str + "\n" + e;
			resultMessage.setMessage(msg);
		} finally {
			if (entry != null) {
				entry.exit();
			}
		}
		return resultMessage;
	}
}

对于使用异常的解释

以上两个方法案例中都涉及到对异常的处理（高亮部分），熔断的方法对应使用Throwable的异常捕获，限流的方法只使用BlockException异常进行捕获。

消费者代码

控制层

/**
 * @Description Nacos消费者 控制层
 */
@RestController
@RequestMapping(value = "nacosConsumerController")
public class NacosConsumerController {
	private NacosFeignService nacosFeignService;

	@Autowired
	public void setNacosFeignService(NacosFeignService nacosFeignService) {
		this.nacosFeignService = nacosFeignService;
	}

	@RequestMapping(value = "/echo/{str}", method = RequestMethod.GET)
	public String echo(@PathVariable String str) {
		return nacosFeignService.echo(str);
	}

	@RequestMapping(value = "/echo2/{str}", method = RequestMethod.GET)
	public String echo2(@PathVariable String str) {
		return nacosFeignService.echo2(str);
	}
}

feign远程调用层

/**
 * @author Evad.Wu
 * @Description Nacos Feign 远程调用接口
 * @date 2022-11-05
 */
@FeignClient(value = "nacos-provider")
public interface NacosFeignService {
	/**
	 * 远程调用的测试方法
	 *
	 * @param str 路由下的参数
	 * @return 返回值
	 * @author Evad.Wu
	 * @Description 远程调用的测试方法
	 * @date 2022-11-05
	 */
	@GetMapping(value = "nacosProviderController/echo/{str}")
	String echo(@PathVariable String str);

	/**
	 * 远程调用的测试方法2
	 *
	 * @param str 路由下的参数
	 * @return 返回值
	 * @author Evad.Wu
	 * @Description 远程调用的测试方法2
	 * @date 2022-11-05
	 */
	@GetMapping(value = "nacosProviderController/echo2/{str}")
	String echo2(@PathVariable String str);
}

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

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

相关文章

如何快速模拟一个后端 API

如何快速模拟一个后端 API

第一步&#xff1a;创建一个文件夹&#xff0c;用来存储你的数据 数据&#xff1a; {"todos": [{ "id": 1, "text": "学习html44", "done": false },{ "id": 2, "text": "学习css", "…
阅读更多...
只会“点点点”，凭什么让开发看的起你？

只会“点点点”，凭什么让开发看的起你？

众所周知&#xff0c;如今无论是大厂还是中小厂&#xff0c;自动化测试基本是标配了&#xff0c;毕竟像双 11、618 这种活动中庞大繁杂的系统&#xff0c;以及多端发布、多版本、机型发布等需求&#xff0c;但只会“写一些自动化脚本”很难胜任。这一点在招聘要求中就能看出来。…
阅读更多...
Android 面试题 优化 (一)

Android 面试题 优化 (一)

&#x1f525; Android性能优化指标 &#x1f525; ​ &#x1f525; 包体积优化 &#x1f525; 安装包的大小会影响用户的安装率&#xff0c;如果一个包的太大&#xff0c;用户安装的意愿会大大降低。 经过包分析可以看到&#xff0c;安装包最大的部分是资源和第三方库&#…
阅读更多...
奥迪A3：最新款奥迪A3内饰设计及智能科技应用

奥迪A3：最新款奥迪A3内饰设计及智能科技应用

奥迪A3一直以来都是奥迪的入门级车型&#xff0c;但这并不意味着它在科技和内饰方面会有所退步。最新款奥迪A3的内饰设计和智能科技应用让人们再次惊叹奥迪的创新能力。 内饰设计 奥迪A3最新款的内饰设计引入了奥迪最新的设计元素&#xff0c;比如8.8英寸的中控显示屏&#xf…
阅读更多...
山西电力市场日前价格预测【2023-07-30】

山西电力市场日前价格预测【2023-07-30】

日前价格预测 预测明日&#xff08;2023-07-30&#xff09;山西电力市场全天平均日前电价为287.10元/MWh。其中&#xff0c;最高日前电价为309.20元/MWh&#xff0c;预计出现在09: 15。最低日前电价为252.82元/MWh&#xff0c;预计出现在24: 00。 价差方向预测 1&#xff1a;实…
阅读更多...
Dendrogram | 今天是人见人爱、花见花开的环形Dendrogram！~（附完整代码）

Dendrogram | 今天是人见人爱、花见花开的环形Dendrogram！~（附完整代码）

1写在前面 好长时间没更新了&#xff0c;这周真的是天天都在手术室度过&#xff0c;常讲到的一句话就是苦的一比啊。&#x1fae0; 很久没有见过外面的世界了&#xff0c;世界那么大&#xff0c;我也想去看看&#xff01;~&#x1f602; 废话太多了&#xff0c;今天的教程是环形…
阅读更多...
网络安全/信息安全（黑客技术）自学笔记

网络安全/信息安全（黑客技术）自学笔记

一、网络安全基础知识 1.计算机基础知识 了解了计算机的硬件、软件、操作系统和网络结构等基础知识&#xff0c;可以帮助您更好地理解网络安全的概念和技术。 2.网络基础知识 了解了网络的结构、协议、服务和安全问题&#xff0c;可以帮助您更好地解决网络安全的原理和技术…
阅读更多...
从分片传输到并行传输之大文件传输加速技术

从分片传输到并行传输之大文件传输加速技术

随着大文件的传输需求越来越多&#xff0c;传输过程中也会遇到很多困难&#xff0c;比如传输速度慢、文件安全性低等。为了克服这些困难&#xff0c;探讨各种大文件传输加速技术。其中&#xff0c;分片传输和并行传输是两种比较常见的技术&#xff0c;下面将对它们进行详细说明…
阅读更多...
WEB:Web_python_template_injection

WEB:Web_python_template_injection

背景知识 python模板注入 ssit 题目 打开题目&#xff0c;发现页面提示&#xff0c;翻译为python模板注入 先测试是否存在注入 可以发现被执行了 先查看所有的子类 payload {{[].__class__.__base__.__subclasses__()}} 利用site.Printer的os模块执行命令 payload {{.__…
阅读更多...
CAN转EtherNet/IP网关can协议破解服务

CAN转EtherNet/IP网关can协议破解服务

JM-EIP-CAN 是自主研发的一款 ETHERNET/IP 从站功能的通讯网关。该产品主要功能是将各种 CAN 总线和 ETHERNET/IP 网络连接起来。 本网关连接到 ETHERNET/IP 总线中做为从站使用&#xff0c;连接到 CAN 总线中根据节点号进行读写。 技术参数 ETHERNET/IP 技术参数 网关做为 …
阅读更多...
C# Socket实际应用案例与属性详解

C# Socket实际应用案例与属性详解

引言 Socket是一个在网络编程中非常常见和重要的概念&#xff0c;它提供了一种通信机制&#xff0c;使不同的计算机之间可以进行数据传输。本文将介绍C#中Socket的实际应用案例&#xff0c;并对Socket的常用属性进行详细解析。 文章目录 1. Socket的实际应用案例2. Socket的属…
阅读更多...
CAS比较并交换具体实现细节

CAS比较并交换具体实现细节

线程2读取内存值到工作内存中&#xff0c;设置一个预估值与读入的值相等&#xff0c;线程1也同样读入。 线程2进行操作&#xff0c;之后在写入内存前&#xff0c;将预估值与内存值作比较&#xff0c;看内存值是否修改过。 如果线程2比较完相同&#xff0c;则修改内存值为1&am…
阅读更多...
开源了！最强原创图解八股文面试网来袭

开源了！最强原创图解八股文面试网来袭

强烈推荐 Github上业内新晋的一匹黑马—Java图解八股文面试网—Java2Top.cn&#xff0c;图解 Java 大厂面试题&#xff0c;深入全面&#xff0c;真的强烈推荐~ 这是一个二本逆袭阿里的大佬根据自己秋招上岸所看过的相关专栏&#xff0c;面经&#xff0c;课程&#xff0c;结合自…
阅读更多...
211. 添加与搜索单词 - 数据结构设计---------------字典树

211. 添加与搜索单词 - 数据结构设计---------------字典树

211. 添加与搜索单词 - 数据结构设计 原题链接&#xff1a;完成情况&#xff1a;解题思路&#xff1a;参考代码&#xff1a; 原题链接&#xff1a; 211. 添加与搜索单词 - 数据结构设计 https://leetcode.cn/problems/design-add-and-search-words-data-structure/descriptio…
阅读更多...
tinkerCAD案例：19. Move Circuit Assembly 移动电路组件

tinkerCAD案例：19. Move Circuit Assembly 移动电路组件

tinkerCAD案例&#xff1a;19. Move Circuit Assembly 移动电路组件 In this tutorial, you’ll learn how to add the Move circuit assembly to a design. 在本教程中&#xff0c;您将学习如何将移动电路装配体添加到设计中。 When you assemble the Move circuit assembly…
阅读更多...
【Docker】Docker应用部署之Docker容器安装Tomcat

【Docker】Docker应用部署之Docker容器安装Tomcat

目录 一、搜索镜像 二、拉取镜像 三、创建容器 四、测试使用 一、搜索镜像 docker search tomcat 二、拉取镜像 docker pull tomcat:版本 三、创建容器 首先在宿主机创建数据卷的目录 mkdir /root/tomcat # 创建目录 cd /root/tomcat # 进入目录 docker run -id -…
阅读更多...
解决mysqld服务启动失败

解决mysqld服务启动失败

1、进程 首先查看下mysql进程: ps -aux | grep mysql有进程号 2、所有者和所属组为mysql 查看/usr/local/MySQL/data/mysqld.pid所有者和所属组是否为mysql 原来是权限有问题&#xff0c;那么更改权限&#xff08;还需要加权限&#xff09;3、 重新启动服务
阅读更多...
2023牛客暑期多校-J-Qu‘est-ce Que C‘est?（DP)

2023牛客暑期多校-J-Qu‘est-ce Que C‘est?（DP)

题意&#xff1a; 给定长度为n的数列,要求每个数都在的范围&#xff0c;且任意长度大于等于2的区间和都大于等于0&#xff0c;问方案数。。 思路&#xff1a; 首先要看出是dp题&#xff0c;用来表示遍历到第i位且后缀和最小为x的可行方案数&#xff08;此时的后缀可以只有最…
阅读更多...
LeetCode[面试题04.08]首个共同祖先

LeetCode[面试题04.08]首个共同祖先

难度&#xff1a;Medium 题目&#xff1a; 设计并实现一个算法&#xff0c;找出二叉树中某两个节点的第一个共同祖先。不得将其他的节点存储在另外的数据结构中。注意&#xff1a;这不一定是二叉搜索树。 例如&#xff0c;给定如下二叉树: root [3,5,1,6,2,0,8,null,null,7,…
阅读更多...
软考高级架构师笔记-10数学计算题

软考高级架构师笔记-10数学计算题

目录 1. 前文回顾 & 考情分析2. 最小生成树3. 最短路径4. 网络与最大流量5. 线性规划6. 动态规划/决策表7. 博弈论8. 状态转移矩阵9. 决策论10. 结语1. 前文回顾 & 考情分析 前文回顾： 软考高级架构师笔记-1计算机硬件软考高级架构师笔记-2计算机软件（操作系统）软考…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023