SpringMvc集成开源流量监控、限流、熔断降级、负载保护组件Sentinel | 京东云技术团队
前言:作者查阅了Sentinel官网、51CTO、CSDN、码农家园、博客园等很多技术文章都没有很准确的springmvc集成Sentinel的示例,因此整理了本文,主要介绍SpringMvc集成Sentinel
SpringMvc集成Sentinel
一、Sentinel 介绍
随着微服务的流行,服务和服务之间的稳定性变得越来越重要。Sentinel 是面向分布式、多语言异构化服务架构的流量治理组件,主要以流量为切入点,从流量路由、流量控制、流量整形、熔断降级、系统自适应过载保护、热点流量防护等多个维度来帮助开发者保障微服务的稳定性。
GitHub主页:https://github.com/alibaba/Sentinel
中文文档:https://sentinelguard.io/zh-cn/docs/introduction.html
控制台文档:https://sentinelguard.io/zh-cn/docs/dashboard.html
核心类解析:https://github.com/alibaba/Sentinel/wiki/Sentinel-%E6%A0%B8%E5%BF%83%E7%B1%BB%E8%A7%A3%E6%9E%90
Sentinel示例项目:https://github.com/alibaba/Sentinel/tree/master/sentinel-demo
https://github.com/alibaba/spring-cloud-alibaba/tree/master/spring-cloud-alibaba-examples/sentinel-example
二、Sentinel 基本概念
资源
资源是 Sentinel 的关键概念。它可以是 Java 应用程序中的任何内容,例如,由应用程序提供的服务,或由应用程序调用的其它应用提供的服务,甚至可以是一段代码。在接下来的文档中,我们都会用资源来描述代码块。
只要通过 Sentinel API 定义的代码,就是资源,能够被 Sentinel 保护起来。大部分情况下,可以使用方法签名,URL,甚至服务名称作为资源名来标示资源。
规则
围绕资源的实时状态设定的规则,可以包括流量控制规则、熔断降级规则以及系统保护规则。所有规则可以动态实时调整。
三、springMVC集成Sentinel
这里用的是spring
<spring.version>5.3.18</spring.version>
<servlet.api.version>2.5</servlet.api.version> <sentinel.version>1.8.6</sentinel.version>
1、springmvc项目引入依赖pom
<!-- 这是sentinel的核心依赖 --> <dependency> <groupId>com.alibaba.csp</groupId> <artifactId>sentinel-core</artifactId> <version>${sentinel.version}</version> </dependency> <!-- 这是将自己项目和sentinel-dashboard打通的依赖 --> <dependency> <groupId>com.alibaba.csp</groupId> <artifactId>sentinel-transport-simple-http</artifactId> <version>${sentinel.version}</version> </dependency> <!-- 这是使用sentinel对限流资源进行AOP --> <dependency> <groupId>com.alibaba.csp</groupId> <artifactId>sentinel-annotation-aspectj</artifactId> <version>${sentinel.version}</version> </dependency> <!--这是使用sentinel适配Web Servlet的依赖--> <dependency> <groupId>com.alibaba.csp</groupId> <artifactId>sentinel-web-servlet</artifactId> <version>${sentinel.version}</version> </dependency> <!-- 这是使用sentinel热点参数限流功能依赖 --> <dependency> <groupId>com.alibaba.csp</groupId> <artifactId>sentinel-parameter-flow-control</artifactId> <version>${sentinel.version}</version> </dependency>
2、添加配置文件
在application.properties下创建同级文件sentinel.properties,内容如下
# 集成到sentinel的项目名称 project.name=spring-sentinel-demo # 对应的sentinel-dashboard地址 csp.sentinel.dashboard.server=localhost:8080
3、添加配置类引入配置文件
创建配置类SentinelAspectConfiguration并引入配置文件sentinel.properties
import com.alibaba.csp.sentinel.annotation.aspectj.SentinelResourceAspect; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.context.annotation.PropertySources; @Configuration @PropertySources({@PropertySource("classpath:/sentinel.properties")}) public class SentinelAspectConfiguration { @Bean public SentinelResourceAspect sentinelResourceAspect() { return new SentinelResourceAspect(); } }
4、web.xml新增如下过滤器配置
<filter> <filter-name>SentinelCommonFilter</filter-name> <filter-class>com.alibaba.csp.sentinel.adapter.servlet.CommonFilter</filter-class> </filter> <filter-mapping> <filter-name>SentinelCommonFilter</filter-name> <url-pattern>/*</url-pattern> </filter-mapping>
接入 filter 之后,所有访问的 Web URL 就会被自动统计为 Sentinel 的资源---来源于 https://sentinelguard.io/zh-cn/docs/open-source-framework-integrations.html
开源框架适配的Web 适配下的Web Servlet
5、创建Controller接口
@Controller public class WebMvcTestController { @GetMapping("/hello") @ResponseBody public String apiHello(String id) { System.out.println("id = " + id); Date date = new Date(); System.out.println("date = " + date); return "Hello!"; } @GetMapping("/doBusiness") @ResponseBody public String doBusiness(String id) { System.out.println("doBusiness = "); return "Oops..."; } }
6、下载控制台-即图形化实时监控平台
参考 https://sentinelguard.io/zh-cn/docs/dashboard.html Sentinel 控制台的下载和启动
访问 https://github.com/alibaba/Sentinel/releases/tag/1.8.6
点击下载
7、运行控制台
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
运行控制台后运行springmvc项目,然后访问某一个路径,就可以在控制台看到了,实时监控如果这个路径没有被访问是显示不出来的
这个时候我们配置限流为即Qps为2
8、测试限流
这里我们用postman进行压测,填写请求的路径保存。并点击run调出压测执行器
执行后查看结果如下
四、自定义异常返回
1、定义如下接口(这里只进行了常见的url定义方式的定义)
import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.*; @Controller @RequestMapping("/test") public class WebMvcTestController { /** * 1.未配置流控规则 1000次请求没有间隔发起请求,应该在1秒中完成09:44:33 * @param id * @return */ @RequestMapping("/RequestMapping") @ResponseBody public String RequestMapping(String id) { return "RequestMapping!"; } @GetMapping("/GetMapping") @ResponseBody public String GetMapping(String id) { return "GetMapping..."; } @PostMapping("/PostMapping") @ResponseBody public String PostMapping(String id) { return "PostMapping..."; } /* * 路径变量(Path Variables):使用花括号 {} 来标记路径中的变量,并通过 @PathVariable 注解将其绑定到方法参数上 * */ @GetMapping("/GetMapping/{id}") @ResponseBody public String apiFoo(@PathVariable("id") Long id) { return "Hello " + id; } /* * Ant风格的路径匹配: * 使用 ? 表示任意单个字符, * * 表示任意多个字符(不包含路径分隔符 /), * ** 表示任意多个字符(包含路径分隔符 /)。 * */ @GetMapping("/Ant/*/{id}") @ResponseBody public String Ant(@PathVariable("id") Long id) { return "Ant " + id; } /* * 正则表达式路径匹配:使用 @RequestMapping 注解的 value 属性结合正则表达式来定义请求路径。 * */ @GetMapping(value = "/users/{id:\\d+}") @ResponseBody public String pattern(@PathVariable("id") int id) { return "Ant " + id; } }
2、自定义限流返回处理Handler
import com.alibaba.csp.sentinel.adapter.servlet.callback.UrlBlockHandler; 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.alibaba.fastjson.JSON; import org.springframework.context.ApplicationContext; import org.springframework.web.method.HandlerMethod; import org.springframework.web.servlet.mvc.condition.PatternsRequestCondition; import org.springframework.web.servlet.mvc.method.RequestMappingInfo; import org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping; import org.springframework.web.util.UrlPathHelper; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.util.*; public class SentinelExceptionHandler implements UrlBlockHandler { @Override public void blocked(HttpServletRequest request, HttpServletResponse httpServletResponse, BlockException e) throws IOException { String contextPath = request.getContextPath(); String servletPath = request.getServletPath(); String requestURI = request.getRequestURI(); String url = request.getRequestURL().toString(); System.out.println("servletPath = " + servletPath); System.out.println("requestURI = " + requestURI); System.out.println("url = " + url); if (contextPath == null) { contextPath = ""; } ApplicationContext controllerApplicationContext = LiteFlowApplicationContext.getControllerApplicationContext(); RequestMappingHandlerMapping handlerMapping = controllerApplicationContext.getBean(RequestMappingHandlerMapping.class); // 查找匹配的处理方法 Class<?> returnType = null; Map<RequestMappingInfo, HandlerMethod> handlerMethods = handlerMapping.getHandlerMethods(); for (Map.Entry<RequestMappingInfo, HandlerMethod> entry : handlerMethods.entrySet()) { RequestMappingInfo requestMappingInfo = entry.getKey(); HandlerMethod handlerMethod = entry.getValue(); //匹配url if (requestMappingInfo.getPatternsCondition().getPatterns().contains(requestURI)) { System.out.println("Controller: " + handlerMethod.getBeanType().getName()); System.out.println("Method: " + handlerMethod.getMethod().getName()); System.out.println("getReturnType: " + handlerMethod.getMethod().getReturnType()); returnType = handlerMethod.getMethod().getReturnType(); break; } //匹配路径带参数的url UrlPathHelper pathHelper = new UrlPathHelper(); String lookupPath = pathHelper.getPathWithinApplication(request); PatternsRequestCondition patternsCondition = requestMappingInfo.getPatternsCondition(); if (patternsCondition != null && patternsCondition.getMatchingPatterns(lookupPath).size() > 0) { System.out.println("Controller1111: " + handlerMethod.getBeanType().getName()); System.out.println("Method111: " + handlerMethod.getMethod().getName()); System.out.println("getReturnType: " + handlerMethod.getMethod().getReturnType()); returnType = handlerMethod.getMethod().getReturnType(); break; } } httpServletResponse.setContentType("application/json;charset=utf-8"); ResponseData data = null; if (returnType != null) { if (returnType == String.class) { String str = "返回类型为字符串方法限流"; httpServletResponse.getWriter().write(str); return; } else if (returnType == Integer.class) { httpServletResponse.getWriter().write(new Integer(1)); return; } else if (returnType == Long.class) { httpServletResponse.getWriter().write(2); return; } else if (returnType == Double.class) { } else if (returnType == Boolean.class) { } else if (returnType == Float.class) { } else if (returnType == Byte.class) { } } //BlockException 异常接口,包含Sentinel的五个异常 // FlowException 限流异常 // DegradeException 降级异常 // ParamFlowException 参数限流异常 // AuthorityException 授权异常 // SystemBlockException 系统负载异常 if (e instanceof FlowException) { data = new ResponseData(-1, "流控规则被触发......"); } else if (e instanceof DegradeException) { data = new ResponseData(-2, "降级规则被触发..."); } else if (e instanceof AuthorityException) { data = new ResponseData(-3, "授权规则被触发..."); } else if (e instanceof ParamFlowException) { data = new ResponseData(-4, "热点规则被触发..."); } else if (e instanceof SystemBlockException) { data = new ResponseData(-5, "系统规则被触发..."); } httpServletResponse.getWriter().write(JSON.toJSONString(data)); } }
3、使用自定义限流处理类
import com.alibaba.csp.sentinel.adapter.servlet.callback.WebCallbackManager; import org.springframework.context.annotation.Configuration; @Configuration public class SentinelConfig { public SentinelConfig() { WebCallbackManager.setUrlBlockHandler(new SentinelExceptionHandler()); } }
4、配置限流并测试结果
当开启限流后访问触发自定义UrlBlockHandler后结果如下
访问对应得url后控制台打印
servletPath = /test/RequestMapping requestURI = /test/RequestMapping url = http://localhost:8081/test/RequestMapping Controller: org.example.WebMvcTestController Method: RequestMapping getReturnType: class java.lang.String servletPath = /test/GetMapping requestURI = /test/GetMapping url = http://localhost:8081/test/GetMapping Controller: org.example.WebMvcTestController Method: GetMapping getReturnType: class java.lang.String servletPath = /test/PostMapping requestURI = /test/PostMapping url = http://localhost:8081/test/PostMapping Controller: org.example.WebMvcTestController Method: PostMapping getReturnType: class java.lang.String servletPath = /test/GetMapping/4 requestURI = /test/GetMapping/4 url = http://localhost:8081/test/GetMapping/4 Controller1111: org.example.WebMvcTestController Method111: apiFoo getReturnType: class java.lang.String servletPath = /test/Ant/a/5 requestURI = /test/Ant/a/5 url = http://localhost:8081/test/Ant/a/5 Controller1111: org.example.WebMvcTestController Method111: Ant getReturnType: class java.lang.String servletPath = /test/users/5 requestURI = /test/users/5 url = http://localhost:8081/test/users/5 Controller1111: org.example.WebMvcTestController Method111: pattern getReturnType: class java.lang.String
5、页面效果如下
五、springboot集成Sentinel
因为springboot集成文章较多,这里不多做赘述
Sentinel 与 Spring Boot/Spring Cloud 的整合见 Sentinel Spring Cloud Starter。
作者:京东健康 马仁喜
来源:京东云开发者社区 转载请注明来源

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
Go 语言微服务框架重磅升级:dubbo-go v3.2.0 -alpha 版本预览
随着 Dubbo3 在云原生微服务方向的快速发展,Dubbo 的 go 语言实现迎来了 Dubbo3 版本以来最全面、最大幅度的一次升级,这次升级是全方位的,涉及 API、协议、流量管控、可观测能力等。总的来说,新版本的 dubbo-go: 全面升级 Triple 协议,兼容 gRPC、标准 HTTP 客户端,提供简单明了的 API 用于编写 RPC server 与 client,解决组件间的基本通信问题。 针对微服务场景,提供了完善的服务治理能力,这包括配置管理、可观测性、流量管控规则、生态集成与适配等的全面升级。 全新升级的 Triple 协议 基于 dubbo-go 实现的 Triple 协议,你可以轻松编写浏览器、gRPC 兼容的 RPC 服务,并让这些服务同时运行在 HTTP/1 和 HTTP/2 上。 如上图所示,你可以使用 "http+json" 的标准形式访问 dubbo-go 发布的后端 triple 服务,基于这一特性, 我们可以在 dubbo 客户端在浏览器页面、移动设备上访问后端服务,使用标准 cURL 工具访问服务,也可以让比如 Spring 体系的应用轻松...
- 下一篇
机器学习 - 似然函数:概念、应用与代码实例
本文深入探讨了似然函数的基础概念、与概率密度函数的关系、在最大似然估计以及机器学习中的应用。通过详尽的定义、举例和Python/PyTorch代码示例,文章旨在提供一个全面而深入的理解。 关注TechLead,分享AI全维度知识。作者拥有10+年互联网服务架构、AI产品研发经验、团队管理经验,同济本复旦硕,复旦机器人智能实验室成员,阿里云认证的资深架构师,项目管理专业人士,上亿营收AI产品研发负责人。 一、概要 在机器学习和统计学领域中,似然函数(Likelihood Function)是一个至关重要的概念。它不仅是参数估计的基础,而且在模型选择、模型评估以及众多先进的算法和技术中都有着广泛的应用。本文旨在全面但深入地探讨似然函数,从其基本定义和性质到在不同机器学习问题中的具体应用。 文章将首先介绍似然函数与概率密度函数的关系,然后通过最大似然估计(Maximum Likelihood Estimation, MLE)来展示如何利用似然函数进行参数估计。接着,我们会探讨似然函数在分类问题和回归问题中的应用,并使用Python和PyTorch代码段进行示例演示。 为了保持文章的技术深度,...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- Mario游戏-低调大师作品
- CentOS8安装Docker,最新的服务器搭配容器使用
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS8编译安装MySQL8.0.19
- SpringBoot2配置默认Tomcat设置,开启更多高级功能