1. 程式人生 > 實用技巧 >Springcloud技術分享

Springcloud技術分享

Springcloud技術分享

Spring Cloud 是一套完整的微服務解決方案,基於 Spring Boot 框架,準確的說,它不是一個框架,而是一個大的容器,它將市面上較好的微服務框架整合進來,從而簡化了開發者的程式碼量。

Spring Cloud 是什麼?

Spring Cloud 是一系列框架的有序集合,它利用 Spring Boot 的開發便利性簡化了分散式系統的開發,比如服務發現、服務閘道器、服務路由、鏈路追蹤等。Spring Cloud 並不重複造輪子,而是將市面上開發得比較好的模組整合進去,進行封裝,從而減少了各模組的開發成本。換句話說:Spring Cloud 提供了構建分散式系統所需的“全家桶”。

Spring Cloud 現狀

目前,國內使用 Spring Cloud 技術的公司並不多見,不是因為 Spring Cloud 不好,主要原因有以下幾點:
Spring Cloud 中文文件較少,出現問題網上沒有太多的解決方案。
國內創業型公司技術老大大多是阿里系員工,而阿里系多采用 Dubbo 來構建微服務架構。
大型公司基本都有自己的分散式解決方案,而中小型公司的架構很多用不上微服務,所以沒有采用 Spring Cloud 的必要性。
但是,微服務架構是一個趨勢,而 Spring Cloud 是微服務解決方案的佼佼者,這也是作者寫本系列課程的意義所在。

Spring Cloud 優缺點

其主要優點有:
集大成者,Spring Cloud 包含了微服務架構的方方面面。
約定優於配置,基於註解,沒有配置檔案。
輕量級元件,Spring Cloud 整合的元件大多比較輕量級,且都是各自領域的佼佼者。
開發簡便,Spring Cloud 對各個元件進行了大量的封裝,從而簡化了開發。
開發靈活,Spring Cloud 的元件都是解耦的,開發人員可以靈活按需選擇元件。
接下來,我們看下它的缺點:
專案結構複雜,每一個元件或者每一個服務都需要建立一個專案。
部署門檻高,專案部署需要配合 Docker 等容器技術進行叢集部署,而要想深入瞭解 Docker,學習成本高。
Spring Cloud 的優勢是顯而易見的。因此對於想研究微服務架構的同學來說,學習 Spring Cloud 是一個不錯的選擇。

Spring Cloud 和 Dubbo 對比

Dubbo 只是實現了服務治理,而 Spring Cloud 實現了微服務架構的方方面面,服務治理只是其中的一個方面。下面通過一張圖對其進行比較:

下面我們就簡單的進行springcloud的學習吧,本文章涉及springcloud的相關重要元件的使用。

1. 專案初始化配置

1. 1. 新建maven工程

使用idea建立maven專案

1. 2. 在parent專案pom中匯入以下依賴

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.3.4.RELEASE</version>
</parent>
<properties>
    <spring.cloud-version>Hoxton.SR8</spring.cloud-version>
</properties>
<dependencyManagement>
<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-dependencies</artifactId>
    <version>${spring.cloud-version}</version>
    <type>pom</type>
    <scope>import</scope>
  </dependency>
</dependencies>
</dependencyManagement>

2. Eureka

Eureka是Spring Cloud Netflix的核心元件之一,其還包括Ribbon、Hystrix、Feign這些Spring Cloud Netflix主要元件。其實除了eureka還有些比較常用的服務發現元件如Consul,Zookeeper等,目前對於springcloud支援最好的應該還是eureka。

eureka組成

Eureka Server:服務的註冊中心,負責維護註冊的服務列表。
Service Provider:服務提供方,作為一個Eureka Client,向Eureka Server做服務註冊、續約和下線等操作,註冊的主要資料包括服務名、機器ip、埠號、域名等等。
Service Consumer:服務消費方,作為一個Eureka Client,向Eureka Server獲取Service Provider的註冊資訊,並通過遠端呼叫與Service Provider進行通訊。

2. 1. 建立子module,命名為eureka-server

2. 2. 在eureka-server中新增以下依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-security</artifactId>
</dependency>

2. 3. 在application.yml中新增以下配置

server:
  port: 8900 #應用的埠號
eureka:
  client:
    service-url:
      defaultZone: http://user:123@localhost:8900/eureka #eureka服務的的註冊地址
    fetch-registry: false #是否去註冊中心拉取其他服務地址
    register-with-eureka: false #是否註冊到eureka
spring:
  application:
    name: eureka-server   #應用名稱 還可以用eureka.instance.hostname = eureka-server
  security: #配置自定義Auth賬號密碼
    user:
      name: user
      password: 123

2. 4. 在啟動類上架註解

@SpringBootApplication
@EnableEurekaServer

在啟動類中加入以下方法,防止spring的Auth攔截eureka請求

@EnableWebSecurity
    static class WebSecurityConfig extends WebSecurityConfigurerAdapter {
        @Override
        protected void configure(HttpSecurity http) throws Exception {
            http.csrf().ignoringAntMatchers("/eureka/**");
            super.configure(http);
        }
    }

2. 5. 建立module名為provider-user為服務提供者

2. 5. 1. 在pom中新增以下依賴
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
2. 5. 2. application.yml配置
server:
  port: 7900 #程式啟動入口
spring:
  application:
    name: provider-user #應用名稱
eureka:
  client:
    service-url:
      defaultZone: http://user:123@${eureka.instance.hostname}:${server.port}/eureka/
2. 5. 3. 啟動類加註解
@SpringBootApplication
@EnableEurekaClient

Controller相關程式碼如下:

@RestController
public class UserController {
    @GetMapping (value = "/user/{id}")
    public User getUser(@PathVariable Long id){
        User user = new User();
        user.setId(id);
        user.setDate(new Date());
        System.out.println("7900");
        return user;
    }
    @PostMapping (value = "/user")
    public User getPostUser(@RequestBody User user){
        return user;
    }
}

2. 6. 建立module名為consumer-order為服務提供者

2. 6. 1. pom依賴同服務提供者
2. 6. 2. application.yml配置
server:
  port: 8010
spring:
  application:
    name: consumer-order
eureka:
  client:
    serviceUrl:
      defaultZone: http://user:123@${eureka.instance.hostname}:${server.port}/eureka/
2. 6. 3. 啟動類
@SpringBootApplication
@EnableEurekaClient
public class ConsumerApp
{
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
    public static void main( String[] args )
    {
        SpringApplication.run(ConsumerApp.class,args);
    }
}
2. 6. 4. Controller層程式碼
@RestController
public class OrderController {

    @Autowired
    private RestTemplate restTemplate;
    @GetMapping (value = "/order/{id}")
    public User getOrder(@PathVariable Long id){
        //獲取資料
        User user = new User();
        user.setId(id);
        user.setDate(new Date());
        user = restTemplate.getForObject("http://provider-user:7900/user/"+id,User.class);
        return user;
    }
}

2. 7. 啟動應用

分別啟動Eureka-server、provider-user、consumer-order三個服務

2. 8. 訪問地址

http://localhost:8900就可以看到兩個服務已經註冊到eureka註冊中心上了

2. 9. eureka高可用配置

兩個節點

#高可用配置,兩個節點
spring:
  application:
    name: eureka-server-ha
  profiles:
    active: peer1

eureka:
  client:
    serviceUrl:
      defaultZone: https://peer1/eureka/,http://peer2/eureka/
---
server:
  port: 8901
spring:
  profiles: peer1
eureka:
  instance:
    hostname: peer1

---
server:
  port: 8902
spring:
  profiles: peer2
eureka:
  instance:
    hostname: peer2

三個節點

#高可用配置,三個
spring:
  application:
    name: eureka-server-ha
  profiles:
    active: peer3
eureka:
  client:
    serviceUrl:
      defaultZone: http://peer1:8901/eureka/,http://peer2:8902/eureka/,http://peer3:8903/eureka/
---
spring:
  profiles: peer1
eureka:
  instance:
    hostname: peer1
server:
  port: 8901
---
spring:
  profiles: peer2
eureka:
  instance:
    hostname: peer2
server:
  port: 8902
---
spring:
  profiles: peer3
eureka:
  instance:
    hostname: peer3
server:
  port: 8903

3. Ribbon

配合eureka使用的一個負載均衡元件,一般情況下我們都是自定義負載均衡策略使用

3. 1. 方式一(預設)

輪詢規則
在啟動類中restTemplate()方法加入註解@LoadBalanced
RestTemplate 是由 Spring Web 模組提供的工具類,與 SpringCloud 無關,是獨立存在的,因 SpringCloud 對 RestTemplate 進行了一定的擴充套件,所以 RestTemplate 具備了負載均衡的功能

@Bean
@LoadBalanced
public RestTemplate restTemplate(){
    return new RestTemplate();
}

在啟動類上加註解

@RibbonClient(name = "provider-user")

3. 2. 方式二(配置檔案自定義)

在application.yml中加入以下配置

#使用配置檔案方式實現負載均衡,優先順序,配置檔案>註解或java程式碼配置>cloud預設配置
provider-user:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

3. 3. 方式三(Java程式碼自定義)

自定義一個配置類,返回規則

@RibbonClient(name = "provider-user",configuration = RibbonConfiguration.class)
public class RibbonConfiguration {
    @Bean
    public IRule getRule(){
        return new RandomRule();
    }
}

4. Feign學習

什麼是feign,是宣告式的webservice客戶端,解決遠端呼叫,支援JAX-RS,即RestFulWebService。Feign是一種宣告式、模板化的HTTP客戶端。在Spring Cloud中使用Feign, 我們可以做到使用HTTP請求遠端服務時能與呼叫本地方法一樣的編碼體驗,開發者完全感知不到這是遠端方法,更感知不到這是個HTTP請求,這整個呼叫過程和Dubbo的RPC非常類似。開發起來非常的優雅。

4. 1. 引入依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

4. 2. 使用註解@FeignClient編寫feign呼叫的客戶端介面

@FeignClient("provider-user")
public interface UserFeignClient {
    @RequestMapping (value = "/user/{id}", method = RequestMethod.GET)
    public User getUser(@PathVariable Long id);
    @RequestMapping (value = "/user", method = RequestMethod.POST)
    public User postUser(@RequestBody User user);
}

4. 3. 在啟動類加註解@EnableFeignClients

4. 4. Controller層的呼叫方法

@Autowired
private UserFeignClient userFeignClient;
@GetMapping (value = "/user/{id}")
public User getUser(@PathVariable Long id){
    //獲取資料
    return this.userFeignClient.getUser(id);
}
@GetMapping (value = "/user")
public User postUser(User user){
    return this.userFeignClient.postUser(user);
}

5. hystrix學習

hystrix是Netflix的一個類庫,在微服務中,具有多層服務呼叫,主要實現斷路器模式的類庫

5. 1. 引入依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

5. 2. 在啟動類上加註解

@EnableCircuitBreaker
    1. 在Controller層類的方法上加註解,並編寫退回方法,需同名
@HystrixCommand(fallbackMethod = "findByIdFallBack")
public User getOrder(@PathVariable Long id){
    //獲取資料
    User user = new User();
    user.setId(id);
    user.setDate(new Date());
    user = restTemplate.getForObject("http://provider-user/user/"+id,User.class);
    System.out.println(Thread.currentThread().getId());
    return user;
}
public User findByIdFallBack(Long id){
    System.out.println(Thread.currentThread().getId());
    User user = new User();
    user.setId(1L);
    return user;
}

6. springboot的健康監控actuator

actuator主要用於服務健康監控,springboot 1.X和2.x有所不同,本次為2.X

6. 1. 引入依賴包

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

6. 2. 配置

#健康監控配置
management:
  endpoint:
    health:
      show-details: always #是否健康監控顯示細節
  endpoints:
    web:
      exposure:
        include: hystrix.stream #hystrix保護機制,不直接暴露監控狀態
      base-path: / #暴露的端點連結

6. 3. 訪問

1.X版本

localhost:8080/health

2.X版本

localhost:8080/actuator/health

7. feign配合Hystrix使用

7. 1. 配置檔案

feign:
  hystrix:
    enabled: true # 總開關,可以通過java單獨控制client

7. 2. 啟動類註解

@EnableFeignClients

7. 3. 控制層

@RestController
public class OrderFeignController {
    @Autowired
    private UserFeignClient userFeignClient;
    @Autowired
    private UserFeignNotHystrixClient userFeignNotHystrixClient;
    @GetMapping (value = "/order/{id}")
    public User getUser(@PathVariable Long id){
        //獲取資料
        return userFeignClient.getUser(id);
    }

    /**
     * 測試Feign客戶端單獨控制
     * @param id
     * @return
     */
    @GetMapping(value = "/user/{id}")
    public User getUserNotHystrix(@PathVariable Long id){
        //獲取資料
        return userFeignNotHystrixClient.getUserNotHystrix(id);
    }
}

7. 4. 兩個FeignClient

一個加了configuration一個沒有,加了可以通過註解重寫feignBuilder方法單獨控制,預設是返回HystrixFeignBuilder

@FeignClient(name = "provider-user", fallback = HystrixClientFallback.class)
public interface UserFeignClient {
    @RequestMapping (value = "/user/{id}", method = RequestMethod.GET)
    User getUser(@PathVariable Long id);
}

@Component
public class HystrixClientFallback implements UserFeignClient{
    @Override
    public User getUser(Long id) {
        System.out.println(Thread.currentThread().getId());
        User user = new User();
        user.setId(1L);
        return user;
    }
}
@FeignClient(name = "provider-user1",configuration = ConfigurationNotHystrix.class,fallback = HystrixClientNotHystrixFallback.class)
public interface UserFeignNotHystrixClient {
    @RequestMapping (value = "/user/{id}", method = RequestMethod.GET)
    User getUserNotHystrix(@PathVariable Long id);
}

@Component
public class HystrixClientNotHystrixFallback implements UserFeignNotHystrixClient{
    @Override
    public User getUserNotHystrix(Long id) {
        System.out.println(Thread.currentThread().getId());
        User user = new User();
        user.setId(1L);
        return user;
    }
}

7. 5. 配置類

@Configuration
public class ConfigurationNotHystrix {

    @Bean
    @Scope("prototype")
    public Feign.Builder feignBuilder(){
        return Feign.builder();
    }
}

7. 6. 獲取異常資訊程式碼

@FeignClient(name = "hello", fallbackFactory = HystrixClientFallbackFactory.class)
protected interface HystrixClient {
    @RequestMapping(method = RequestMethod.GET, value = "/hello")
    Hello iFailSometimes();
}

@Component
static class HystrixClientFallbackFactory implements FallbackFactory<HystrixClient> {
    @Override
    public HystrixClient create(Throwable cause) {
        return new HystrixClient() {
            @Override
            public Hello iFailSometimes() {
                return new Hello("fallback; reason was: " + cause.getMessage());
            }
        };
    }
}

8. Zuul

Zuul是Spring Cloud全家桶中的微服務API閘道器。

所有從裝置或網站來的請求都會經過Zuul到達後端的Netflix應用程式。作為一個邊界性質的應用程式,Zuul提供了動態路由、監控、彈性負載和安全功能。Zuul底層利用各種filter實現如下功能:

認證和安全 識別每個需要認證的資源,拒絕不符合要求的請求。
效能監測 在服務邊界追蹤並統計資料,提供精確的生產檢視。
動態路由 根據需要將請求動態路由到後端叢集。
壓力測試 逐漸增加對叢集的流量以瞭解其效能。
負載解除安裝 預先為每種型別的請求分配容量,當請求超過容量時自動丟棄。
靜態資源處理 直接在邊界返回某些響應。

8. 1. 編寫一個Zuul閘道器

@SpringBootApplication
@EnableZuulProxy
@EnableEurekaClient
public class GatewayZuulApp
{
    public static void main( String[] args )
    {
        SpringApplication.run(GatewayZuulApp.class,args);
    }
    @Bean
    public PreZuulFilter preZuulFilter(){
        return new PreZuulFilter();
    }
}

application.yml 配置

zuul:
  ignoredServices: '*' #剔除的連結,*代表所有
  routes:
    lyh-provider-user: /myusers/** #自定義的反向代理url

8. 2. Zuul的fallback機制

需要實現回退的介面FallbackProvider,當服務不可用時,就會走fallback,原始碼如下

@Component
public class ZuulFallbackProvider implements FallbackProvider {
    /**
     * fallback的路由返回服務名,“*”匹配所有
     * @return
     */
    @Override
    public String getRoute() {
        return "lyh-provider-user";
    }

    /**
     * fallbacl響應,可以用於異常資訊的記錄
     * @param route
     * @param cause
     * @return
     */
    @Override
    public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
        if (cause instanceof HystrixTimeoutException) {
            return response(HttpStatus.GATEWAY_TIMEOUT);
        } else {
            return response(HttpStatus.INTERNAL_SERVER_ERROR);
        }
    }
    private ClientHttpResponse response(final HttpStatus status) {
        return new ClientHttpResponse() {
            @Override
            public HttpStatus getStatusCode() throws IOException {
                //當fallback時返回給呼叫者的狀態碼
                return status;
            }

            @Override
            public int getRawStatusCode() throws IOException {
                return status.value();
            }

            @Override
            public String getStatusText() throws IOException {
                //狀態碼的文字形式
                return status.getReasonPhrase();
            }

            @Override
            public void close() {
            }

            @Override
            public InputStream getBody() throws IOException {
                //響應體
                return new ByteArrayInputStream("fallback".getBytes());
            }

            @Override
            public HttpHeaders getHeaders() {
                //設定headers
                HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_JSON);
                return headers;
            }
        };
    }
}

8. 3. Zuul 的Filter

8. 3. 1. Zuul中的Filter

Zuul是圍繞一系列Filter展開的,這些Filter在整個HTTP請求過程中執行一連串的操作。

Zuul Filter有以下幾個特徵:

Type:用以表示路由過程中的階段(內建包含PRE、ROUTING、POST和ERROR)
Execution Order:表示相同Type的Filter的執行順序
Criteria:執行條件
Action:執行體
Zuul提供了動態讀取、編譯和執行Filter的框架。各個Filter間沒有直接聯絡,但是都通過RequestContext共享一些狀態資料。

儘管Zuul支援任何基於JVM的語言,但是過濾器目前是用Groovy編寫的。 每個過濾器的原始碼被寫入到Zuul伺服器上的一組指定的目錄中,這些目錄將被定期輪詢檢查是否更新。Zuul會讀取已更新的過濾器,動態編譯到正在執行的伺服器中,並後續請求中呼叫。

8. 3. 2. Filter Types

以下提供四種標準的Filter型別及其在請求生命週期中所處的位置:

PRE Filter:在請求路由到目標之前執行。一般用於請求認證、負載均衡和日誌記錄。
ROUTING Filter:處理目標請求。這裡使用Apache HttpClient或Netflix Ribbon構造對目標的HTTP請求。
POST Filter:在目標請求返回後執行。一般會在此步驟新增響應頭、收集統計和效能資料等。
ERROR Filter:整個流程某塊出錯時執行。
除了上述預設的四種Filter型別外,Zuul還允許自定義Filter型別並顯示執行。例如,我們定義一個STATIC型別的Filter,它直接在Zuul中生成一個響應,而非將請求在轉發到目標。

8. 3. 3. Zuul請求生命週期


一圖勝千言,下面通過官方的一張圖來了解Zuul請求的生命週期。

8. 3. 4. 自定義一個filter

需要繼承ZuulFilter類

public class PreZuulFilter extends ZuulFilter {
    @Override
    public String filterType() {
        return "pre";
    }

    @Override
    public int filterOrder() {
        return 5;
    }

    @Override
    public boolean shouldFilter() {
        return true;
    }

    @Override
    public Object run() throws ZuulException {
        String requestURI = RequestContext.getCurrentContext().getRequest().getRequestURI();
        System.out.println(requestURI);
        return requestURI;
    }
}

將自定義的filter通過@Bean注入

@Bean
    public PreZuulFilter preZuulFilter(){
        return new PreZuulFilter();
    }

filter配置

zuul:
  PreZuulFilter:  #過濾器類名
    pre:  #過濾型別
      disable: false
8. 3. 5. zuul上傳下載

zuul一樣可以正常的上傳下載,要注意的是他使用的是預設大小配置,想要上傳大檔案 需要在訪問的地址前加/zuul/服務地址,同時需要配置超時時間

#當上傳大檔案是在serviceid前加zuul/ 如:zuul/servcieid/*,且需要配置ribbon的超時時間和hystrix的超時時間,防止報錯後走hystrix的退回程式碼
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 60000
ribbon:
  ConnectTimeout: 3000
  ReadTimeout: 60000

9. springCloud的Config

9. 1. 什麼是spring cloud config

在分散式系統中,spring cloud config 提供一個服務端和客戶端去提供可擴充套件的配置服務。我們可用用配置服務中心區集中的管理所有的服務的各種環境配置檔案。配置服務中心採用Git的方式儲存配置檔案,因此我們很容易部署修改,有助於對環境配置進行版本管理。

Spring Cloud Config就是雲端儲存配置資訊的,它具有中心化,版本控制,支援動態更新,平臺獨立,語言獨立等特性。其特點是:

a.提供服務端和客戶端支援(spring cloud config server和spring cloud config client)
b.集中式管理分散式環境下的應用配置
c.基於Spring環境,無縫與Spring應用整合
d.可用於任何語言開發的程式
e.預設實現基於git倉庫,可以進行版本管理

spring cloud config包括兩部分:

  • spring cloud config server 作為配置中心的服務端
  1. 拉取配置時更新git倉庫副本,保證是最新結果
  2. 支援資料結構豐富,yml, json, properties 等
  3. 配合 eureke 可實現服務發現,配合 cloud bus 可實現配置推送更新
  4. 配置儲存基於 git 倉庫,可進行版本管理
  5. 簡單可靠,有豐富的配套方案
  • Spring Cloud Config Client 客戶端

Spring Boot專案不需要改動任何程式碼,加入一個啟動配置檔案指明使用ConfigServer上哪個配置檔案即可

9. 2. 簡單的使用

服務端配置使用

首先需要新增相關依賴

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-config-server</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

啟動類

@SpringBootApplication
@EnableEurekaClient
@EnableConfigServer
public class SpringCloudConfigApp
{
    public static void main( String[] args )
    {
        SpringApplication.run(SpringCloudConfigApp.class,args);
    }
}

本地方式配合Eureka配置

spring:
  application:
    name: config-server
  cloud:
    config:
      name: config-server
      server:
        native:
          search-locations: classpath:/config
        bootstrap: true
        #配置git方式
        #git:
          #uri:  #配置git倉庫地址
          #username: #訪問git倉庫的使用者名稱
          #password: #訪問git倉庫的使用者密碼
          #search-paths: #配置倉庫路徑
      #label: master #git使用,預設master
  profiles:
    active: native  #開啟本地配置
server:
  port: 8080
eureka:
  client:
    service-url:
      defaultZone: http://user:123@localhost:8761/eureka

在resources下建立 資料夾config,在config下建立檔案

lyh-provider-user-dev.yml
內容為:
profile: lyh-provider-user-dev

lyh-provider-user-pro.yml
內容為:
profile: lyh-provider-user-pro

客戶端配置

新增依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
server:
  port: 7900 #程式啟動入口
spring:
  application:
    name: lyh-provider-user #應用名稱
  cloud:
    config:
      profile: dev
      discovery: #使用eureka的發現尋找config-server的服務
        enabled: true
        service-id: config-server
      name: lyh-provider-user
      #uri: http://localhost:8080   這裡可以是git地址
#trace資訊 配置
    bus:
      trace:
        enabled: true
#配合rabbitmq實現自動重新整理引數
    rabbitmq: #配置rabbitmq實現自動重新整理
      host: localhost
      port: 5672
      username: guest
      password: guest
eureka:
  client:
    service-url:
      defaultZone: http://user:123@localhost:8761/eureka
#健康監控配置
management:
  endpoint:
    health:
      show-details: always #是否健康監控顯示細節
    refresh:
      enabled: true
  endpoints:
    web:
      exposure:
        include: "*"  #放開所有地址,跳過安全攔截
      base-path: /

客戶端測試程式碼,@RefreshScope註解實現引數的重新整理

@RestController
@RefreshScope
public class UserController {
    @Value("${profile}")
    private String profile;
    @GetMapping (value = "/profile")
    public String getProfile(){
       return this.profile;
    }
}

訪問後我們就能拿到config服務的profile配置上資料