Sentinel 容灾中心的使用

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);
}

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Jquery笔记

Jquery笔记

DOM对象通过jquery获取 所有的代码都是基于引入jquery.js文件 var mydiv $(#div);//直接获取到DOM对象元素id var mydiv$(.div)&#xff1b;//通过class获取DOM对象&#xff0c;如果有同名class只会获取第一个 var mysapn$(span);//通过元素的标签名获取DOM对象 var divarr$(…
阅读更多...
Closure Table-树形多级关系数据库设计(MySql)

Closure Table-树形多级关系数据库设计(MySql)

一般树形多级关系数据库设计&#xff0c;比较普遍的就是四种方法&#xff1a;&#xff08;具体见 SQL Anti-patterns这本书&#xff09; Adjacency List&#xff1a;每一条记录存parent_id Path Enumerations&#xff1a;每一条记录存整个tree path经过的node枚举&#xff08…
阅读更多...
30个前端开发中常用的JavaScript函数

30个前端开发中常用的JavaScript函数

&#x1f9d1;‍&#x1f4bb;作者名称&#xff1a;DaenCode &#x1f3a4;作者简介&#xff1a;啥技术都喜欢捣鼓捣鼓&#xff0c;喜欢分享技术、经验、生活。 &#x1f60e;人生感悟&#xff1a;尝尽人生百味&#xff0c;方知世间冷暖。 前言 在前端开发中通常会用到校验函数…
阅读更多...
VSCode搭建GCC环境

VSCode搭建GCC环境

1. 下载 https://www.mingw-w64.org/downloads/ https://github.com/niXman/mingw-builds-binaries/releases 2.安装 x86_64-12.2.0-release-win32-seh-rt_v10-rev1.7z解压到D盘 我的电脑–属性–系统属性–环境变量–系统变量–path D:\MinGW-w64\x86_64-12.2.0-release…
阅读更多...
一种嵌入式LCD显示多国语言方法

一种嵌入式LCD显示多国语言方法

简介 介绍一种嵌入式LCD显示多国语言方法&#xff0c;由于很多产品嵌入式资源有限&#xff0c;显示的字符也不多&#xff0c;所以可以自己制作一些字库&#xff0c;而不用字库芯片。 下面展示一种从字库取出字符的方法。 代码示例 #include <stdio.h> #include <s…
阅读更多...
27 用linprog、fmincon求 解线性规划问题（matlab程序）

27 用linprog、fmincon求 解线性规划问题（matlab程序）

1.简述 ① linprog函数&#xff1a; 求解线性规划问题&#xff0c;求目标函数的最小值&#xff0c; [x,y] linprog(c,A,b,Aeq,beq,lb,ub) 求最大值时&#xff0c;c加上负号&#xff1a;-c ② intlinprog函数&#xff1a; 求解混合整数线性规划问题&#xff0c; [x,y] intl…
阅读更多...
hadoop部署配置

hadoop部署配置

端口名称 Hadoop2.x Hadoop3.x NameNode内部通信端口 8020 / 9000 8020 / 9000/9820 NameNode HTTP UI 50070 9870 MapReduce查看执行任务端口 8088 8088 历史服务器通信端口 19888 19888 端口名称Hadoop2.xHadoop3.xNameNode内部通信端口8020 / 90008020 / 9000/9820NameNode…
阅读更多...
安科瑞智慧空开微型断路器在银行的应用-安科瑞黄安南

安科瑞智慧空开微型断路器在银行的应用-安科瑞黄安南

应用场景 智能微型断路器与智能网关组合应用于末端回路 功能 1.计量功能&#xff1a;实时上报电压、电流、功率、电能、漏电、温度、频率等电参量&#xff1b; 2.报警功能&#xff1a;过压报警、欠压报警、过流报警、过载报警、漏电报警、超温报警、三相电缺相报警&#xff…
阅读更多...
【面试】某公司记录一次面试题

【面试】某公司记录一次面试题

文章目录 框架类1. Spring boot与 spring 架相比&#xff0c;好在哪里?2. Spring boot以及 Spring MVC 常用注解(如requestingMapping&#xff0c;responseBody 等)3. 常用的java 设计模式&#xff0c;spring 中用到哪些设计模式4. SpringIOC是什么&#xff0c;如何理解5. AOP…
阅读更多...
ES开启身份认证

ES开启身份认证

文章目录 X-Pack简介之前的安全方案ES开启认证ES服务升级https协议开启集群节点之间的证书认证 X-Pack简介 X-Pack是Elastic Stack扩展功能&#xff0c;提供安全性&#xff0c;警报&#xff0c;监视&#xff0c;报告&#xff0c;机器学习和许多其他功能。 X-Pack的发展演变&am…
阅读更多...
jsonp 实现跨域 同时也是一个 webflux 的demo 示例

jsonp 实现跨域 同时也是一个 webflux 的demo 示例

文章目录 核心原理代码html服务端 &#xff08;java 为例子&#xff09;服务端目录结构 核心原理 前端&#xff1a; 使用js 创建 script 标签&#xff0c;将请求地址&#xff0c;放到其src 中&#xff0c;并将 script 标签追加到文档流&#xff1b;后端&#xff1a;根据约定好…
阅读更多...
Jenkins+Docker+Docker-Compose自动部署，SpringCloud架构公共包一个任务配置

Jenkins+Docker+Docker-Compose自动部署，SpringCloud架构公共包一个任务配置

前言 Jenkins和docker的安装&#xff0c;随便百度吧&#xff0c;实际场景中我们很多微服务的架构&#xff0c;都是有公共包&#xff0c;肯定是希望一个任务能够把公共包的配置加进去&#xff0c;一并构建&#xff0c;ok&#xff0c;直接上干货。 Jenkins 全局环境安装 pwd e…
阅读更多...
使用SpringBoot+SpringMVC+Mybatis+Redis实现个人博客管理平台

使用SpringBoot+SpringMVC+Mybatis+Redis实现个人博客管理平台

文章目录 前言1. 项目概述2. 项目需求2.1功能需求2.2 其他需求2.3 系统功能模块图 3. 开发环境4. 项目结构5. 部分功能介绍5.1 数据库密码密文存储5.2 统一数据格式返回5.3 登录拦截器 6. 项目展示 前言 在几个月前实现了一个servlet版本的博客系统&#xff0c;本项目则是在原…
阅读更多...
左神算法之中级提升班（8)

左神算法之中级提升班（8)

目录 【案例1】 【题目描述】 【思路解析】 【代码实现】 【案例2】 【题目描述】 【思路解析】 【代码实现】 【案例3】 【题目描述】 【思路解析】 【案例4】 【题目描述】 【思路解析】 【代码实现】 【案例5】 【题目描述】 【子序列概念】 【思路解析1 经典…
阅读更多...
【C++】STL中list的模拟实现（增删查改，迭代器封装，运算符重载）

【C++】STL中list的模拟实现（增删查改，迭代器封装，运算符重载）

文章目录 前言大体框架&#xff1a; 一、节点的封装&#xff08;list_node&#xff09;二、迭代器的封装(_list_iterator)1.类模板的定义&#xff1a;2.构造函数3.前置&#xff0c;后置4.前置--&#xff0c;后置--5.解引用(operator*())6. ->重载&#xff08;operator- >…
阅读更多...
关于提示词 Prompt

关于提示词 Prompt

Prompt原则 原则1 提供清晰明确的指示 注意在提示词中添加正确的分割符号 prompt """ 请给出下面文本的摘要&#xff1a; <你的文本> """可以指定输出格式&#xff0c;如&#xff1a;Json、HTML提示词中可以提供少量实例&#xff0c;…
阅读更多...
Android 面试题 ANR 五

Android 面试题 ANR 五

&#x1f525; 什么是 ANR &#x1f525; ANR(Application Not Responding )应用无响应的简称&#xff0c;是为了在 APP卡死时&#xff0c;用户 可以强制退出APP的选择&#xff0c;从而避免卡机无响应问题&#xff0c;这是Android系统的一种自我保护机制。 在Android中&#xf…
阅读更多...
【无标题】使用Debate Dynamics在知识图谱上进行推理（2020）7.31

【无标题】使用Debate Dynamics在知识图谱上进行推理（2020）7.31

使用Debate Dynamics在知识图谱上进行推理 摘要介绍背景与相关工作我们的方法 摘要 我们提出了一种新的基于 Debate Dynamics 的知识图谱自动推理方法。 其主要思想是将三重分类任务定义为两个强化学习主体之间的辩论游戏&#xff0c;这两个主体提取论点&#xff08;知识图中…
阅读更多...
fixed-视频倍速

fixed-视频倍速

首先fn12打开开发者模式 然后进入console控制台 document.getElementsByTagName(“video”)[0].playbackRate 3 数字3 就是多少倍速 可以替换想要的倍速 直接快进到 最后 let video document.getElementsByTagName(‘video’) for (let i0; i<video.length; i) { video[…
阅读更多...
音频编辑必备技能：怎么将音频转换mp3

音频编辑必备技能：怎么将音频转换mp3

丽萨&#xff1a;嘿&#xff0c;听说你最近在研究音频格式转换的方法&#xff0c;有眉目了吗&#xff1f; 凯瑞&#xff1a;没错&#xff0c;我下载了很多高清音乐&#xff0c;发现有些格式的音频文件在我的播放器上打不开&#xff0c;所以想一个转换工具。但是网上软件太多&a…
阅读更多...
最新文章

Copyright @ 2022~2023