最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

springcloud組件技術(shù)分享(推薦)

 更新時間:2020年10月13日 11:50:07   作者:烏漢德  
Spring Cloud 是一系列框架的有序集合,它利用 Spring Boot 的開發(fā)便利性簡化了分布式系統(tǒng)的開發(fā),比如服務發(fā)現(xiàn)、服務網(wǎng)關(guān)、服務路由、鏈路追蹤等。這篇文章主要介紹了springcloud組件技術(shù)分享,需要的朋友可以參考下

Springcloud技術(shù)分享

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

Spring Cloud 是什么?

Spring Cloud 是一系列框架的有序集合,它利用 Spring Boot 的開發(fā)便利性簡化了分布式系統(tǒng)的開發(fā),比如服務發(fā)現(xiàn)、服務網(wǎng)關(guān)、服務路由、鏈路追蹤等。Spring Cloud 并不重復造輪子,而是將市面上開發(fā)得比較好的模塊集成進去,進行封裝,從而減少了各模塊的開發(fā)成本。換句話說:Spring Cloud 提供了構(gòu)建分布式系統(tǒng)所需的“全家桶”。

Spring Cloud 現(xiàn)狀

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

Spring Cloud 優(yōu)缺點

其主要優(yōu)點有:
集大成者,Spring Cloud 包含了微服務架構(gòu)的方方面面。
約定優(yōu)于配置,基于注解,沒有配置文件。
輕量級組件,Spring Cloud 整合的組件大多比較輕量級,且都是各自領(lǐng)域的佼佼者。
開發(fā)簡便,Spring Cloud 對各個組件進行了大量的封裝,從而簡化了開發(fā)。
開發(fā)靈活,Spring Cloud 的組件都是解耦的,開發(fā)人員可以靈活按需選擇組件。
接下來,我們看下它的缺點:
項目結(jié)構(gòu)復雜,每一個組件或者每一個服務都需要創(chuàng)建一個項目。
部署門檻高,項目部署需要配合 Docker 等容器技術(shù)進行集群部署,而要想深入了解 Docker,學習成本高。
Spring Cloud 的優(yōu)勢是顯而易見的。因此對于想研究微服務架構(gòu)的同學來說,學習 Spring Cloud 是一個不錯的選擇。

Spring Cloud 和 Dubbo 對比

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

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

1. 項目初始化配置

1. 1. 新建maven工程

使用idea創(chuàng)建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還有些比較常用的服務發(fā)現(xiàn)組件如Consul,Zookeeper等,目前對于springcloud支持最好的應該還是eureka。

eureka組成

Eureka Server:服務的注冊中心,負責維護注冊的服務列表。
Service Provider:服務提供方,作為一個Eureka Client,向Eureka Server做服務注冊、續(xù)約和下線等操作,注冊的主要數(shù)據(jù)包括服務名、機器ip、端口號、域名等等。
Service Consumer:服務消費方,作為一個Eureka Client,向Eureka Server獲取Service Provider的注冊信息,并通過遠程調(diào)用與Service Provider進行通信。

2. 1. 創(chuàng)建子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

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. 創(chuàng)建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相關(guān)代碼如下:

@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. 創(chuàng)建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){
 //獲取數(shù)據(jù)
 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就可以看到兩個服務已經(jīng)注冊到eureka注冊中心上了

2. 9. eureka高可用配置

兩個節(jié)點

#高可用配置,兩個節(jié)點
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

三個節(jié)點

#高可用配置,三個
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. 方式一(默認)

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

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

在啟動類上加注解

@RibbonClient(name = "provider-user")

3. 2. 方式二(配置文件自定義)

在application.yml中加入以下配置

#使用配置文件方式實現(xiàn)負載均衡,優(yōu)先級,配置文件>注解或java代碼配置>cloud默認配置
provider-user:
 ribbon:
 NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

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

自定義一個配置類,返回規(guī)則

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

4. Feign學習

什么是feign,是聲明式的webservice客戶端,解決遠程調(diào)用,支持JAX-RS,即RestFulWebService。Feign是一種聲明式、模板化的HTTP客戶端。在Spring Cloud中使用Feign, 我們可以做到使用HTTP請求遠程服務時能與調(diào)用本地方法一樣的編碼體驗,開發(fā)者完全感知不到這是遠程方法,更感知不到這是個HTTP請求,這整個調(diào)用過程和Dubbo的RPC非常類似。開發(fā)起來非常的優(yōu)雅。

4. 1. 引入依賴

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

4. 2. 使用注解@FeignClient編寫feign調(diào)用的客戶端接口

@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層的調(diào)用方法

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

5. hystrix學習

hystrix是Netflix的一個類庫,在微服務中,具有多層服務調(diào)用,主要實現(xiàn)斷路器模式的類庫

5. 1. 引入依賴

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

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

@EnableCircuitBreaker

在Controller層類的方法上加注解,并編寫退回方法,需同名

@HystrixCommand(fallbackMethod = "findByIdFallBack")
public User getOrder(@PathVariable Long id){
 //獲取數(shù)據(jù)
 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的健康監(jiān)控actuator

actuator主要用于服務健康監(jiān)控,springboot 1.X和2.x有所不同,本次為2.X

6. 1. 引入依賴包

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

6. 2. 配置

#健康監(jiān)控配置
management:
 endpoint:
 health:
 show-details: always #是否健康監(jiān)控顯示細節(jié)
 endpoints:
 web:
 exposure:
 include: hystrix.stream #hystrix保護機制,不直接暴露監(jiān)控狀態(tài)
 base-path: / #暴露的端點鏈接

6. 3. 訪問

1.X版本

localhost:8080/health

2.X版本

localhost:8080/actuator/health

7. feign配合Hystrix使用

 7. 1. 配置文件

feign:
 hystrix:
 enabled: true # 總開關(guān),可以通過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){
 //獲取數(shù)據(jù)
 return userFeignClient.getUser(id);
 }

 /**
 * 測試Feign客戶端單獨控制
 * @param id
 * @return
 */
 @GetMapping(value = "/user/{id}")
 public User getUserNotHystrix(@PathVariable Long id){
 //獲取數(shù)據(jù)
 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網(wǎng)關(guān)。

所有從設(shè)備或網(wǎng)站來的請求都會經(jīng)過Zuul到達后端的Netflix應用程序。作為一個邊界性質(zhì)的應用程序,Zuul提供了動態(tài)路由、監(jiān)控、彈性負載和安全功能。Zuul底層利用各種filter實現(xiàn)如下功能:

認證和安全 識別每個需要認證的資源,拒絕不符合要求的請求。
性能監(jiān)測 在服務邊界追蹤并統(tǒng)計數(shù)據(jù),提供精確的生產(chǎn)視圖。
動態(tài)路由 根據(jù)需要將請求動態(tài)路由到后端集群。
壓力測試 逐漸增加對集群的流量以了解其性能。
負載卸載 預先為每種類型的請求分配容量,當請求超過容量時自動丟棄。
靜態(tài)資源處理 直接在邊界返回某些響應。

8. 1. 編寫一個Zuul網(wǎng)關(guān)

@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機制

需要實現(xiàn)回退的接口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時返回給調(diào)用者的狀態(tài)碼
  return status;
  }

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

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

  @Override
  public void close() {
  }

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

  @Override
  public HttpHeaders getHeaders() {
  //設(shè)定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請求過程中執(zhí)行一連串的操作。

Zuul Filter有以下幾個特征:

Type:用以表示路由過程中的階段(內(nèi)置包含PRE、ROUTING、POST和ERROR)
Execution Order:表示相同Type的Filter的執(zhí)行順序
Criteria:執(zhí)行條件
Action:執(zhí)行體
Zuul提供了動態(tài)讀取、編譯和執(zhí)行Filter的框架。各個Filter間沒有直接聯(lián)系,但是都通過RequestContext共享一些狀態(tài)數(shù)據(jù)。

盡管Zuul支持任何基于JVM的語言,但是過濾器目前是用Groovy編寫的。 每個過濾器的源代碼被寫入到Zuul服務器上的一組指定的目錄中,這些目錄將被定期輪詢檢查是否更新。Zuul會讀取已更新的過濾器,動態(tài)編譯到正在運行的服務器中,并后續(xù)請求中調(diào)用。

8. 3. 2. Filter Types

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

PRE Filter:在請求路由到目標之前執(zhí)行。一般用于請求認證、負載均衡和日志記錄。
ROUTING Filter:處理目標請求。這里使用Apache HttpClient或Netflix Ribbon構(gòu)造對目標的HTTP請求。
POST Filter:在目標請求返回后執(zhí)行。一般會在此步驟添加響應頭、收集統(tǒng)計和性能數(shù)據(jù)等。
ERROR Filter:整個流程某塊出錯時執(zhí)行。
除了上述默認的四種Filter類型外,Zuul還允許自定義Filter類型并顯示執(zhí)行。例如,我們定義一個STATIC類型的Filter,它直接在Zuul中生成一個響應,而非將請求在轉(zhuǎn)發(fā)到目標。

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

image
一圖勝千言,下面通過官方的一張圖來了解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

在分布式系統(tǒng)中,spring cloud config 提供一個服務端和客戶端去提供可擴展的配置服務。我們可用用配置服務中心區(qū)集中的管理所有的服務的各種環(huán)境配置文件。配置服務中心采用Git的方式存儲配置文件,因此我們很容易部署修改,有助于對環(huán)境配置進行版本管理。

Spring Cloud Config就是云端存儲配置信息的,它具有中心化,版本控制,支持動態(tài)更新,平臺獨立,語言獨立等特性。其特點是:

a.提供服務端和客戶端支持(spring cloud config server和spring cloud config client)
b.集中式管理分布式環(huán)境下的應用配置
c.基于Spring環(huán)境,無縫與Spring應用集成
d.可用于任何語言開發(fā)的程序
e.默認實現(xiàn)基于git倉庫,可以進行版本管理

spring cloud config包括兩部分:

  • spring cloud config server 作為配置中心的服務端
  • 拉取配置時更新git倉庫副本,保證是最新結(jié)果
  • 支持數(shù)據(jù)結(jié)構(gòu)豐富,yml, json, properties 等
  • 配合 eureke 可實現(xiàn)服務發(fā)現(xiàn),配合 cloud bus 可實現(xiàn)配置推送更新
  • 配置存儲基于 git 倉庫,可進行版本管理
  • 簡單可靠,有豐富的配套方案 Spring Cloud Config Client 客戶端

Spring Boot項目不需要改動任何代碼,加入一個啟動配置文件指明使用ConfigServer上哪個配置文件即可

9. 2. 簡單的使用

服務端配置使用

首先需要添加相關(guān)依賴

<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下創(chuàng)建 文件夾config,在config下創(chuàng)建文件

lyh-provider-user-dev.yml
內(nèi)容為:
profile: lyh-provider-user-dev

lyh-provider-user-pro.yml
內(nèi)容為:
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的發(fā)現(xiàn)尋找config-server的服務
 enabled: true
 service-id: config-server
 name: lyh-provider-user
 #uri: http://localhost:8080 這里可以是git地址
#trace信息 配置
 bus:
 trace:
 enabled: true
#配合rabbitmq實現(xiàn)自動刷新參數(shù)
 rabbitmq: #配置rabbitmq實現(xiàn)自動刷新
 host: localhost
 port: 5672
 username: guest
 password: guest
eureka:
 client:
 service-url:
 defaultZone: http://user:123@localhost:8761/eureka
#健康監(jiān)控配置
management:
 endpoint:
 health:
 show-details: always #是否健康監(jiān)控顯示細節(jié)
 refresh:
 enabled: true
 endpoints:
 web:
 exposure:
 include: "*" #放開所有地址,跳過安全攔截
 base-path: /

客戶端測試代碼,@RefreshScope注解實現(xiàn)參數(shù)的刷新

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

訪問后我們就能拿到config服務的profile配置上數(shù)據(jù)

到此這篇關(guān)于springcloud組件技術(shù)分享的文章就介紹到這了,更多相關(guān)springcloud組件內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • JAVA反射機制中g(shù)etClass和class對比分析

    JAVA反射機制中g(shù)etClass和class對比分析

    這篇文章主要介紹了JAVA反射機制中g(shù)etClass和class對比分析,具有一定參考價值,需要的朋友可以了解下。
    2017-11-11
  • 配置JAVA環(huán)境變量中CLASSPATH變量的作用

    配置JAVA環(huán)境變量中CLASSPATH變量的作用

    這篇文章主要介紹了配置JAVA環(huán)境變量中CLASSPATH變量的作用,需要的朋友可以參考下
    2023-06-06
  • Java計時新姿勢StopWatch詳解

    Java計時新姿勢StopWatch詳解

    這篇文章主要介紹了Java計時新姿勢StopWatch,最近公司來了個大佬,從他那里學到不少東西,其中一個就是計時的新姿勢「StopWatch」,需要的朋友可以參考下
    2019-07-07
  • RocketMQ中的通信模塊詳解

    RocketMQ中的通信模塊詳解

    這篇文章主要介紹了RocketMQ中的通信模塊詳解,RocketMQ消息隊列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4個角色,本文我們簡單來講解一下,需要的朋友可以參考下
    2024-01-01
  • Java中的TreeSet集合詳解

    Java中的TreeSet集合詳解

    這篇文章主要介紹了Java中的TreeSet集合詳解,TreeSet 是一個 有序集合,它擴展了 AbstractSet 類并實現(xiàn)了 NavigableSet 接口,作為自平衡二叉搜索樹,二叉樹的每個節(jié)點包括一個額外的位,用于識別紅色或黑色的節(jié)點的顏色,需要的朋友可以參考下
    2023-09-09
  • 實戰(zhàn)分布式醫(yī)療掛號系統(tǒng)登錄接口整合阿里云短信詳情

    實戰(zhàn)分布式醫(yī)療掛號系統(tǒng)登錄接口整合阿里云短信詳情

    這篇文章主要為大家介紹了實戰(zhàn)分布式醫(yī)療掛號系統(tǒng)登錄接口整合阿里云短信詳情,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪<BR>
    2022-04-04
  • 詳解基于MybatisPlus兩步實現(xiàn)多租戶方案

    詳解基于MybatisPlus兩步實現(xiàn)多租戶方案

    這篇文章主要介紹了詳解基于MybatisPlus兩步實現(xiàn)多租戶方案,本文分兩步,通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-04-04
  • Java的CopyOnWriteArrayList操作詳解

    Java的CopyOnWriteArrayList操作詳解

    這篇文章主要介紹了Java的CopyOnWriteArrayList操作詳解,  CopyOnWriteArrayList是ArrayList 的一個線程安全的變體,其中所有可變操作(add、set等等)都是通過對底層數(shù)組進行一次新的復制來實現(xiàn)的,需要的朋友可以參考下
    2023-12-12
  • Java 多線程傳值的四種方法

    Java 多線程傳值的四種方法

    這篇文章主要介紹了Java 多線程傳值的四種方法,幫助大家更好的理解和學習Java,感興趣的朋友可以了解下
    2020-09-09
  • java判斷字符串包含某個字符的實例方法

    java判斷字符串包含某個字符的實例方法

    在本篇文章里小編給大家整理的是一篇關(guān)于java判斷字符串包含某個字符的實例方法,有需要的朋友們學習下。
    2019-12-12

最新評論

嘉兴市| 芒康县| 定安县| 东源县| 阿拉善右旗| 偃师市| 康马县| 定兴县| 瑞金市| 九龙坡区| 抚顺市| 宁德市| 新田县| 泌阳县| 博白县| 沙洋县| 沁阳市| 连平县| 分宜县| 昭平县| 安陆市| 朝阳县| 靖远县| 中西区| 班玛县| 日照市| 墨江| 小金县| 亳州市| 苍南县| 定安县| 二连浩特市| 三明市| 昆明市| 花垣县| 香港 | 莱阳市| 漠河县| 类乌齐县| 兴义市| 安图县|