一文入门 Spring Cloud Tencent

Spring Cloud Tencent 是什么

Spring Cloud Tencent 是腾讯开源的一站式微服务解决方案。Spring Cloud Tencent 实现了 Spring Cloud 标准微服务 SPI,开发者可以基于 Spring Cloud Tencent 快速开发 Spring Cloud 微服务架构应用。Spring Cloud Tencent 的核心依托腾讯开源的一站式服务发现与治理平台 Polarismesh ,实现各种分布式微服务场景。

Spring Cloud Tencent 提供的能力包括但不限于:

架构图

一、安装北极星

北极星是腾讯开源的服务发现和治理中心,致力于解决分布式或者微服务架构中的服务可见、故障容错、流量控制和安全问题。虽然,业界已经有些组件可以解决其中一部分问题,但是缺少一个标准的、多语言的、框架无关的实现。

腾讯具有海量的分布式服务,加上业务线和技术栈的多样性,沉淀了大大小小数十个相关组件。从 2019 年开始,我们通过北极星对这些组件进行抽象和整合,打造公司统一的服务发现和治理方案,帮助业务提升研发效率和运营质量。

北极星界面展示

二、服务注册与发现

  • 服务增加 polaris-discovery 依赖
  1. <dependency>
  2. <groupId>com.tencent.cloud</groupId>
  3. <artifactId>spring-cloud-starter-tencent-polaris-discovery</artifactId>
  4. </dependency>
  • application.yaml 接入 polaris server
  1. spring:
  2. cloud:
  3. polaris:
  4. address: grpc://127.0.0.1:8091
  • 启动服务观察 polaris console

  • 服务调用示例
  1. @Bean
  2. @LoadBalanced
  3. public RestTemplate restTemplate() {
  4. return new RestTemplate();
  5. }
  6. @Autowired
  7. private RestTemplate restTemplate;
  8. @GetMapping("/consumer")
  9. public String consumer() {
  10. return restTemplate.getForObject("http://lengleng-tencent-discovery-provider/provider/lengleng", String.class);
  11. }

三、 配置管理

在应用启动 Bootstrap 阶段,Spring Cloud 会调用 PolarisConfigFileLocator 从 Polaris 服务端获取配置文件并加载到 Spring 上下文里。通过 Spring Boot 标准的 @Value@ConfigurationProperties 注解即可获取配置内容。动态配置刷新能力,则通过 Spring Cloud 标准的 @RefreshScope 机制实现。

  • 服务增加 polaris-config 依赖
  1. <dependency>
  2. <groupId>com.tencent.cloud</groupId>
  3. <artifactId>spring-cloud-starter-tencent-polaris-config</artifactId>
  4. </dependency>
  • bootstrap.yaml 接入 polaris-config
  1. spring:
  2. cloud:
  3. polaris:
  4. address: grpc://127.0.0.1:8081
  5. config:
  6. groups:
  7. - name: ${spring.application.name}
  8. files: "application"

特别注意: 这里需要配置在 bootstrap, spring-cloud-tencent 未适配 spring boot 最新的文件加载机制

  • 北极星控制台增加配置

  • 代码使用配置
  1. @Value("${name:}")
  2. private String name;

四、服务限流

服务限流是最常见的一种服务自我保护措施之一,防止流量洪峰打垮服务。Spring Cloud Tencent Rate Limit 模块内置了针对 Spring Web 和 Spring WebFlux 场景的限流 Filter,结合 Polaris 的限流功能帮忙业务快速接入限流能力。

  • 服务增加 polaris-ratelimit 依赖

使用限流组件时添加 discovery ,方便在服务列表编辑

  1. <dependency>
  2. <groupId>com.tencent.cloud</groupId>
  3. <artifactId>spring-cloud-starter-tencent-polaris-discovery</artifactId>
  4. </dependency>
  5. <dependency>
  6. <groupId>com.tencent.cloud</groupId>
  7. <artifactId>spring-cloud-starter-tencent-polaris-ratelimit</artifactId>
  8. </dependency>
  • 服务接入 polaris-ratelimit
  1. spring:
  2. cloud:
  3. polaris:
  4. address: grpc://127.0.0.1:8091
  5. namespace: default
  6. ratelimit:
  7. reject-http-code: 403
  8. reject-request-tips: "lengleng test rate limit"
  • 北极星控制台增加限流规则

五、服务路由

polaris 能够实现的路由形式较多元数据路由、就近路由、规则路由、自定义路由等形式,本文以元数据路由演示,如下图只会路由至相同元数据信息的服务

  • 服务增加 polaris-router 依赖
  1. <dependency>
  2. <groupId>com.tencent.cloud</groupId>
  3. <artifactId>spring-cloud-starter-tencent-polaris-router</artifactId>
  4. </dependency>
  • 服务标记元数据
  1. spring:
  2. cloud:
  3. polaris:
  4. address: grpc://127.0.0.1:8091
  5. tencent:
  6. metadata:
  7. content:
  8. version: local

六、限流熔断

故障实例熔断是常见的一种容错保护机制。故障实例熔断能实现主调方迅速自动屏蔽错误率高或故障的服务实例,并启动定时任务对熔断实例进行探活。在达到恢复条件后对其进行半开恢复。在半开恢复后,释放少量请求去进行真实业务探测。并根据真实业务探测结果去判断是否完全恢复正常。

  • 添加限流熔断相关的依赖 polaris-circuitbreaker
  1. <dependency>
  2. <groupId>com.tencent.cloud</groupId>
  3. <artifactId>spring-cloud-starter-tencent-polaris-circuitbreaker</artifactId>
  4. </dependency>
  5. <dependency>
  6. <groupId>org.springframework.cloud</groupId>
  7. <artifactId>spring-cloud-starter-loadbalancer</artifactId>
  8. </dependency>
  9. <dependency>
  10. <groupId>com.tencent.cloud</groupId>
  11. <artifactId>spring-cloud-starter-tencent-polaris-discovery</artifactId>
  12. </dependency>
  13. <dependency>
  14. <groupId>org.springframework.cloud</groupId>
  15. <artifactId>spring-cloud-circuitbreaker-spring-retry</artifactId>
  16. </dependency>
  17. <dependency>
  18. <groupId>org.springframework.cloud</groupId>
  19. <artifactId>spring-cloud-starter-openfeign</artifactId>
  20. </dependency>
  • 提供 Feign 服务调用实现

spring-cloud-tencent 当前版本仅支持 feign 熔断

  1. @FeignClient(contextId = "demoFeign", value = "lengleng-circuitbreaker-tencent-circuitbreaker-provider",
  2. fallback = DemoFeignFallback.class)
  3. public interface DemoFeign {
  4. @GetMapping("/provider")
  5. String get(@RequestParam String name);
  6. }
  • 服务接入 polaris-circuitbreaker
  1. spring:
  2. cloud:
  3. polaris:
  4. address: grpc://127.0.0.1:8091
  5. #开启断路器
  6. feign:
  7. circuitbreaker:
  8. enabled: true
  • 编写熔断规则 polaris.yml
  1. consumer:
  2. circuitBreaker:
  3. checkPeriod: 100ms
  4. chain:
  5. - errorCount
  6. - errorRate
  7. plugin:
  8. errorCount:
  9. continuousErrorThreshold: 1
  10. metricNumBuckets: 1
  11. errorRate:
  12. errorRateThreshold: 100
  13. metricStatTimeWindow: 1s
  14. requestVolumeThreshold: 1

全文配套源码: https://github.com/lltx/spring-cloud-tencent-demo

本文由mdnice多平台发布


文章标签:

原文连接:https://juejin.cn/post/7111883125818392606

相关推荐

Flask框架——消息闪现

34个图片压缩工具集合,包含在线压缩和CLI工具

入门即享受!coolbpf 硬核提升 BPF 开发效率 | 龙蜥技术

基于 OPLG 从 0 到 1 构建统一可观测平台实践

全链路灰度在数据库上我们是怎么做的?

冴羽答读者问:过程比结果重要吗?如果是,怎么理解?如果不是,又怎么解?

接口文档管理工具,选yapi 还是 Apifox? 这里列出了两款软件的深度分析,看完再下载不迟。

基于 Docker 来部署 Vue 或 React 前端项目及 Node 后端服务

三十岁的我,自由了!

如何实现带timeout的input?

统计千行代码Bug率,有没有意义?

814. 二叉树剪枝 : 简单递归运用题

【综合笔试题】难度 3.5\u002F5,多解法热门二叉树笔试题

为什么设计的软件不好用?那是因为不熟悉软件开发模型!一文熟悉软件开发模型

作为前端,我是这样从零实现CI\u002FCD二(node服务部署及前后端联调)

极智开发 | 讲解 Nginx 特性之一:反向代理

Netty 案例之 IM 方案设计

从 Google 离职,前Go 语言负责人跳槽小公司

最终一致性性分布式事务 TCC

不谈源码,聊聊位运算的实际应用