springcloud組件技術(shù)分享(推薦)
Springcloud技術(shù)分享
Spring Cloud 是一套完整的微服務(wù)解決方案，基于 Spring Boot 框架，準(zhǔn)確的說，它不是一個(gè)框架，而是一個(gè)大的容器，它將市面上較好的微服務(wù)框架集成進(jìn)來，從而簡化了開發(fā)者的代碼量。
Spring Cloud 是什么？
Spring Cloud 是一系列框架的有序集合，它利用 Spring Boot 的開發(fā)便利性簡化了分布式系統(tǒng)的開發(fā)，比如服務(wù)發(fā)現(xiàn)、服務(wù)網(wǎng)關(guān)、服務(wù)路由、鏈路追蹤等。Spring Cloud 并不重復(fù)造輪子，而是將市面上開發(fā)得比較好的模塊集成進(jìn)去，進(jìn)行封裝，從而減少了各模塊的開發(fā)成本。換句話說：Spring Cloud 提供了構(gòu)建分布式系統(tǒng)所需的“全家桶”。
Spring Cloud 現(xiàn)狀
目前，國內(nèi)使用 Spring Cloud 技術(shù)的公司并不多見，不是因?yàn)?Spring Cloud 不好，主要原因有以下幾點(diǎn)：
Spring Cloud 中文文檔較少，出現(xiàn)問題網(wǎng)上沒有太多的解決方案。
國內(nèi)創(chuàng)業(yè)型公司技術(shù)老大大多是阿里系員工，而阿里系多采用 Dubbo 來構(gòu)建微服務(wù)架構(gòu)。
大型公司基本都有自己的分布式解決方案，而中小型公司的架構(gòu)很多用不上微服務(wù)，所以沒有采用 Spring Cloud 的必要性。
但是，微服務(wù)架構(gòu)是一個(gè)趨勢，而 Spring Cloud 是微服務(wù)解決方案的佼佼者，這也是作者寫本系列課程的意義所在。
Spring Cloud 優(yōu)缺點(diǎn)
其主要優(yōu)點(diǎn)有：
集大成者，Spring Cloud 包含了微服務(wù)架構(gòu)的方方面面。
約定優(yōu)于配置，基于注解，沒有配置文件。
輕量級組件，Spring Cloud 整合的組件大多比較輕量級，且都是各自領(lǐng)域的佼佼者。
開發(fā)簡便，Spring Cloud 對各個(gè)組件進(jìn)行了大量的封裝，從而簡化了開發(fā)。
開發(fā)靈活，Spring Cloud 的組件都是解耦的，開發(fā)人員可以靈活按需選擇組件。
接下來，我們看下它的缺點(diǎn)：
項(xiàng)目結(jié)構(gòu)復(fù)雜，每一個(gè)組件或者每一個(gè)服務(wù)都需要?jiǎng)?chuàng)建一個(gè)項(xiàng)目。
部署門檻高，項(xiàng)目部署需要配合 Docker 等容器技術(shù)進(jìn)行集群部署，而要想深入了解 Docker，學(xué)習(xí)成本高。
Spring Cloud 的優(yōu)勢是顯而易見的。因此對于想研究微服務(wù)架構(gòu)的同學(xué)來說，學(xué)習(xí) Spring Cloud 是一個(gè)不錯(cuò)的選擇。
Spring Cloud 和 Dubbo 對比
Dubbo 只是實(shí)現(xiàn)了服務(wù)治理，而 Spring Cloud 實(shí)現(xiàn)了微服務(wù)架構(gòu)的方方面面，服務(wù)治理只是其中的一個(gè)方面。下面通過一張圖對其進(jìn)行比較：
下面我們就簡單的進(jìn)行springcloud的學(xué)習(xí)吧，本文章涉及springcloud的相關(guān)重要組件的使用。
1. 項(xiàng)目初始化配置
1. 1. 新建maven工程
使用idea創(chuàng)建maven項(xiàng)目
1. 2. 在parent項(xiàng)目pom中導(dǎo)入以下依賴
<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主要組件。其實(shí)除了eureka還有些比較常用的服務(wù)發(fā)現(xiàn)組件如Consul，Zookeeper等，目前對于springcloud支持最好的應(yīng)該還是eureka。
eureka組成
Eureka Server：服務(wù)的注冊中心，負(fù)責(zé)維護(hù)注冊的服務(wù)列表。 Service Provider：服務(wù)提供方，作為一個(gè)Eureka Client，向Eureka Server做服務(wù)注冊、續(xù)約和下線等操作，注冊的主要數(shù)據(jù)包括服務(wù)名、機(jī)器ip、端口號、域名等等。 Service Consumer：服務(wù)消費(fèi)方，作為一個(gè)Eureka Client，向Eureka Server獲取Service Provider的注冊信息，并通過遠(yuǎn)程調(diào)用與Service Provider進(jìn)行通信。
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 #應(yīng)用的端口號 eureka: client: service-url: defaultZone: http://user:123@localhost:8900/eureka #eureka服務(wù)的的注冊地址 fetch-registry: false #是否去注冊中心拉取其他服務(wù)地址 register-with-eureka: false #是否注冊到eureka spring: application: name: eureka-server #應(yīng)用名稱 還可以用eureka.instance.hostname = eureka-server security: #配置自定義Auth賬號密碼 user: name: user
2. 4. 在啟動(dòng)類上架注解
@SpringBootApplication @EnableEurekaServer
在啟動(dòng)類中加入以下方法,防止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為服務(wù)提供者 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 #程序啟動(dòng)入口
spring:
application:
name: provider-user #應(yīng)用名稱
eureka:
client:
service-url:
defaultZone: http://user:123@${eureka.instance.hostname}:${server.port}/eureka/
2. 5. 3. 啟動(dòng)類加注解
@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為服務(wù)提供者 2. 6. 1. pom依賴同服務(wù)提供者 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. 啟動(dòng)類
@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. 啟動(dòng)應(yīng)用
分別啟動(dòng)Eureka-server、provider-user、consumer-order三個(gè)服務(wù)
2. 8. 訪問地址
http://localhost:8900就可以看到兩個(gè)服務(wù)已經(jīng)注冊到eureka注冊中心上了
2. 9. eureka高可用配置
兩個(gè)節(jié)點(diǎn)
#高可用配置，兩個(gè)節(jié)點(diǎn) 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
三個(gè)節(jié)點(diǎn)
#高可用配置，三個(gè) 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使用的一個(gè)負(fù)載均衡組件，一般情況下我們都是自定義負(fù)載均衡策略使用
3. 1. 方式一(默認(rèn))
輪詢規(guī)則
在啟動(dòng)類中restTemplate()方法加入注解@LoadBalanced
RestTemplate 是由 Spring Web 模塊提供的工具類，與 SpringCloud 無關(guān)，是獨(dú)立存在的，因 SpringCloud 對 RestTemplate 進(jìn)行了一定的擴(kuò)展，所以 RestTemplate 具備了負(fù)載均衡的功能
@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}
在啟動(dòng)類上加注解
@RibbonClient(name = "provider-user")
3. 2. 方式二(配置文件自定義)
在application.yml中加入以下配置
#使用配置文件方式實(shí)現(xiàn)負(fù)載均衡，優(yōu)先級，配置文件>注解或java代碼配置>cloud默認(rèn)配置 provider-user: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
3. 3. 方式三(Java代碼自定義)
自定義一個(gè)配置類，返回規(guī)則
@RibbonClient(name = "provider-user",configuration = RibbonConfiguration.class)
public class RibbonConfiguration {
@Bean
public IRule getRule(){
return new RandomRule();
}
}
4. Feign學(xué)習(xí)
什么是feign，是聲明式的webservice客戶端，解決遠(yuǎn)程調(diào)用，支持JAX-RS,即RestFulWebService。Feign是一種聲明式、模板化的HTTP客戶端。在Spring Cloud中使用Feign, 我們可以做到使用HTTP請求遠(yuǎn)程服務(wù)時(shí)能與調(diào)用本地方法一樣的編碼體驗(yàn)，開發(fā)者完全感知不到這是遠(yuǎn)程方法，更感知不到這是個(gè)HTTP請求，這整個(gè)調(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. 在啟動(dòng)類加注解@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學(xué)習(xí)
hystrix是Netflix的一個(gè)類庫，在微服務(wù)中，具有多層服務(wù)調(diào)用，主要實(shí)現(xiàn)斷路器模式的類庫
5. 1. 引入依賴
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
5. 2. 在啟動(dòng)類上加注解
@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主要用于服務(wù)健康監(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)控顯示細(xì)節(jié) endpoints: web: exposure: include: hystrix.stream #hystrix保護(hù)機(jī)制，不直接暴露監(jiān)控狀態(tài) base-path: / #暴露的端點(diǎn)鏈接
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單獨(dú)控制client
7. 2. 啟動(dòng)類注解
@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客戶端單獨(dú)控制
* @param id
* @return
*/
@GetMapping(value = "/user/{id}")
public User getUserNotHystrix(@PathVariable Long id){
//獲取數(shù)據(jù)
return userFeignNotHystrixClient.getUserNotHystrix(id);
}
}
7. 4. 兩個(gè)FeignClient
一個(gè)加了configuration一個(gè)沒有，加了可以通過注解重寫feignBuilder方法單獨(dú)控制，默認(rèn)是返回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全家桶中的微服務(wù)API網(wǎng)關(guān)。
所有從設(shè)備或網(wǎng)站來的請求都會經(jīng)過Zuul到達(dá)后端的Netflix應(yīng)用程序。作為一個(gè)邊界性質(zhì)的應(yīng)用程序，Zuul提供了動(dòng)態(tài)路由、監(jiān)控、彈性負(fù)載和安全功能。Zuul底層利用各種filter實(shí)現(xiàn)如下功能：
認(rèn)證和安全 識別每個(gè)需要認(rèn)證的資源，拒絕不符合要求的請求。
性能監(jiān)測 在服務(wù)邊界追蹤并統(tǒng)計(jì)數(shù)據(jù)，提供精確的生產(chǎn)視圖。
動(dòng)態(tài)路由 根據(jù)需要將請求動(dòng)態(tài)路由到后端集群。
壓力測試 逐漸增加對集群的流量以了解其性能。
負(fù)載卸載 預(yù)先為每種類型的請求分配容量，當(dāng)請求超過容量時(shí)自動(dòng)丟棄。
靜態(tài)資源處理 直接在邊界返回某些響應(yīng)。
8. 1. 編寫一個(gè)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機(jī)制
需要實(shí)現(xiàn)回退的接口FallbackProvider，當(dāng)服務(wù)不可用時(shí)，就會走fallback，源碼如下
@Component
public class ZuulFallbackProvider implements FallbackProvider {
/**
* fallback的路由返回服務(wù)名，“*”匹配所有
* @return
*/
@Override
public String getRoute() {
return "lyh-provider-user";
}
/**
* fallbacl響應(yīng)，可以用于異常信息的記錄
* @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 {
//當(dāng)fallback時(shí)返回給調(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 {
//響應(yīng)體
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在整個(gè)HTTP請求過程中執(zhí)行一連串的操作。
Zuul Filter有以下幾個(gè)特征：
Type：用以表示路由過程中的階段（內(nèi)置包含PRE、ROUTING、POST和ERROR）
Execution Order：表示相同Type的Filter的執(zhí)行順序
Criteria：執(zhí)行條件
Action：執(zhí)行體
Zuul提供了動(dòng)態(tài)讀取、編譯和執(zhí)行Filter的框架。各個(gè)Filter間沒有直接聯(lián)系，但是都通過RequestContext共享一些狀態(tài)數(shù)據(jù)。
盡管Zuul支持任何基于JVM的語言，但是過濾器目前是用Groovy編寫的。 每個(gè)過濾器的源代碼被寫入到Zuul服務(wù)器上的一組指定的目錄中，這些目錄將被定期輪詢檢查是否更新。Zuul會讀取已更新的過濾器，動(dòng)態(tài)編譯到正在運(yùn)行的服務(wù)器中，并后續(xù)請求中調(diào)用。
8. 3. 2. Filter Types
以下提供四種標(biāo)準(zhǔn)的Filter類型及其在請求生命周期中所處的位置：
PRE Filter：在請求路由到目標(biāo)之前執(zhí)行。一般用于請求認(rèn)證、負(fù)載均衡和日志記錄。
ROUTING Filter：處理目標(biāo)請求。這里使用Apache HttpClient或Netflix Ribbon構(gòu)造對目標(biāo)的HTTP請求。
POST Filter：在目標(biāo)請求返回后執(zhí)行。一般會在此步驟添加響應(yīng)頭、收集統(tǒng)計(jì)和性能數(shù)據(jù)等。
ERROR Filter：整個(gè)流程某塊出錯(cuò)時(shí)執(zhí)行。
除了上述默認(rèn)的四種Filter類型外，Zuul還允許自定義Filter類型并顯示執(zhí)行。例如，我們定義一個(gè)STATIC類型的Filter，它直接在Zuul中生成一個(gè)響應(yīng)，而非將請求在轉(zhuǎn)發(fā)到目標(biāo)。
8. 3. 3. Zuul請求生命周期
一圖勝千言，下面通過官方的一張圖來了解Zuul請求的生命周期。
8. 3. 4. 自定義一個(gè)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一樣可以正常的上傳下載，要注意的是他使用的是默認(rèn)大小配置，想要上傳大文件 需要在訪問的地址前加/zuul/服務(wù)地址，同時(shí)需要配置超時(shí)時(shí)間
#當(dāng)上傳大文件是在serviceid前加zuul/ 如：zuul/servcieid/*,且需要配置ribbon的超時(shí)時(shí)間和hystrix的超時(shí)時(shí)間，防止報(bào)錯(cuò)后走h(yuǎn)ystrix的退回代碼 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 提供一個(gè)服務(wù)端和客戶端去提供可擴(kuò)展的配置服務(wù)。我們可用用配置服務(wù)中心區(qū)集中的管理所有的服務(wù)的各種環(huán)境配置文件。配置服務(wù)中心采用Git的方式存儲配置文件，因此我們很容易部署修改，有助于對環(huán)境配置進(jìn)行版本管理。
Spring Cloud Config就是云端存儲配置信息的,它具有中心化,版本控制,支持動(dòng)態(tài)更新,平臺獨(dú)立,語言獨(dú)立等特性。其特點(diǎn)是：
a.提供服務(wù)端和客戶端支持(spring cloud config server和spring cloud config client) b.集中式管理分布式環(huán)境下的應(yīng)用配置 c.基于Spring環(huán)境，無縫與Spring應(yīng)用集成 d.可用于任何語言開發(fā)的程序 e.默認(rèn)實(shí)現(xiàn)基于git倉庫，可以進(jìn)行版本管理
spring cloud config包括兩部分：
- spring cloud config server 作為配置中心的服務(wù)端
- 拉取配置時(shí)更新git倉庫副本，保證是最新結(jié)果
- 支持?jǐn)?shù)據(jù)結(jié)構(gòu)豐富，yml, json, properties 等
- 配合 eureke 可實(shí)現(xiàn)服務(wù)發(fā)現(xiàn)，配合 cloud bus 可實(shí)現(xiàn)配置推送更新
- 配置存儲基于 git 倉庫，可進(jìn)行版本管理
- 簡單可靠，有豐富的配套方案 Spring Cloud Config Client 客戶端
Spring Boot項(xiàng)目不需要改動(dòng)任何代碼，加入一個(gè)啟動(dòng)配置文件指明使用ConfigServer上哪個(gè)配置文件即可
9. 2. 簡單的使用
服務(wù)端配置使用
首先需要添加相關(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>
啟動(dòng)類
@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使用，默認(rèn)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 #程序啟動(dòng)入口 spring: application: name: lyh-provider-user #應(yīng)用名稱 cloud: config: profile: dev discovery: #使用eureka的發(fā)現(xiàn)尋找config-server的服務(wù) enabled: true service-id: config-server name: lyh-provider-user #uri: http://localhost:8080 這里可以是git地址 #trace信息 配置 bus: trace: enabled: true #配合rabbitmq實(shí)現(xiàn)自動(dòng)刷新參數(shù) rabbitmq: #配置rabbitmq實(shí)現(xiàn)自動(dòng)刷新 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)控顯示細(xì)節(jié) refresh: enabled: true endpoints: web: exposure: include: "*" #放開所有地址，跳過安全攔截 base-path: /
客戶端測試代碼，@RefreshScope注解實(shí)現(xiàn)參數(shù)的刷新
@RestController
@RefreshScope
public class UserController {
@Value("${profile}")
private String profile;
@GetMapping (value = "/profile")
public String getProfile(){
return this.profile;
}
}
訪問后我們就能拿到config服務(wù)的profile配置上數(shù)據(jù)
到此這篇關(guān)于springcloud組件技術(shù)分享的文章就介紹到這了,更多相關(guān)springcloud組件內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
IDEA最新版2020.1的maven工程本地依賴倉庫無法使用問題(已解決)
這篇文章主要介紹了IDEA最新版2020.1的maven工程本地依賴倉庫無法使用問題，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-06-06
解決SpringBoot項(xiàng)目讀取yml文件中值為中文時(shí),在視圖頁面顯示亂碼
這篇文章主要介紹了解決SpringBoot項(xiàng)目讀取yml文件中值為中文時(shí),在視圖頁面顯示亂碼的問題,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-08-08
java 用redisTemplate 的 Operations存取list集合操作
這篇文章主要介紹了java 用redisTemplate 的 Operations存取list集合操作，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-08-08
java多線程累加計(jì)數(shù)的實(shí)現(xiàn)方法
在多線程協(xié)作任務(wù)中,如何計(jì)算也是很重的，這篇文章主要介紹了java多線程累加計(jì)數(shù)的實(shí)現(xiàn)方法，感興趣的朋友可以了解一下2021-05-05
關(guān)于swagger配置及踩坑@Api參數(shù)postion無效解決接口排序問題
這篇文章主要介紹了關(guān)于swagger配置及踩坑@Api參數(shù)postion無效解決接口排序問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-06-06
SpringBoot整合JPA框架實(shí)現(xiàn)過程講解
在開發(fā)中，我們通常會對數(shù)據(jù)庫的數(shù)據(jù)進(jìn)行操作，Sprirng?Boot對關(guān)系型數(shù)據(jù)庫和非關(guān)系型數(shù)據(jù)庫的訪問操作都提供了非常好的整合支持2022-12-12
Java消息摘要算法MAC實(shí)現(xiàn)與應(yīng)用完整示例
這篇文章主要介紹了Java消息摘要算法MAC實(shí)現(xiàn)與應(yīng)用,結(jié)合完整實(shí)例形式分析了java消息摘要算法MAC的概念、原理、實(shí)現(xiàn)方法及相關(guān)操作注意事項(xiàng),需要的朋友可以參考下2019-09-09
java中如何對arrayList按數(shù)字大小逆序排序
這篇文章主要介紹了java中如何對arrayList按數(shù)字大小逆序排序問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-04-04
SpringBoot整合Shiro兩種方式(總結(jié))
這篇文章主要介紹了SpringBoot整合Shiro兩種方式，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-06-06
Spring MVC實(shí)現(xiàn)文件上傳及優(yōu)化案例解析
本文介紹如何在SpringMVC框架中實(shí)現(xiàn)文件上傳和異步登錄功能,通過添加必要的依賴和配置,創(chuàng)建文件上傳頁面和控制器,實(shí)現(xiàn)文件上傳到指定文件夾,同時(shí),展示了如何使用AJAX實(shí)現(xiàn)局部刷新的異步登錄,優(yōu)化用戶體驗(yàn),詳細(xì)步驟包括配置springmvc.xml、編寫前端頁面和控制器等2024-10-10