当前位置:首页 > java技术文章 > Spring Cloud Alibaba使用Sentinel实现接口限流

Spring Cloud Alibaba使用Sentinel实现接口限流的方法

  • 发布时间:
  • 作者:码农之家原创
  • 点击:277

这篇文章主要知识点是关于Spring、Cloud、Alibaba、Sentinel、接口限流、的内容,如果大家想对相关知识点有系统深入的学习,可以参阅以下电子书

Spring Cloud微服务架构开发实战
  • 类型:微服务大小:173.4 MB格式:PDF作者:董超
立即下载

Spring Cloud Alibaba使用Sentinel实现接口限流

最近管点闲事浪费了不少时间,感谢网友 libinwalan 的留言提醒。及时纠正路线,继续跟大家一起学习Spring Cloud Alibaba。

Nacos作为注册中心和配置中心的基础教程,到这里先告一段落,后续与其他结合的内容等讲到的时候再一起拿出来说,不然内容会有点跳跃。接下来我们就来一起学习一下Spring Cloud Alibaba下的另外一个重要组件:Sentinel。

Sentinel是什么

Sentinel的官方标题是:分布式系统的流量防卫兵。从名字上来看,很容易就能猜到它是用来作服务稳定性保障的。对于服务稳定性保障组件,如果熟悉Spring Cloud的用户,第一反应应该就是Hystrix。但是比较可惜的是Netflix已经宣布对Hystrix停止更新。那么,在未来我们还有什么更好的选择呢?除了Spring Cloud官方推荐的resilience4j之外,目前Spring Cloud Alibaba下整合的Sentinel也是用户可以重点考察和选型的目标。

Sentinel的功能和细节比较多,一篇内容很难介绍完整。所以下面我会分多篇来一一介绍Sentinel的重要功能。本文就先从限流入手,说说如何把Sentinel整合到Spring Cloud应用中,以及如何使用Sentinel Dashboard来配置限流规则。通过这个简单的例子,先将这一套基础配置搭建起来。

使用Sentinel实现接口限流

Sentinel的使用分为两部分:

  • sentinel-dashboard:与hystrix-dashboard类似,但是它更为强大一些。除了与hystrix-dashboard一样提供实时监控之外,还提供了流控规则、熔断规则的在线维护等功能。
  • 客户端整合:每个微服务客户端都需要整合sentinel的客户端封装与配置,才能将监控信息上报给dashboard展示以及实时的更改限流或熔断规则等。

下面我们就分两部分来看看,如何使用Sentienl来实现接口限流。

部署Sentinel Dashboard

本文采用的spring cloud alibaba版本是0.2.1,可以查看依赖发现当前版本使用的是sentinel 1.4.0。为了顺利完成本文的内容,建议挑选同版本的sentinel dashboard来使用是最稳妥的。

下载地址: sentinel-dashboard-1.4.0.jar

其他版本: Sentinel/releases

同以往的Spring Cloud教程一样,这里也不推荐大家跨版本使用,不然可能会出现各种各样的问题。

通过命令启动:

java -jar sentinel-dashboard-1.4.0.jar

sentinel-dashboard不像Nacos的服务端那样提供了外置的配置文件,比较容易修改参数。不过不要紧,由于sentinel-dashboard是一个标准的spring boot应用,所以如果要自定义端口号等内容的话,可以通过在启动命令中增加参数来调整,比如: -Dserver.port=8888

默认情况下,sentinel-dashboard以8080端口启动,所以可以通过访问: localhost:8080 来验证是否已经启动成功,如果一切顺利的话,可以看到如下页面:

Spring Cloud Alibaba使用Sentinel实现接口限流

整合Sentinel

第一步:在Spring Cloud应用的 pom.xml 中引入Spring Cloud Alibaba的Sentinel模块:

 <dependencies>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
 </dependency>

 <dependency>
  <groupId>org.projectlombok</groupId>
  <artifactId>lombok</artifactId>
  <version>1.18.2</version>
  <optional>true</optional>
 </dependency>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
 </dependency>
</dependencies>

第二步:在Spring Cloud应用中通过 spring.cloud.sentinel.transport.dashboard 参数配置sentinel dashboard的访问地址,比如:

spring.application.name=alibaba-sentinel-rate-limiting
server.port=8001

# sentinel dashboard
spring.cloud.sentinel.transport.dashboard=localhost:8080

第三步:创建应用主类,并提供一个rest接口,比如:

@SpringBootApplication
public class TestApplication {

 public static void main(String[] args) {
  SpringApplication.run(TestApplication.class, args);
 }

 @Slf4j
 @RestController
 static class TestController {

  @GetMapping("/hello")
  public String hello() {
   return "didispace.com";
  }
 }
}

第四步:启动应用,然后通过postman或者curl访问几下 localhost:8001/hello 接口。

$ curl localhost:8001/hello
didispace.com

此时,在上一节启动的Sentinel Dashboard中就可以当前我们启动的 alibaba-sentinel-rate-limiting 这个服务以及接口调用的实时监控了。具体如下图所示:

Spring Cloud Alibaba使用Sentinel实现接口限流

配置限流规则

在完成了上面的两节之后,我们在 alibaba-sentinel-rate-limiting 服务下,点击 簇点链路 菜单,可以看到如下界面:

Spring Cloud Alibaba使用Sentinel实现接口限流

其中 /hello 接口,就是我们上一节中实现并调用过的接口。通过点击 流控 按钮,来为该接口设置限流规则,比如:

Spring Cloud Alibaba使用Sentinel实现接口限流

这里做一个最简单的配置:

  • 阈值类型选择:QPS
  • 单机阈值:2

综合起来的配置效果就是,该接口的限流策略是每秒最多允许2个请求进入。

点击 新增 按钮之后,可以看到如下界面:

Spring Cloud Alibaba使用Sentinel实现接口限流

其实就是左侧菜单中 流控规则 的界面,这里可以看到当前设置的所有限流策略。

验证限流规则

在完成了上面所有内容之后,我们可以尝试一下快速的调用这个接口,看看是否会触发限流控制,比如:

$ curl localhost:8001/hello
didispace.com
$ curl localhost:8001/hello
didispace.com
$ curl localhost:8001/hello
Blocked by Sentinel (flow limiting)

可以看到,快速的调用两次 /hello 接口之后,第三次调用被限流了。

代码示例

本文介绍内容的客户端代码,示例读者可以通过查看下面仓库中的 alibaba-sentinel-rate-limiting 项目:

Github:https://github.com/dyc87112/SpringCloud-Learning/

Gitee: https://gitee.com/didispace/SpringCloud-Learning/

参考资料

下面是Sentinel的仓库地址与官方文档,读者也可以自己查阅文档学习:

Github
Sentinel官方文档
Spring Cloud Alibaba Sentinel文档

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持码农之家。

以上就是本次给大家分享的关于java的全部知识点内容总结,大家还可以在下方相关文章里找到相关文章进一步学习,感谢大家的阅读和支持。

推荐内容

jQuery遮罩层代码分享

JS策略模式概念与实例用法

webpack4.x下babel的安装、配置及使用的知识点总结

JavaScript按概率随机生成代码整理

PHP中加速、缓存扩展的区别及用法整理

展开 +

收起 -

Spring Cloud 相关电子书
学习笔记
网友NO.681074

Spring-cloud-eureka使用feign调用服务接口

Spring-cloud-eureka使用feign调用服务接口的具体方法,供大家参考,具体内容如下 基于spring-boot 2.0以上版本完成的微服务架构 pom.xml parent groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-parent/artifactId version2.0.5.RELEASE/version relativePath/ !-- lookup parent from repository -- /parent properties project.build.sourceEncodingUTF-8/project.build.sourceEncoding project.reporting.outputEncodingUTF-8/project.reporting.outputEncoding java.version1.8/java.version spring-cloud.versionFinchley.SR1/spring-cloud.version maven.compiler.source1.8/maven.compiler.source maven.compiler.target1.8/maven.compiler.target /properties dependencies dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-starter-netflix-eureka-server/artifactId /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter/artifactId version2.0.5.RELEASE/version /dependency dependency groupIdorg.springframework.cl……

网友NO.417703

详解springcloud 基于feign的服务接口的统一hystrix降级处理

springcloud开发微服务时,基于feign来做声明式服务接口,当启用hystrix服务熔断降级时,项目服务众多,每个Feign服务接口都得写一些重复问的服务降级处理代码,势必显得枯燥无味: Feign服务接口: @FeignClient(name="springcloud-nacos-producer", qualifier="productApiService", contextId="productApiService", fallback=ProductFallbackApiService.class)public interface ProductApiService { /** * 创建商品 * @param product */ @PostMapping(value="/api/product/add", produces=APPLICATION_JSON, consumes=APPLICATION_JSON) public ResultLong createProduct(@RequestBody Product product); /** * 修改商品 * @param product */ @PutMapping(value="/api/product/update", produces=APPLICATION_JSON, consumes=APPLICATION_JSON) public ResultObject updateProduct(@RequestBody Product product); /** * 删除商品 * @param productId */ @DeleteMapping(value="/api/product/delete/{productId}", produces=APPLICATION_JSON) public ResultObject deleteProductB……

<
1
>

电子书 编程教程 文档 软件 源码 视频

Copyright 2018-2020 xz577.com 码农之家

本站所有电子书资源不再提供下载地址,只分享来路

免责声明:网站所有作品均由会员网上搜集共同更新,仅供读者预览及学习交流使用,下载后请24小时内删除

版权投诉 / 书籍推广 / 赞助:QQ:520161757