SpringCloud 集成Sentinel的实战教程

更新时间：2024年08月05日 10:58:46 作者：Dragon Wu

这篇文章主要介绍了SpringCloud 集成Sentinel的详细过程,本文通过实例代码图文相结合给大家介绍的非常详细,感兴趣的朋友一起看看吧

一、Seninel简介

二、Sentinel和Hystrix的区别

三、sentinel可视化界面安装

下载对应版本的sentinel的jar包，通过终端命令：

java -jar jar包名

启动

访问对应路径：控制台如下：

四、在springcloudalibaba中整合sentinel

(1)添加依赖

        <!--sentinel启动器-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>

(2)配置yml

server:
  port: 8002
spring:
  application:
    name: WXL-DEV-SERVICE-2
  cloud:
    sentinel:
      transport:
        dashboard: 127.0.0.1:8080

(3)启动服务，再访问服务后，观察控制台：因为访问接口以后才会注册到sentinel当中。

五、流控规则

(1)实时监控，可用于查看接口访问情况

(2)簇点链路，可以对对应的资源流控降级

可以设置阀值来流控：

(3)QPS流控

可以看到当每秒超过2次时被流控：

流控文字可自定义：

    @GetMapping("/world")
    @SentinelResource(value = "helloWorld",blockHandlerClass = TestController.class,blockHandler = "helloBlock")
    public String helloWorld() {
        return "Hello world";
    }
    public static String helloBlock(BlockException e){
        return "你已被流控";
    }

value将该方法定义为sentinel的资源，blockHandlerClass指明流控处理的类，blockHandler是流控时调用的方法。

这里需要注意处理异常的方法必须是静态方法添加static, 并需要添加sentinel的异常参数BlockException。

统一异常控制处理

上面通过注解实现流控灵活性更高，对于需要统一管理的流控处理，我们可以通过统一异常处理来实现。可以自定义处理不同类型的限流。

只需实现对应接口即可，案例代码如下：

package com.dragonwu.exception;
import com.alibaba.csp.sentinel.adapter.spring.webmvc.callback.BlockExceptionHandler;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.authority.AuthorityException;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeException;
import com.alibaba.csp.sentinel.slots.block.flow.FlowException;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowException;
import com.alibaba.csp.sentinel.slots.system.SystemBlockException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.Map;
@Component
public class MyBlockExceptionHandler implements BlockExceptionHandler {
    @Override
    public void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws Exception {
        System.out.println("BlockExceptioonHandler ++++++++++++++++++++++++++"+e.getRule());
        Map<Integer,String> hashMap=new HashMap<>();
        if(e instanceof FlowException){
            hashMap.put(100,"接口限流了");
        }else if(e instanceof DegradeException){
            hashMap.put(101,"服务降级了");
        }else if(e instanceof ParamFlowException){
            hashMap.put(102,"热点参数限流了");
        }else if(e instanceof SystemBlockException){
            hashMap.put(103,"触发系统保护规则了");
        }else if(e instanceof AuthorityException){
            hashMap.put(104,"授权规则不通过");
        }
        //返回json数据
        httpServletResponse.setStatus(500);
        httpServletResponse.setCharacterEncoding("utf-8");
        httpServletResponse.setContentType(MediaType.APPLICATION_JSON_VALUE);
        new ObjectMapper().writeValue(httpServletResponse.getWriter(),hashMap);
    }
}

(4)线程流控

(5)关联限流

这里的意思是如果/hello/add接口一秒钟之内访问超过2次，则/hello/query会被限流。

(6)熔断降级

也要设置熔断时长，熔断时长过完之后会进入半开状态，即若下一次请求为慢请求则再次熔断，直到第一次请求不是慢请求才会恢复正常状态。

六、OpenFeign整合Sentinel

(1)导入依赖：

        <!--OpenFeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

(2)调用者开发整合配置：

feign:
  sentinel:
    enabled: true #开启openFeign对sentinel的整合

（3）添加openFeign调用接口

package com.wxl.feign;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
@FeignClient(name = "WXL-DEV-SERVICE-2", path = "/hello",fallback = ServiceFailFeign.class)
public interface Service1HelloInterface {
    @GetMapping("/world")
    String helloWorld();
}

并且这里添加参数fallback值为失败时回调的实现类。

实现类如下:

package com.wxl.feign;
import org.springframework.stereotype.Component;
@Component
public class ServiceFailFeign implements Service1HelloInterface{
    public String helloWorld() {
        return "降级了！！！";
    }
}

当接口请求失败时便会调用失败类里的该方法。

这里我们为了使用效果，在服务生产者的接口里故意写入报错代码：

    @GetMapping("/world")
    public String helloWorld() {
        int i=1/0;
        return "Hello world";
    }

请求该消费者服务接口：

调用了失败回调方法！

七、规则持久化

(1)引入依赖

        <!--sentinel持久化存储-->
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>

(2)为nacos添加配置

更多见：

sentinel配置持久化到nacos

到此这篇关于SpringCloud 集成Sentinel的文章就介绍到这了,更多相关SpringCloud 集成Sentinel内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

如何基于mybatis框架查询数据库表数据并打印
这篇文章主要介绍了如何基于mybatis框架查询数据库表数据并打印,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-11-11
JDK8安装与配置实践超详细指南
本文详细介绍了在Windows 64位系统上安装和配置JDK8的步骤,包括JDK8下载、环境变量设置及安装验证,同时提供了JDK8新特性如Lambda表达式、StreamAPI等的概览,旨在帮助Java开发者有效利用JDK8新特性进行开发,需要的朋友可以参考下
2024-10-10
springboot启动扫描不到dao层接口的解决方案
这篇文章主要介绍了springboot启动扫描不到dao层接口的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-07-07
SpringBoot入门实现第一个SpringBoot项目
今天我们一起来完成一个简单的SpringBoot(Hello World)。就把他作为你的第一个SpringBoot项目。具有一定的参考价值，感兴趣的可以了解一下
2021-09-09
Java多线程实现简易微信发红包的方法实例
这篇文章主要给大家介绍了关于Java多线程实现简易微信发红包的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-01-01
MyBatis XPathParser解析器使用范例详解
这篇文章主要介绍了关于MyBatis中解析器XPathParser的实际使用实践，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2022-07-07
Java微服务分布式调度Elastic-job环境搭建及配置
Elastic-Job在配置中提供了JobEventConfiguration，支持数据库方式配置，会在数据库中自动创建JOB_EXECUTION_LOG和JOB_STATUS_TRACE_LOG两张表以及若干索引，来记录作业的相关信息
2023-02-02
一篇文章教你如何用Java自定义一个参数校验器
这篇文章主要介绍了使用java自定义一个参数校验器，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习
2021-09-09
解析SpringCloud简介与微服务架构
这篇文章主要介绍了SpringCloud简介与微服务架构,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-01-01
解决springboot无法注入JpaRepository的问题
这篇文章主要介绍了解决springboot无法注入JpaRepository的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2021-01-01