SpringCloud Tencent 全套解决方案源码分析

更新时间：2022年07月04日 10:28:12 作者：叶秋学长

Spring Cloud Tencent实现Spring Cloud标准微服务SPI，开发者可以基于Spring Cloud Tencent开发Spring Cloud微服务架构应用，Spring Cloud Tencent 的核心依托腾讯开源的一站式服务发现与治理平台 Polarismesh，实现各种分布式微服务场景，感兴趣的朋友一起看看吧

Spring Cloud Tencent 是什么？

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

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

项目地址：https://github.com/Tencent/spring-cloud-tencent

项目源码地址

https://github.com/lltx/spring-cloud-tencent-demo

一、安装北极星

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

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

北极星安装非常的简单下载响应平台的 zip 直接运行即可，下载地址：https://github.com/polarismesh/polaris/releases/tag/v1.9.0

二、服务注册与发现

服务增加 polaris-discovery 依赖

<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>spring-cloud-starter-tencent-polaris-discovery</artifactId>
</dependency>

application.yaml 接入 polaris server

spring:
  cloud:
    polaris:
      address: grpc://127.0.0.1:8091

启动服务观察 polaris console

服务调用示例

@Bean
@LoadBalanced
public RestTemplate restTemplate() {
  return new RestTemplate();
}
 
@Autowired
private RestTemplate restTemplate;
 
@GetMapping("/consumer")
public String consumer() {
  return restTemplate.getForObject("http://lengleng-tencent-discovery-provider/provider/lengleng", String.class);
}

三、配置管理

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

服务增加 polaris-config 依赖

<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>spring-cloud-starter-tencent-polaris-config</artifactId>
</dependency>

bootstrap.yaml 接入 polaris-config

spring:
  cloud:
    polaris:
      address: grpc://127.0.0.1:8081
      config:
        groups:
          - name: ${spring.application.name}
            files: "application"

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

北极星控制台增加配置

代码使用配置

@Value("${name:}")
private String name;

四、服务限流

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

服务增加 polaris-ratelimit 依赖，使用限流组件时添加 discovery ,方便在服务列表编辑

<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>spring-cloud-starter-tencent-polaris-discovery</artifactId>
</dependency>
<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>spring-cloud-starter-tencent-polaris-ratelimit</artifactId>
</dependency>

服务接入 polaris-ratelimit

spring:
  cloud:
    polaris:
      address: grpc://127.0.0.1:8091
      namespace: default
      ratelimit:
        reject-http-code: 403
        reject-request-tips: "lengleng test rate limit"

北极星控制台增加限流规则

五、服务路由

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

服务增加 polaris-router 依赖

<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>spring-cloud-starter-tencent-polaris-router</artifactId>
</dependency>

服务标记元数据

spring:
  cloud:
    polaris:
      address: grpc://127.0.0.1:8091
    tencent:
      metadata:
        content:
          version: local

六、限流熔断

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

添加限流熔断相关的依赖 polaris-circuitbreaker

<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>spring-cloud-starter-tencent-polaris-circuitbreaker</artifactId>
</dependency>
 
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
 
<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>spring-cloud-starter-tencent-polaris-discovery</artifactId>
</dependency>
 
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-circuitbreaker-spring-retry</artifactId>
</dependency>
 
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

提供 Feign 服务调用实现

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

@FeignClient(contextId = "demoFeign", value = "lengleng-circuitbreaker-tencent-circuitbreaker-provider",
  fallback = DemoFeignFallback.class)
public interface DemoFeign {
 @GetMapping("/provider")
 String get(@RequestParam String name);
 
}

服务接入 polaris-circuitbreaker

spring:
  cloud:
    polaris:
      address: grpc://127.0.0.1:8091
#开启断路器
feign:
  circuitbreaker:
    enabled: true

编写熔断规则 polaris.yml

consumer:
  circuitBreaker:
    checkPeriod: 100ms
    chain:
      - errorCount
      - errorRate
    plugin:
      errorCount:
        continuousErrorThreshold: 1
        metricNumBuckets: 1
      errorRate:
        errorRateThreshold: 100
        metricStatTimeWindow: 1s
        requestVolumeThreshold: 1

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

您可能感兴趣的文章:

Java中Socket下载一个文本文件
这篇文章主要介绍了Socket下载一个文本文件的实例代码，非常不错，具有参考借鉴价值,需要的朋友可以参考下
2017-06-06
Spring容器注入bean的五种方法逐个解析
依赖注入(Dependency Injection)和控制反转(Inversion of Control)是同一个概念。具体含义是:当某个角色(可能是一个Java实例，调用者)需要另一个角色(另一个Java实例，被调用者)的协助时，在传统的程序设计过程中，通常由调用者来创建被调用者的实例
2023-02-02
聊聊SpringBoot中组件无法被注入的问题
这篇文章主要介绍了SpringBoot中组件无法被注入的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-08-08
Java发送form-data请求实现文件上传
这篇文章主要为大家详细介绍了Java发送form-data请求实现文件上传，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-06-06
Java动态数组添加数据的方法与应用示例
这篇文章主要介绍了Java动态数组添加数据的方法,结合实例形式详细分析了Java动态数组的创建、添加、查找、打印等相关操作技巧,需要的朋友可以参考下
2019-11-11
SpringBoot中的@Value注解用法
这篇文章主要介绍了SpringBoot中的@Value注解用法，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-02-02
Java 创建动态类和查看方法列表信息的实例
这篇文章主要介绍了 Java 创建动态类和查看方法列表信息的实例的相关资料,需要的朋友可以参考下
2017-06-06
Java Clone(类的复制)实例代码
Java Clone(类的复制)实例代码，需要的朋友可以参考一下
2013-03-03
Java实现调用ElasticSearch API的示例详解
这篇文章主要为大家详细介绍了Java调用ElasticSearch API的效果资料，文中的示例代码讲解详细，具有一定的参考价值，感兴趣的可以了解一下
2023-03-03
Java AQS信号量Semaphore的使用
Semaphore来自于JDK1.5的JUC包，直译过来就是信号量，被作为一种多线程并发控制工具来使用。本文将详解其原理与使用方法，感兴趣的可以学习一下
2023-02-02