SpringCloud Alibaba - Sentinel 高级玩法,修改 Sentinel-dashboard 源码,实现 push 模式

news2024/11/25 18:39:54

目录

一、规则持久化

1.1、什么是规则持久化

1.1.1、使用背景

1.1.2、规则管理的三种模式

a)原始模式

b)pull 模式

c)push 模式

1.2、实现 push 模式

1.2.1、修改 order-service 服务,使其监听 Nacos 配置中心

1.2.2、修改 Sentinel-dashboard 源码,配置 nacos 数据源

1.2.3、修改 Sentinel-dashboard 源码,修改前端页面

1.2.4、重新编译、打包-dashboard源码

1.2.5、启动


一、规则持久化


1.1、什么是规则持久化

1.1.1、使用背景

前面我们学习了 Sentinel 中的常用玩法,但是在使用的过程中发现一个问题,就是每当我们的服务重启的时候,在 sentinel 控制台上配置的各种规则就都丢失了.  这是因为 sentinel 默认会把这些规则保存到内存中,重启自然就丢失了.  在生产环境中,肯定是不能容忍这种情况的.

通过 sentinel 的规则持久化就可解决这个问题.

1.1.2、规则管理的三种模式

a)原始模式

原始模式就是 sentinel 默认模式,这种模式下,sentinel 会把规则保存在内存中,一旦重启自然就丢失了.

b)pull 模式

在实际的开发当中,微服务一定是一个集群,那么在 Dashboard 中编写规则的时候,会把这个规则推送给微服务中 Sentinel 客户端,然后他会把这个规则先更新到内存中,然后持久化到 本地文件 或者 数据库 中.

那怎么知道这个规则有没有变化呢?

这里我们的微服务会定时轮询 文件 或者 数据库,当监听到 数据库 或者 文件 的内容发生改变的时候,就知道规则更新了,那么就可以去去更新缓存中的数据.

 缺陷

1. 时效性差:抛开硬盘的读取速度不说,他是定时的啊,就会导致数据库中的数据变化了,而缓存中的数据还没变化.  此时去读取缓存中的数据可能就是无效数据.

c)push 模式

push 模式中 Sentinel Dashboard 并不会把规则推送给任意一个 Sentinel 客户端,而是把这个规则保到远程的一个配置中心.

比如说 nacos ,微服务可以去监听 nacos,一旦发现变化,就立即更新这些数据到 Sentinel 客户端(说明 push 模式是实时更新的).

缺陷

实现起来比较复杂,还需要进行源码的修改

 

1.2、实现 push 模式

1.2.1、修改 order-service 服务,使其监听 Nacos 配置中心

在order-service中引入sentinel监听nacos的依赖:

<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>

在order-service中的application.yml文件配置nacos地址及监听的配置信息:

spring:
  cloud:
    sentinel:
      datasource:
        flow:
          nacos:
            server-addr: localhost:8848 # nacos地址
            dataId: orderservice-flow-rules
            groupId: SENTINEL_GROUP
            rule-type: flow # 还可以是:degrade、authority、param-flow

 

1.2.2、修改 Sentinel-dashboard 源码,配置 nacos 数据源

从 github 上下载 Sentinel 源码包,进行解压,然后用 IDEA 打开

修改 sentinel-dashboard 源码的 pom 文件,将 sentinel-datasource-nacos 依赖的 scope 去掉

1.2.3、修改 Sentinel-dashboard 源码,修改前端页面

a)拷贝 test 目录下的 nacos 代码到 main 下的 com.alibaba.csp.sentinel.dashboard.rule 包:

b)修改刚刚拷贝的 nacos 包下的 NacosConfig 类,修改其中的nacos地址:

import java.util.List;

import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.FlowRuleEntity;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.api.config.ConfigFactory;
import com.alibaba.nacos.api.config.ConfigService;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author Eric Zhao
 * @since 1.4.0
 */
@Configuration
public class NacosConfig {

    @Bean
    public Converter<List<FlowRuleEntity>, String> flowRuleEntityEncoder() {
        return JSON::toJSONString;
    }

    @Bean
    public Converter<String, List<FlowRuleEntity>> flowRuleEntityDecoder() {
        return s -> JSON.parseArray(s, FlowRuleEntity.class);
    }

    @Bean
    public ConfigService nacosConfigService() throws Exception {
        return ConfigFactory.createConfigService("localhost:8848");
    }
}

c)修改 com.alibaba.csp.sentinel.dashboard.controller.v2 包下的 FlowControllerV2 类:

将以下代码:

    @Autowired
    @Qualifier("flowRuleDefaultProvider")
    private DynamicRuleProvider<List<FlowRuleEntity>> ruleProvider;
    @Autowired
    @Qualifier("flowRuleDefaultPublisher")
    private DynamicRulePublisher<List<FlowRuleEntity>> rulePublisher;

修改为:

    @Autowired
    @Qualifier("flowRuleNacosProvider")
    private DynamicRuleProvider<List<FlowRuleEntity>> ruleProvider;
    @Autowired
    @Qualifier("flowRuleNacosPublisher")
    private DynamicRulePublisher<List<FlowRuleEntity>> rulePublisher;

d)修改 src/main/webapp/resources/app/scripts/directives/sidebar/ 目录下的 sidebar.html 文件

将其中的这部分注释打开:

          <!--<li ui-sref-active="active" ng-if="entry.appType==0">-->
            <!--<a ui-sref="dashboard.flow({app: entry.app})">-->
              <!--<i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则 V1</a>-->
          <!--</li>-->

修改其中的文本:

          <li ui-sref-active="active" ng-if="entry.appType==0">
            <a ui-sref="dashboard.flow({app: entry.app})">
              <i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则 Nacos</a>
          </li>

1.2.4、重新编译、打包-dashboard源码

运行IDEA中的maven插件,编译和打包修改好的 Sentinel-Dashboard(记得去掉单元测试).

1.2.5、启动

通过以下命令,修改 nacos 地址并启动.

java -jar -Dnacos.addr=localhost:8848 sentinel-dashboard.jar

打开 Sentinel 客户端就可以看到这里多出了一个 流控规则.  在这上面配置的规则就不会随着服务的重启而消失.

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

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

相关文章

基于SpringBoot+Vue的企业信息反馈平台

1 简介 企业客户信息反馈的需求和管理上的不断提升&#xff0c;企业客户信息反馈管理的潜力将无限扩大&#xff0c;企业客户信息反馈平台在业界被广泛关注&#xff0c;本平台及对此进行总体分析&#xff0c;将企业客户信息反馈信息管理的发展提供参考。企业客户信息反馈平台对企…

【多任务案例:猫狗脸部定位与分类】

【猫狗脸部定位与识别】 1 引言2 损失函数3 The Oxford-IIIT Pet Dataset数据集4 数据预处理4 创建模型输入5 自定义数据集加载方式6 显示一批次数据7 创建定位模型8 模型训练9 绘制损失曲线10 模型保存与预测 1 引言 猫狗脸部定位与识别分为定位和识别&#xff0c;即定位猫狗…

批量导入、筛选与删除,文件改名从未如此简单!

您是否曾经为了给文件夹中的文件批量改名而感到烦恼&#xff1f;现在&#xff0c;有了我们的文件批量改名工具&#xff0c;这些问题都将成为过去&#xff01; 第一步&#xff0c;我们打开需要改名文件夹&#xff0c;可以看到里面文件名很多&#xff0c;很乱。 第二步进入文件批…

Acwing 844. 走迷宫

Acwing 844. 走迷宫 知识点题目描述思路讲解代码展示 知识点 BFS 题目描述 思路讲解 宽搜可以搜到最短路径&#xff1a; 代码展示 #include <cstring> #include <iostream> #include <algorithm> #include <queue>using namespace std;typedef pa…

传输层协议—UDP协议

传输层协议—UDP协议 文章目录 传输层协议—UDP协议传输层再谈端口号端口号范围划分pidofnetstat UDP协议端格式UDP报文UDP特点UDP缓冲区基于UDP的应用层协议 传输层 在学习HTTP/HTTPS等应用层协议时&#xff0c;为了方便理解&#xff0c;可以简单认为HTTP将请求和响应直接发送…

基于Java的图书个性化推荐系统设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作…

基于Java的校园失物招领平台设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作…

E. Mishap in Club

题目&#xff1a; 样例1&#xff1a; 输入 --输出 1 样例2&#xff1a; 输入 --- 输出 3 思路&#xff1a; 数学贪心模拟思路&#xff0c;由于不知道在俱乐部的人数和在外面的人数&#xff0c;又要尽可能少的人数&#xff0c;那么定义两个变量&#xff0c;一个是里面的人数 i…

Python中使用IDLE调试程序

在IDLE中&#xff0c;使用菜单栏中的“Debug”对IDLE打开的python程序进行调试。 1 打开调试开关 选择IDLE菜单栏的“Debug->Debugger”&#xff0c;如图1①所示&#xff1b;此时在IDLE中会显示“[DEBUG ON]”&#xff0c;即“调试模式已打开”&#xff0c;如图1②所示&am…

JMeter学习第三天+

性能测试前言 老师开局一句话&#xff1a;性能测试和你会不会JMeter一点关系没有…… 作者坚持技多不压身的原则&#xff0c;还是多学一点JMeter吧&#xff0c;看老师到底要怎么讲下去&#xff0c;什么并发量、吞吐量啥的…… 性能测试的核心思想&#xff1a;在于创造大量并发去…

16,8和4位浮点数是如何工作的

50年前Kernighan、Ritchie和他们的C语言书的第一版开始&#xff0c;人们就知道单精度“float”类型有32位大小&#xff0c;双精度类型有64位大小。还有一种具有扩展精度的80位“长双精度”类型&#xff0c;这些类型几乎涵盖了浮点数据处理的所有需求。但是在最近几年&#xff0…

Javase ------> 泛型

Jdk自从5.0后引入泛型之后一直没有删除,而且在我们的集合框架中进场能使用的到,今天我们就详细介绍一下泛型的一些特性和使用须知,希望能对你的编程学习带来一些帮助. 1.什么是泛型 泛型&#xff0c;即“参数化类型”。一提到参数&#xff0c;最熟悉的就是定义方法时有形参&…

c# 中的类

反射 Activator.CreateInstance class Program {static void Main(string[] args){//反射Type t typeof(Student);object o Activator.CreateInstance(t, 1, "FJ");Student stu o as Student;Console.WriteLine(stu.Name);//动态编程dynamic stu2 Activator.Cre…

【算法】二分相关题目

文章目录 二分相关二分查找在排序数组中查找元素的第一个和最后一个位置寻找峰值x 的平方根0~n-1中缺失的数字## 搜索插入位置 二分相关 二分查找 https://leetcode.cn/problems/binary-search/ 在一个有序数组当中&#xff0c;查找值为target的元素&#xff0c;返回下标 cla…

SSM - Springboot - MyBatis-Plus 全栈体系(十七)

第三章 MyBatis 五、MyBatis 高级扩展 1. mapper 批量映射优化 1.1 需求 Mapper 配置文件很多时&#xff0c;在全局配置文件中一个一个注册太麻烦&#xff0c;希望有一个办法能够一劳永逸。 1.2 配置方式 Mybatis 允许在指定 Mapper 映射文件时&#xff0c;只指定其所在的…

2023年中国家用智能门锁市场发展概况分析:家用智能门锁线上市场销量290.4万套[图]

智能门锁是指区别于传统机械锁的基础上改进的&#xff0c;在用户安全性、识别、管理性方面更加智能化简便化的锁具。智能门锁是门禁系统中锁门的执行部件。智能门锁区别于传统机械锁, 是具有安全性, 便利性, 先进技术的复合型锁具。 智能门锁级别分类 资料来源&#xff1a;共研…

MARS: An Instance-aware, Modular and Realistic Simulator for Autonomous Driving

● MARS: An Instance-aware, Modular and Realistic Simulator for Autonomous Driving&#xff08;基于神经辐射场的自动驾驶仿真器&#xff09; ● https://github.com/OPEN-AIR-SUN/mars ● https://arxiv.org/pdf/2307.15058.pdf ● https://mp.weixin.qq.com/s/6Ion_DZGJ…

flink处理函数--副输出功能

背景 在flink中&#xff0c;如果你想要访问记录的处理时间或者事件时间&#xff0c;注册定时器&#xff0c;或者是将记录输出到多个输出流中&#xff0c;你都需要处理函数的帮助&#xff0c;本文就来通过一个例子来讲解下副输出 副输出 本文还是基于streaming-with-flink这本…

解决SpringBoot Configuration Annotation Processor not configured

版权声明 本文原创作者&#xff1a;谷哥的小弟作者博客地址&#xff1a;http://blog.csdn.net/lfdfhl 问题描述 在使用ConfigurationProperties注解和EnableConfigurationProperties注解时&#xff0c;IDEA报错&#xff1a;SpringBoot Configuration Annotation Processor no…