SpringCloud Tencent 全套解決方案源碼分析

Posted on by

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內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：