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 = "https://www.cnblogs.com/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 = "https://www.cnblogs.com/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 = "https://www.cnblogs.com/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 = "https://www.cnblogs.com/user/{id}", method = RequestMethod.GET)
    public User getUser(@PathVariable Long id);
    @RequestMapping (value = "https://www.cnblogs.com/user", method = RequestMethod.POST)
    public User postUser(@RequestBody User user);
}

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

4. 4. Controller層的呼叫方法

@Autowired
private UserFeignClient userFeignClient;
@GetMapping (value = "https://www.cnblogs.com/user/{id}")
public User getUser(@PathVariable Long id){
    //獲取資料
    return this.userFeignClient.getUser(id);
}
@GetMapping (value = "https://www.cnblogs.com/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 = "https://www.cnblogs.com/order/{id}")
    public User getUser(@PathVariable Long id){
        //獲取資料
        return userFeignClient.getUser(id);
    }

    /**
     * 測驗Feign客戶端單獨控制
     * @param id
     * @return
     */
    @GetMapping(value = "https://www.cnblogs.com/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 = "https://www.cnblogs.com/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 = "https://www.cnblogs.com/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 = "https://www.cnblogs.com/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 作為配置中心的服務端

拉取配置時更新git倉庫副本，保證是最新結果
支持資料結構豐富，yml, json, properties 等
配合 eureke 可實作服務發現，配合 cloud bus 可實作配置推送更新
配置存盤基于 git 倉庫，可進行版本管理
簡單可靠，有豐富的配套方案

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 = "https://www.cnblogs.com/profile")
    public String getProfile(){
       return this.profile;
    }
}

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

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/169234.html

標籤：Java

上一篇：Java 替換 PPT 中的圖片

下一篇：Spring IOC 容器預啟動流程原始碼探析