|
Springcloud技術(shù)分享 Spring Cloud 是一套完整的微服務(wù)解決方案,，基于 Spring Boot 框架,，準確的說,，它不是一個框架,，而是一個大的容器,，它將市面上較好的微服務(wù)框架集成進來，從而簡化了開發(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ā)得比較好的模塊集成進去,，進行封裝,，從而減少了各模塊的開發(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)建微服務(wù)架構(gòu),。
大型公司基本都有自己的分布式解決方案,，而中小型公司的架構(gòu)很多用不上微服務(wù)，所以沒有采用 Spring Cloud 的必要性,。
但是,，微服務(wù)架構(gòu)是一個趨勢，而 Spring Cloud 是微服務(wù)解決方案的佼佼者,，這也是作者寫本系列課程的意義所在,。 Spring Cloud 優(yōu)缺點 其主要優(yōu)點有：
集大成者，Spring Cloud 包含了微服務(wù)架構(gòu)的方方面面,。
約定優(yōu)于配置,，基于注解，沒有配置文件,。
輕量級組件,，Spring Cloud 整合的組件大多比較輕量級，且都是各自領(lǐng)域的佼佼者,。
開發(fā)簡便,，Spring Cloud 對各個組件進行了大量的封裝,，從而簡化了開發(fā),。
開發(fā)靈活，Spring Cloud 的組件都是解耦的,，開發(fā)人員可以靈活按需選擇組件,。
接下來，我們看下它的缺點：
項目結(jié)構(gòu)復(fù)雜,，每一個組件或者每一個服務(wù)都需要創(chuàng)建一個項目,。
部署門檻高，項目部署需要配合 Docker 等容器技術(shù)進行集群部署,，而要想深入了解 Docker,，學習成本高。
Spring Cloud 的優(yōu)勢是顯而易見的,。因此對于想研究微服務(wù)架構(gòu)的同學來說,，學習 Spring Cloud 是一個不錯的選擇。 Spring Cloud 和 Dubbo 對比 Dubbo 只是實現(xiàn)了服務(wù)治理,，而 Spring Cloud 實現(xiàn)了微服務(wù)架構(gòu)的方方面面,，服務(wù)治理只是其中的一個方面,。下面通過一張圖對其進行比較： 
下面我們就簡單的進行springcloud的學習吧，本文章涉及springcloud的相關(guān)重要組件的使用,。 1. 項目初始化配置1. 1. 新建maven工程 使用idea創(chuàng)建maven項目 1. 2. 在parent項目pom中導(dǎo)入以下依賴 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | <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. EurekaEureka是Spring Cloud Netflix的核心組件之一,，其還包括Ribbon、Hystrix,、Feign這些Spring Cloud Netflix主要組件,。其實除了eureka還有些比較常用的服務(wù)發(fā)現(xiàn)組件如Consul，Zookeeper等,，目前對于springcloud支持最好的應(yīng)該還是eureka,。 eureka組成 1 2 3 | Eureka Server：服務(wù)的注冊中心，負責維護注冊的服務(wù)列表,。
Service Provider：服務(wù)提供方,，作為一個Eureka Client，向Eureka Server做服務(wù)注冊,、續(xù)約和下線等操作,，注冊的主要數(shù)據(jù)包括服務(wù)名、機器ip,、端口號,、域名等等。
Service Consumer：服務(wù)消費方,，作為一個Eureka Client,，向Eureka Server獲取Service Provider的注冊信息，并通過遠程調(diào)用與Service Provider進行通信,。
|
2. 1. 創(chuàng)建子module,，命名為eureka-server 2. 2. 在eureka-server中添加以下依賴 1 2 3 4 5 6 7 8 9 10 11 12 | <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中添加以下配置 1 2 3 4 5 6 7 8 9 10 11 12 13 14 | 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. 在啟動類上架注解 1 2 | @SpringBootApplication
@EnableEurekaServer
|
在啟動類中加入以下方法,防止spring的Auth攔截eureka請求 1 2 3 4 5 6 7 8 | @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中添加以下依賴 1 2 3 4 5 6 7 8 | <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配置 1 2 3 4 5 6 7 8 9 | server:
port: 7900 #程序啟動入口
spring:
application:
name: provider-user #應(yīng)用名稱
eureka:
client:
service-url:
defaultZone: http://user:123@${eureka.instance.hostname}:${server.port}/eureka/
|
2. 5. 3. 啟動類加注解 1 2 | @SpringBootApplication
@EnableEurekaClient
|
Controller相關(guān)代碼如下： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 | @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配置 1 2 3 4 5 6 7 8 9 | server:
port: 8010
spring:
application:
name: consumer-order
eureka:
client:
serviceUrl:
defaultZone: http://user:123@${eureka.instance.hostname}:${server.port}/eureka/
|
2. 6. 3. 啟動類 1 2 3 4 5 6 7 8 9 10 11 12 13 | @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層代碼 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 | @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());
return user;
}
}
|
2. 7. 啟動應(yīng)用 分別啟動Eureka-server、provider-user,、consumer-order三個服務(wù) 2. 8. 訪問地址 http://localhost:8900就可以看到兩個服務(wù)已經(jīng)注冊到eureka注冊中心上了 2. 9. eureka高可用配置 兩個節(jié)點 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 | #高可用配置,，兩個節(jié)點
spring:
application:
name: eureka-server-ha
profiles:
active: peer1
eureka:
client:
serviceUrl:
---
server:
port: 8901
spring:
profiles: peer1
eureka:
instance:
hostname: peer1
---
server:
port: 8902
spring:
profiles: peer2
eureka:
instance:
hostname: peer2
|
三個節(jié)點 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 | #高可用配置，三個
spring:
application:
name: eureka-server-ha
profiles:
active: peer3
eureka:
client:
serviceUrl:
---
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 具備了負載均衡的功能 1 2 3 4 5 | @Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}
|
在啟動類上加注解 1 | @RibbonClient(name = "provider-user")
|
3. 2. 方式二(配置文件自定義) 在application.yml中加入以下配置 1 2 3 4 | #使用配置文件方式實現(xiàn)負載均衡，優(yōu)先級,，配置文件>注解或java代碼配置>cloud默認配置
provider-user:
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
|
3. 3. 方式三(Java代碼自定義) 自定義一個配置類,，返回規(guī)則 1 2 3 4 5 6 7 | @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請求遠程服務(wù)時能與調(diào)用本地方法一樣的編碼體驗,，開發(fā)者完全感知不到這是遠程方法，更感知不到這是個HTTP請求,，這整個調(diào)用過程和Dubbo的RPC非常類似,。開發(fā)起來非常的優(yōu)雅。 4. 1. 引入依賴 1 2 3 4 | <dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
|
4. 2. 使用注解@FeignClient編寫feign調(diào)用的客戶端接口 1 2 3 4 5 6 7 | @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)用方法 1 2 3 4 5 6 7 8 9 10 11 | @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的一個類庫，在微服務(wù)中，具有多層服務(wù)調(diào)用,，主要實現(xiàn)斷路器模式的類庫 5. 1. 引入依賴 1 2 3 4 | <dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
|
5. 2. 在啟動類上加注解 在Controller層類的方法上加注解，并編寫退回方法,，需同名 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | @HystrixCommand(fallbackMethod = "findByIdFallBack")
public User getOrder(@PathVariable Long id){
//獲取數(shù)據(jù)
User user = new User();
user.setId(id);
user.setDate(new Date());
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)控actuatoractuator主要用于服務(wù)健康監(jiān)控,springboot 1.X和2.x有所不同，本次為2.X 6. 1. 引入依賴包 1 2 3 4 | <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
|
6. 2. 配置 1 2 3 4 5 6 7 8 9 10 | #健康監(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版本 2.X版本 1 | localhost:8080/actuator/health
|
7. feign配合Hystrix使用 7. 1. 配置文件 1 2 3 | feign:
hystrix:
enabled: true # 總開關(guān),，可以通過java單獨控制client
|
7. 2. 啟動類注解 7. 3. 控制層 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 | @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 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | @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;
}
}
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | @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. 配置類 1 2 3 4 5 6 7 8 9 | @Configuration
public class ConfigurationNotHystrix {
@Bean
@Scope("prototype")
public Feign.Builder feignBuilder(){
return Feign.builder();
}
}
|
7. 6. 獲取異常信息代碼 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 | @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. ZuulZuul是Spring Cloud全家桶中的微服務(wù)API網(wǎng)關(guān),。 所有從設(shè)備或網(wǎng)站來的請求都會經(jīng)過Zuul到達后端的Netflix應(yīng)用程序。作為一個邊界性質(zhì)的應(yīng)用程序,，Zuul提供了動態(tài)路由,、監(jiān)控、彈性負載和安全功能,。Zuul底層利用各種filter實現(xiàn)如下功能： 認證和安全 識別每個需要認證的資源,，拒絕不符合要求的請求。
性能監(jiān)測 在服務(wù)邊界追蹤并統(tǒng)計數(shù)據(jù),，提供精確的生產(chǎn)視圖,。
動態(tài)路由 根據(jù)需要將請求動態(tài)路由到后端集群,。
壓力測試 逐漸增加對集群的流量以了解其性能,。
負載卸載 預(yù)先為每種類型的請求分配容量，當請求超過容量時自動丟棄,。
靜態(tài)資源處理 直接在邊界返回某些響應(yīng),。 8. 1. 編寫一個Zuul網(wǎng)關(guān) 1 2 3 4 5 6 7 8 9 10 11 12 13 14 | @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 配置 1 2 3 4 | zuul:
ignoredServices: '*' #剔除的鏈接，*代表所有
routes:
lyh-provider-user: /myusers/** #自定義的反向代理url
|
8. 2. Zuul的fallback機制 需要實現(xiàn)回退的接口FallbackProvider,，當服務(wù)不可用時,，就會走fallback，源碼如下 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 | @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 {
//當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 {
//響應(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在整個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服務(wù)器上的一組指定的目錄中，這些目錄將被定期輪詢檢查是否更新,。Zuul會讀取已更新的過濾器,，動態(tài)編譯到正在運行的服務(wù)器中，并后續(xù)請求中調(diào)用,。 8. 3. 2. Filter Types 以下提供四種標準的Filter類型及其在請求生命周期中所處的位置： PRE Filter：在請求路由到目標之前執(zhí)行,。一般用于請求認證、負載均衡和日志記錄,。
ROUTING Filter：處理目標請求,。這里使用Apache HttpClient或Netflix Ribbon構(gòu)造對目標的HTTP請求。
POST Filter：在目標請求返回后執(zhí)行,。一般會在此步驟添加響應(yīng)頭,、收集統(tǒng)計和性能數(shù)據(jù)等。
ERROR Filter：整個流程某塊出錯時執(zhí)行,。
除了上述默認的四種Filter類型外,，Zuul還允許自定義Filter類型并顯示執(zhí)行。例如,，我們定義一個STATIC類型的Filter,，它直接在Zuul中生成一個響應(yīng)，而非將請求在轉(zhuǎn)發(fā)到目標,。 8. 3. 3. Zuul請求生命周期 
一圖勝千言,，下面通過官方的一張圖來了解Zuul請求的生命周期。
8. 3. 4. 自定義一個filter 需要繼承ZuulFilter類 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 | 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注入 1 2 3 4 | @Bean
public PreZuulFilter preZuulFilter(){
return new PreZuulFilter();
}
|
filter配置 1 2 3 4 | zuul:
PreZuulFilter: #過濾器類名
pre: #過濾類型
disable: false
|
8. 3. 5. zuul上傳下載 zuul一樣可以正常的上傳下載,，要注意的是他使用的是默認大小配置,，想要上傳大文件 需要在訪問的地址前加/zuul/服務(wù)地址，同時需要配置超時時間 1 2 3 4 5 | #當上傳大文件是在serviceid前加zuul/ 如：zuul/servcieid/*,且需要配置ribbon的超時時間和hystrix的超時時間,，防止報錯后走hystrix的退回代碼
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 60000
ribbon:
ConnectTimeout: 3000
ReadTimeout: 60000
|
9. springCloud的Config9. 1. 什么是spring cloud config 在分布式系統(tǒng)中,，spring cloud config 提供一個服務(wù)端和客戶端去提供可擴展的配置服務(wù)。我們可用用配置服務(wù)中心區(qū)集中的管理所有的服務(wù)的各種環(huán)境配置文件。配置服務(wù)中心采用Git的方式存儲配置文件,，因此我們很容易部署修改,，有助于對環(huán)境配置進行版本管理。 Spring Cloud Config就是云端存儲配置信息的,它具有中心化,版本控制,支持動態(tài)更新,平臺獨立,語言獨立等特性,。其特點是： 1 2 3 4 5 | 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.默認實現(xiàn)基于git倉庫，可以進行版本管理
|
spring cloud config包括兩部分： spring cloud config server 作為配置中心的服務(wù)端 拉取配置時更新git倉庫副本,，保證是最新結(jié)果 支持數(shù)據(jù)結(jié)構(gòu)豐富,，yml, json, properties 等 配合 eureke 可實現(xiàn)服務(wù)發(fā)現(xiàn)，配合 cloud bus 可實現(xiàn)配置推送更新 配置存儲基于 git 倉庫,，可進行版本管理 簡單可靠,，有豐富的配套方案 Spring Cloud Config Client 客戶端
Spring Boot項目不需要改動任何代碼，加入一個啟動配置文件指明使用ConfigServer上哪個配置文件即可 9. 2. 簡單的使用 服務(wù)端配置使用 首先需要添加相關(guān)依賴 1 2 3 4 5 6 7 8 | <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>
|
啟動類 1 2 3 4 5 6 7 8 9 10 | @SpringBootApplication
@EnableEurekaClient
@EnableConfigServer
public class SpringCloudConfigApp
{
public static void main( String[] args )
{
SpringApplication.run(SpringCloudConfigApp.class,args);
}
}
|
本地方式配合Eureka配置 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | 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)建文件 1 2 3 4 5 6 7 | lyh-provider-user-dev.yml
內(nèi)容為：
profile: lyh-provider-user-dev
lyh-provider-user-pro.yml
內(nèi)容為：
profile: lyh-provider-user-pro
|
客戶端配置 添加依賴 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 | <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>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 | server:
port: 7900 #程序啟動入口
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實現(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ù)的刷新 1 2 3 4 5 6 7 8 9 10 | @RestController
@RefreshScope
public class UserController {
@Value("${profile}")
private String profile;
@GetMapping (value = "/profile")
public String getProfile(){
return this.profile;
}
}
|
訪問后我們就能拿到config服務(wù)的profile配置上數(shù)據(jù)
|
