Spring Cloud(微服务)学习篇(七)

news2024/11/18 19:55:05

Spring Cloud(微服务)学习篇(七)

1.使用代码的方式实现流量限制规则

1.1 变更SentinelController类

1.1.1 加入的代码

//流控限制 (一个或多个资源限流), postConstruct注解的作用是保证项目一启动就会加载,
    // 一个rule就是一个规则
    @PostConstruct
    public void FlowRule(){
        List<FlowRule> rules = new ArrayList<FlowRule>();
        FlowRule rule = new FlowRule();
        rule.setResource("find");//资源名
        // set limit qps to 10
        rule.setCount(7);//并发数 1s钟最多执行次数
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule.setLimitApp("default");
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
    }

1.2.1 完整的SentinelController类代码

package com.zlz.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;

@RestController
public class SentinelController {
    int count=0;
    @SentinelResource("find")
    //资源名称和下方一致
    @RequestMapping("find")
    public String find(){
        count++;
        System.out.println("进入用户查询方法");
        return "查询用户:"+count;
    }

    //流控限制 (一个或多个资源限流), postConstruct注解的作用是保证项目一启动就会加载,
    // 一个rule就是一个规则
    @PostConstruct
    public void FlowRule(){
        List<FlowRule> rules = new ArrayList<FlowRule>();
        FlowRule rule = new FlowRule();
        rule.setResource("find");//资源名
        // set limit qps to 10
        rule.setCount(7);//并发数 1s钟最多执行次数
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule.setLimitApp("default");
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
    }
}

1.2 测试

1.2.1 查看Mysql服务是否打开(只有mysql服务打开,启动nacos窗口才正常)

在这里插入图片描述

1.2.2 启动nacos服务

在这里插入图片描述

1.2.3 启动Sentinel控制台项目

a 找到sentinel控制台jar包所在的位置➡输入java -jar sentinel-dashboard.jar➡回车

在这里插入图片描述

b 回车后的界面

在这里插入图片描述

c 通过浏览器登录进入Sentinel后台界面
c.1 在浏览器输入地址localhost:8080后跳转的页面

在这里插入图片描述

c.2 输入账户和密码后跳转的页面

在这里插入图片描述

1.2.4 启动用户服务

在这里插入图片描述

1.2.5 点击刷新Sentinal控制台界面➡点击shop-user➡流控规则

在这里插入图片描述

1.2.6 点击编辑

在这里插入图片描述

1.2.7 点击编辑按钮后跳转的页面

在这里插入图片描述

2 对流量限流给出友好提示

2.1 定义方法的形式

2.1.1 更新SentinelController类

a 加入的代码
//    blockHandler就是 限流了应该怎么处理,通常是用于查询的请求,因为这样做本质上是丢弃了这个请求
//    必须要有BlockException e
//需要与原来方法(find方法)的返回值一模一样
//①新增xlHandler方法
    public String xlHandler(BlockException e){
        //请求太多放弃掉 查询
         return "当前访问人数过多 请稍后再试";
    }
//② 在find方法的@SentinelResource注解里面加上blockHandler = "xlHandler"
b 完整的SentinelController类
package com.zlz.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import com.zlz.handler.SentinelHandler;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;

@RestController
public class SentinelController {
    int count=0;
    //blockHandler指定的是方法
    @SentinelResource(value="find",blockHandler = "xlHandler")
    //资源名称和下方一致
    @RequestMapping("find")
    public String find(){
        count++;
        System.out.println("进入用户查询方法");
        return "查询用户:"+count;
    }

    //流控限制 (一个或多个资源限流), postConstruct注解的作用是保证项目一启动就会加载,
    // 一个rule就是一个规则
    @PostConstruct
    public void FlowRule(){
        List<FlowRule> rules = new ArrayList<FlowRule>();
        FlowRule rule = new FlowRule();
        rule.setResource("find");//资源名
        // set limit qps to 10
        rule.setCount(7);//并发数 1s钟最多执行次数
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule.setLimitApp("default");
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
    }
    //    blockHandler就是 限流了应该怎么处理
//必须要有BlockException e,若find方法有形参,那么这个方法也得有相应顺序的形参,但是最后一个形参一定是e
//需要与原来方法(find方法)的返回值一模一样
    public String xlHandler(BlockException e){
        //原理是请求太多放弃掉查询
        return "当前访问人数过多 请稍后再试";
    }
}

2.1.2 测试

a 重新启动用户服务

在这里插入图片描述

b jemeter压力测试
b.1 添加线程组

在这里插入图片描述

b.2 编辑线程组

在这里插入图片描述

b.3 创建HTTP请求

在这里插入图片描述

b.4 编辑HTTP请求

在这里插入图片描述

b.5 在线程组下面创建结果树

在这里插入图片描述

b.6 点击绿色按钮➡点击NO按钮

在这里插入图片描述

b.7 点击前7个的HTTP请求的任意一个,都是正常访问

在这里插入图片描述

b.8 点击后三个的HTTP请求的任意一个,都是显示当前访问人数过多,请稍后再试

在这里插入图片描述

2.2 定义类的方式(处理方法在类中)

2.2.1 在zlz包下创建handler包并创建SentinelHandler类

package com.zlz.handler;

import com.alibaba.csp.sentinel.slots.block.BlockException;

public class SentinelHandler {
    //这个方法必须是静态方法
    public static String xlHandler(BlockException e){
        //请求太多放弃掉 查询
        return "当前访问人数过多 请稍后再试";
    }
}

2.2.2 更新SentinelController类

a 加入的代码
//① 在find方法的@SentinelResource注解里面加上blockHandler = "xlHandler" blockHandlerClass = SentinelHandler.class
b 完整的SentinelController类
package com.zlz.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import com.zlz.handler.SentinelHandler;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;

@RestController
public class SentinelController {
    int count=0;
    @SentinelResource(value="find",blockHandler = "xlHandler",blockHandlerClass = SentinelHandler.class)
    //资源名称和下方一致
    @RequestMapping("find")
    public String find(){
        count++;
        System.out.println("进入用户查询方法");
        return "查询用户:"+count;
    }

    //流控限制 (一个或多个资源限流), postConstruct注解的作用是保证项目一启动就会加载,
    // 一个rule就是一个规则
    @PostConstruct
    public void FlowRule(){
        List<FlowRule> rules = new ArrayList<FlowRule>();
        FlowRule rule = new FlowRule();
        rule.setResource("find");//资源名
        rule.setCount(7);//并发数 1s钟最多执行次数
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule.setLimitApp("default");
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
    }
}

2.2.2 测试

a 重新启动用户服务

在这里插入图片描述

b jemeter压力测试
b.1 清除之前的结果

在这里插入图片描述

b.2 重新点击绿色按钮➡点击NO按钮

在这里插入图片描述

b.3 点击前7个的HTTP请求的任意一个,都没有限流提示

在这里插入图片描述

b.4 点击后三个的HTTP请求的任意一个,都有限流提示

在这里插入图片描述

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

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

相关文章

【C++】string的成员函数、成员常量和非成员函数

【C++】string的成员函数、成员常量和非成员函数

目录 string 1. string的成员函数 1.1 构造、析构和赋值运算符重载 1.1.1 构造函数 1.1.2 析构函数 1.1.3 赋值运算符重载 1.2 迭代器 1.3 容量 1.4 元素访问 1.4.1 遍历方法 1.5 修改器 1.6 字符串操作 2. string的成员常量 3. string的非成员函数 string 以下…
阅读更多...
javaEE 初阶 — 应用层中的 DNS 协议（域名解析系统）

javaEE 初阶 — 应用层中的 DNS 协议（域名解析系统）

文章目录什么是域名1. 如何建立 域名 与 IP 的对应关系2. 域名的分级什么是域名 域名也就是平常所说的网址&#xff0c;比如 www.baidu.com。 其实网络上的服务器要访问这个网址&#xff0c;需要的是 IP 地址。、 但是 IP 地址比较拗口不方便记忆&#xff0c;于是就有使用一些…
阅读更多...
单向非循环链表

单向非循环链表

1、顺序表遗留问题 1. 中间/头部的插入删除&#xff0c;时间复杂度为O(N) 2. 增容需要申请新空间&#xff0c;使用malloc、realloc等函数拷贝数据&#xff0c;释放旧空间。会有不小的消耗。 3. 当我们以2倍速度增容时&#xff0c;势必会有一定的空间浪费。例如当前容量为100&a…
阅读更多...
IDEA这些配置，简单高效

IDEA这些配置，简单高效

优化导包配置配置路径&#xff1a;File-> settings -> Editor -> General -> Auto ImportAdd unambiguous imports on the fly&#xff1a;自动导包Optimize imports on th fly (for current project)&#xff1a;自动删除无用包代码提示取消大小写配置路径&#x…
阅读更多...
AOP（概念和原理）

AOP（概念和原理）

文章目录1. AOP&#xff08;概念&#xff09;2. AOP&#xff08;底层原理&#xff09;2.1 AOP底层使用动态代理&#xff08;两种&#xff09;2.2 AOP 底层使用哪种代理方式 &#xff1f;3. AOP相关概念3.1 AOP术语4. AOP操作4.1 基于AspectJ实现AOP操作4.2 切点表达式4.3 基于A…
阅读更多...
6 分布式事务简介

6 分布式事务简介

分布式事务简介 概念 基础概念&#xff1a;事务ACID * A&#xff08;Atomic&#xff09;&#xff1a;原子性&#xff0c;构成事务的所有操作&#xff0c;要么都执行完成&#xff0c;要么全部不执行&#xff0c;不可能出现部分成功部分失 败的情况。 * C&#xff08;Consisten…
阅读更多...
嵌入式和Python（一）：python环境搭建的详细步骤

嵌入式和Python（一）：python环境搭建的详细步骤

目录 ● 安装python ① 更新软件列表 ② 安装编译python需要用到的环境 ③ 下载python源码 ④ 解压源码包 ⑤ 配置 ⑥ 编译 ⑦ 安装 ● 建立软连接 说明 ① 删除原来的软连接 ② 在/usr/bin/目录创建软连接python&#xff0c;定向/usr/local/bin/python3.9 ③ 检查…
阅读更多...
Java面向对象:多态特性的学习

Java面向对象:多态特性的学习

本文介绍了Java面向对象多态特性, 多态的介绍. 多态的实现条件–1.发生继承.2.发生重写(重写与重载的区别)3.向上转型与向下转型.4.静态绑定和动态绑定5. 实现多态 举例总结多态的优缺点 避免在构造方法内调用被重写的方法… Java面向对象:多态特性的学习一.什么是多态?二.多态…
阅读更多...
MATLAB | 如何将colormap中心点置为0值处？

MATLAB | 如何将colormap中心点置为0值处？

本期讲有一些绘图时正负部分需要分开赋予颜色&#xff0c;这时候双向colormap的中心对应的可能并不是数值0&#xff0c;该咋办&#xff0c;就比如下面的情况&#xff1a; 事先说明&#xff0c;为了绘图好看&#xff0c;本文中全部示例都在代码最后用了以下这个简单函数进行修饰…
阅读更多...
库到底是个啥？为啥要链接，链接库的本质又是个啥？

库到底是个啥？为啥要链接，链接库的本质又是个啥？

目录 前言 一、库是个啥&#xff1f; ①最开始的库是用来解决啥问题&#xff1f; ②库的基本构成 ③动态库与静态库 二、如何生成库 0、相关知识 ①生成静态库 ②生成动态库 三、库的使用 ①修改环境变量 ②拷贝.so文件到系统共享库路径下, 一般指/usr/lib ③ldconfig 配置/etc…
阅读更多...
安卓逆向_6 --- JNI 和 NDK

安卓逆向_6 --- JNI 和 NDK

Java 本机接口规范内容&#xff1a;https://docs.oracle.com/en/java/javase/19/docs/specs/jni/index.html JNI官方中文资料&#xff1a;https://blog.csdn.net/yishifu/article/details/52180448 NDK 官方文档&#xff1a;https://developer.android.google.cn/training/ar…
阅读更多...
【Python学习笔记】第二十八节 Python random 模块

【Python学习笔记】第二十八节 Python random 模块

一、Python random简介Python random 模块主要用于生成随机数。大部分python人都会用&#xff0c;但是一般人都是使用randint()帮我们生成某个范围的整数&#xff0c;但其实random模块还有很多非常使用的功能供我们使用&#xff0c;接下来我们就一一了解一下我们的random。要使…
阅读更多...
JavaWeb系列之tomcat 服务器安装

JavaWeb系列之tomcat 服务器安装

文章目录一、JavaWeb应用程序架构B/S 架构C/S 架构B/S 与 C/S 对比MVC设计模式二、MVCMVC 开发项目搭建Web 服务器tomcat 服务器Idea 集成 tomcat第一个 JavaWeb 项目三、JSP 技术jsp 与 servlet 联系与区别一、JavaWeb 简介 JavaWeb 可以理解成使用 java 进行应用程序开发&am…
阅读更多...
Windows-jdk8/jdk16安装

Windows-jdk8/jdk16安装

Windows-JAVA jdk-8安装教程 下载地址 百度网盘 提取码&#xff1a;Chen 官网 安装jdk8 双击打开下载的安装包 点击下一步 更改安装目录 点击下一步 修改Java安装目录 点击下一步 完成 配置环境变量 按住WindowsR 打开运行窗口 输入 sysdm.cpl 打开系统属性——》高级—…
阅读更多...
华为机试题：HJ102 字符统计（python）

华为机试题：HJ102 字符统计（python）

文章目录&#xff08;1&#xff09;题目描述&#xff08;2&#xff09;Python3实现&#xff08;3&#xff09;知识点详解1、input()&#xff1a;获取控制台&#xff08;任意形式&#xff09;的输入。输出均为字符串类型。1.1、input() 与 list(input()) 的区别、及其相互转换方…
阅读更多...
【Redis】Redis分片集群

【Redis】Redis分片集群

【Redis】Redis分片集群 文章目录【Redis】Redis分片集群1. 搭建分片集群1.1 分片集群结构1.2 搭建分片集群1.2.1 集群结构1.2.2 准备实例和配置1.2.3 启动1.2.4 创建集群1.2.5 测试2. 散列插槽2.1 总结3. 集群伸缩4. 故障转移4.1 数据迁移5. RedisTemplate访问分片集群1. 搭建…
阅读更多...
GEE开发之ERA5（气温、降水、压力、风速等）数据获取和分析

GEE开发之ERA5（气温、降水、压力、风速等）数据获取和分析

GEE开发之ERA5&#xff08;气温、降水、压力、风速等&#xff09;数据获取和分析1.ERA5介绍2.初始ERA5数据2.1 DAILY代码2.2 MONTHLY代码3.遥感影像查看&#xff08;DAILY之mean_2m_air_temperature&#xff09;4.逐日数据分析和获取(以mean_2m_air_temperature为例)5.逐月数据…
阅读更多...
【Storm】【二】Storm和流处理简介

【Storm】【二】Storm和流处理简介

Storm和流处理简介 一、Storm1.1 简介1.2 Storm 与 Hadoop对比1.3 Storm 与 Spark Streaming对比1.4 Storm 与 Flink对比二、流处理2.1 静态数据处理2.2 流处理一、Storm 1.1 简介 Storm 是一个开源的分布式实时计算框架&#xff0c;可以以简单、可靠的方式进行大数据流的处理…
阅读更多...
基于 explore_lite包 的单个机器人自主探索建图

基于 explore_lite包 的单个机器人自主探索建图

文章目录一、简介二、安装 explore_lite三、launch 文件配置四、实验效果五、常见问题机器人自主建图有很多方式&#xff0c;比如基于位置边界的map-explore&#xff0c;基于快速搜索树的rrt-explore&#xff0c;指定区域自主探索建图frontier-explore&#xff0c;这几种方法各…
阅读更多...
SQL速查

SQL速查

学习自C语言中文网SQL教程笔记&#xff0c;该笔记为速查笔记&#xff0c;学习还是看原教程文章&#xff1a;http://c.biancheng.net/sql/ SQL命令 SQL 是关系型数据库的标准语言&#xff0c;SQL关键字不区分大小写 SQL语句分为以下三种类型&#xff1a; DML: Data Manipulat…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023