Spring Cloud系列之配置中心Config

Spring Cloud系列之Eureka
Spring Cloud系列之配置中心Config
Spring Cloud系列之gateway
Spring Cloud系列之Feign
Spring Cloud系列之Hystrix
Spring Cloud系列之鏈路追蹤

配置中心可以簡單的理解為一個服務(wù)模塊，開發(fā)人員或運(yùn)維人員可以通過界面對配種中心進(jìn)行配置，下面相關(guān)的微服務(wù)連接到配置中心上面就可以實(shí)時連接獲取到配置中心上面修改的參數(shù)。更新的方式一般有兩種

  • pull模式，服務(wù)定時去拉取配置中心的數(shù)據(jù)

  • push模式，服務(wù)一直連接到配置中心上，一旦配置有變成，配種中心將把變更的參數(shù)推送到對應(yīng)的微服務(wù)上

這兩種做法其實(shí)各有利弊

  • pull可以保證一定可以拉取得到數(shù)據(jù)，pull一般采用定時拉取的方式，即使某一次出現(xiàn)網(wǎng)絡(luò)沒有拉取得到數(shù)據(jù)，那在下一次定時器也將可以拉取得到數(shù)據(jù)，最終保證能更新得到配置

  • push也有好處，避免pull定時器獲取存在時延，基本可以做到準(zhǔn)實(shí)時的更新，但push也存在問題，如果有網(wǎng)絡(luò)抖動，某一次push沒有推送成功，將丟失這次配置的更新

目前比較流行的配種中心開源組件有Spring Cloud Config，百度的disconf，阿里的Nacos，還有攜程的apollo。

實(shí)現(xiàn)原理大同小異

配置中心.png

實(shí)踐

config server搭建
  • 引入依賴
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dy-springcloud</artifactId>
        <groupId>com.dy</groupId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.dy</groupId>
    <artifactId>config-server</artifactId>

    <dependencies>

        <!--config server端依賴-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-server</artifactId>
        </dependency>

        <!--config server端也注冊到注冊中心-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

    </dependencies>

</project>
  • 配置文件
#eureka 參數(shù)配置
eureka:
  # 此實(shí)例注冊到eureka服務(wù)端的唯一的實(shí)例ID,其組成為${spring.application.name}:${spring.application.instance_id:${random.value}}
  instance:
    #  與此實(shí)例相關(guān)聯(lián)的主機(jī)名，是其他實(shí)例可以用來進(jìn)行請求的準(zhǔn)確名稱
    hostname: localhost
    # 獲取實(shí)例的ip地址
    prefer-ip-address: true
    #  eureka客戶需要多長時間發(fā)送心跳給eureka服務(wù)器，表明它仍然活著,默認(rèn)為30 秒
    lease-renewal-interval-in-seconds: 10
    #  Eureka服務(wù)器在接收到實(shí)例的最后一次發(fā)出的心跳后，需要等待多久才可以將此實(shí)例刪除，默認(rèn)為90秒
    lease-expiration-duration-in-seconds: 30
  client:
    # 注冊自己
    register-with-eureka: true
    # 是否拉取服務(wù)
    fetch-registry: true
    # 配置注冊中心服務(wù)地址
    service-url:
      # eureka 服務(wù)地址
      defaultZone: http://172.16.10.16:10001/eureka
server:
  port: 10002
spring:
  application:
    name: config-server
  cloud:
    # cloud配置中心相關(guān)配置
    config:
      server:
        # git相關(guān)配置
        git:
          # git 地址
          uri: https://gitee.com/dai-yong-1/config-server-dy.git
          # git用戶名
          username: xxxx
          # git密碼
          password: xxxxx
          # 配置文件所在文件夾
          search-paths: config-yml

配置中心git倉庫如下：

配置中心git倉庫.png
  • 啟動類
/**
 * @Description:
 * @author: dy
 */
@EnableConfigServer  //聲明當(dāng)前應(yīng)用是config server服務(wù)
@EnableDiscoveryClient //開啟Eureka客戶端發(fā)現(xiàn)功能
@SpringBootApplication
public class ConfigServerApplication {

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

}
config client 搭建
  • 引入依賴
<dependencies>

    <!--配置中心相關(guān)依賴-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>

    <!--erueka客戶端相關(guān)依賴-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

</dependencies>
  • 配置類
server:
  port: 11001
spring:
  application:
    name: user-service
  cloud:
    config:
      enabled: true
      # 與遠(yuǎn)程倉庫中的配置文件的application保持一致
      name: user-service
      # 遠(yuǎn)程倉庫中的配置文件的profile保持一致
      profile: dev
      # 遠(yuǎn)程倉庫中的 分支 版本保持一致
      label: master
      # config server地址
      uri: http://localhost:10002/
      # 配置的用戶名密碼
      username: root
      password: root

在git倉庫里面我們新建了一個配置文件user-service-dev.yml，配置內(nèi)容如下：

dy:
  config:
    app-id: 110
    app-name: 'user-service-name'

使用的時候在config client端我們新建一個配置文件：

package com.dy.user.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;

/**
 * @Description:
 * @author: dy
 */
@Data
@Component
@Configuration
@ConfigurationProperties(prefix = "dy.config")
public class AppInfo {

    private String appId;

    private String appName;

}

測試類如下：

package com.dy.user.resource;

import com.dy.user.client.UserClient;
import com.dy.user.config.AppInfo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @Description:
 * @author: dy
 */
@Slf4j
@RestController
@RequestMapping(UserClient.MAPPING)
public class UserResource implements UserClient {

    @Autowired
    private AppInfo appinfo;

    @Override
    public String getUserId() {
        return "======111111222>>"+appinfo.getAppId();
    }
}

運(yùn)行結(jié)果如下：

配置中心運(yùn)行結(jié)果.png

如此我們就大致實(shí)現(xiàn)了配置中心的基礎(chǔ)功能

config刷新功能

但是如果我們線上實(shí)時修改了git倉庫里面的配置文件內(nèi)容，那我們的客戶端怎么及時讀取git倉庫里面實(shí)時的文件內(nèi)容呢？

spring cloud config給我們提供了兩種方式：

  • config配置手動刷新

  • 自動刷新

config配置手動刷新
  • 引入依賴
<!-- 健康監(jiān)測依賴 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
  • 添加配置
management:
  #啟用監(jiān)控 默認(rèn)打開health和info,* 表示開放所有端口
  endpoints:
    web:
      exposure:
        include: *
  #打印健康信息詳情
  endpoint:
    health:
      show-details: always

  • 引用類里面添加注解@RefreshScope

    該注解處代理的bean會在調(diào)用/refresh接口時被清空

@Slf4j
@RestController
@RequestMapping(UserClient.MAPPING)
@RefreshScope
public class UserResource implements UserClient {

    @Autowired
    private AppInfo appinfo;

    @Override
    public String getUserId() {
        log.info("==============請求來了===============");
        return "======111111222>>"+appinfo.getAppId();
    }
}

  • 先修改git倉庫配置文件內(nèi)容

  • 再調(diào)用http://localhost:11001/actuator/refresh 進(jìn)行手動刷新，注意是：post方式訪問

  • 請求接口我們可以發(fā)現(xiàn)內(nèi)容改變了

雖然手動刷新可以避免我們重啟服務(wù)，但是每次去刷腳本跑接口刷新每個服務(wù)感覺十分不便，那有什么更好的方式呢？

config自動刷新

在微服務(wù)架構(gòu)體系中，我們可以接口消息總線bus實(shí)現(xiàn)配置的自動更新，也就是Spring Cloud Config+Spring Cloud Bus

Spring Cloud Bus是基于MQ的，支持Rabbitmq/Kafka，是Spring Cloud的消息總線方案。

具體實(shí)現(xiàn)流程如下：

配置中心自動刷新流程.png

具體實(shí)現(xiàn)如下（mq我們使用的是Rabbitmq）：

config server端

  • 引入依賴
<!-- spring cloud bus消息總線依賴 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
  • 添加配置
server:
  port: 10002
spring:
  application:
    name: config-server
  # 這里我們用的rabbitmq
  rabbitmq:
    addresses: amqp://192.168.2.56:5672
    username: sxw_demo
    password: sxw_demo
  cloud:
    # cloud配置中心相關(guān)配置
    config:
      server:
        # git相關(guān)配置
        git:
          # git 地址
          uri: https://gitee.com/dai-yong-1/config-server-dy.git
          # git用戶名
          username: 15828101225
          # git密碼
          password: hd961740841
          # 配置文件所在文件夾
          search-paths: config-yml
          
#eureka 參數(shù)配置  
eureka:
  # 此實(shí)例注冊到eureka服務(wù)端的唯一的實(shí)例ID,其組成為${spring.application.name}:${spring.application.instance_id:${random.value}}
  instance:
    #  與此實(shí)例相關(guān)聯(lián)的主機(jī)名，是其他實(shí)例可以用來進(jìn)行請求的準(zhǔn)確名稱
    hostname: localhost
    # 獲取實(shí)例的ip地址
    prefer-ip-address: true
    #  eureka客戶需要多長時間發(fā)送心跳給eureka服務(wù)器，表明它仍然活著,默認(rèn)為30 秒
    lease-renewal-interval-in-seconds: 10
    #  Eureka服務(wù)器在接收到實(shí)例的最后一次發(fā)出的心跳后，需要等待多久才可以將此實(shí)例刪除，默認(rèn)為90秒
    lease-expiration-duration-in-seconds: 30
  client:
    # 注冊自己
    register-with-eureka: true
    # 不拉取服務(wù)
    fetch-registry: true
    # 配置服務(wù)地址
    service-url:
      # eureka 服務(wù)地址，如果是集群的話；需要指定其它集群eureka地址  ,如果是多臺eureka server 地址以逗號隔開
      defaultZone: http://172.16.10.16:10001/eureka

management:
  #啟用監(jiān)控 默認(rèn)打開health和info,* 表示開放所有端口
  endpoints:
    web:
      exposure:
        include: "*"
  #打印健康信息詳情，
  endpoint:
    health:
      show-details: always

config client端

  • 引入依賴
<!-- spring cloud bus消息總線依賴 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
  • 添加配置
server:
  port: 11001
spring:
  application:
    name: user-service
  rabbitmq:
    addresses: amqp://192.168.2.56:5672
    username: sxw_demo
    password: sxw_demo
  zipkin:
    # zipkin server的請求地址
    base-url: http://localhost:10005/
    sender:
      #web 客戶端將蹤跡日志數(shù)據(jù)通過網(wǎng)絡(luò)請求http的方式發(fā)送到服務(wù)端
      #rabbit 客戶端將蹤跡日志數(shù)據(jù)通過mp  rabbit的方式發(fā)送到服務(wù)端
      #kafka 客戶端將蹤跡日志數(shù)據(jù)通過mp  kafka的方式發(fā)送到服務(wù)端
      type: web
  sleuth:
    sampler:
      probability: 1 # 采樣率
  cloud:
    config:
      enabled: true
      # 與遠(yuǎn)程倉庫中的配置文件的application保持一致
      name: user-service
      # 遠(yuǎn)程倉庫中的配置文件的profile保持一致
      profile: dev
      # 遠(yuǎn)程倉庫中的 分支 版本保持一致
      label: master
      # config server地址
      uri: http://localhost:10002/
      # 配置的用戶名密碼
      username: root
      password: root

運(yùn)行項(xiàng)目操作步驟如下：

如果要實(shí)現(xiàn)修改完遠(yuǎn)程git文件自動刷新配置的話,可以在git上面添加一個WebHooks, URL需要把本地的 http://localhost:10002/actuator/bus-refresh映射成公網(wǎng)IP.可以使用第三方內(nèi)網(wǎng)穿透實(shí)現(xiàn).具體如下：

配置中心wehooks配置.png
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容