場景
SpringCloud-使用熔斷器儀表盤監控熔斷:
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/102673599
SpringCloud -創建統一的依賴管理:
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/102530574
上面在實作了使用熔斷儀表盤進行監控熔斷后,使用路由網關統一訪問介面,
API網關
API網關負責請求路由、組合和協議轉發,所有的客戶端請求首先要通過API網關,之后請求被路由到適當的服務,
API網關通常會呼叫多個微服務和聚合結果來處理一個請求,它可以在Web協議(如HTTP和WebSocket)和利用于內部的非Web友好協議之間進行轉換,
負載均衡方式
在Spring Cloud微服務系統中,一種常見的負載均衡方式是:客戶端的請求先經過負載均衡(Zuul、Nginx),再到達服務網關(Zuul集群),然后再到具體的服務,服務統一注冊到高可用的服務注冊中心集群,服務的所有的組態檔放在Git倉庫,方便開發人員隨時改配置,
Zuul簡介
Zuul的主要功能是路由轉發和過濾器,路由功能是微服務的一部分,
Zuul默認和Ribbon結合實作了負載均衡的功能,
注:
博客:
https://blog.csdn.net/badao_liumang_qizhi
關注公眾號
霸道的程式猿
獲取編程相關電子書、教程推送與免費下載,
實作
參考上面構建專案的方式,依次建立目錄hello-spring-cloud-zuul目錄以及在
目錄下新建pom.xml,并將其托管,然后新建src/main/java目錄和src/main/resources目錄并分別進行目錄設定,
然后在java下新建包,包下新建啟動類,在resources下新建組態檔application.yml,
完成后的目錄為:

pom.xml代碼
<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>com.badao</groupId> <artifactId>hello-spring-cloud-dependencies</artifactId> <version>1.0.0-SNAPSHOT</version> <relativePath>../hello-spring-cloud-dependencies/pom.xml</relativePath> </parent> <artifactId>hello-spring-cloud-zuul</artifactId> <packaging>jar</packaging> <name>hello-spring-cloud-zuul</name> <url>https://blog.csdn.net/badao_liumang_qizhi</url> <inceptionYear>2019-Now</inceptionYear> <dependencies> <!-- Spring Boot Begin --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-tomcat</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!-- Spring Boot End --> <!-- Spring Cloud Begin --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-zuul</artifactId> </dependency> <!-- Spring Cloud End --> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <mainClass>com.badao.hello.spring.cloud.zuul.ZuulApplication</mainClass> </configuration> </plugin> </plugins> </build></project>
組態檔application.yml代碼
spring: application: name: hello-spring-cloud-zuulserver: port: 8769eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/zuul: routes: api-a: path: /api/a/** serviceId: hello-spring-cloud-web-admin-ribbon api-b: path: /api/b/** serviceId: hello-spring-cloud-web-admin-feign
注:
以 /api/a 開頭的請求都轉發給 hello-spring-cloud-web-admin-ribbon 服務
以 /api/b 開頭的請求都轉發給 hello-spring-cloud-web-admin-feign 服務
其中routes是固定的,但是api-a與api-b是自己定義的,
在自定義的路由中,path代表請求的路徑,serviceId代表真正映射的服務的Id,
在path中**代表通配符,即以/api/a開頭的都會請求同組內的serviceId所對應的服務,
然后在包下新建com.badao.hello.spring.cloud.zuul包,并在包下新建ZuulApplication啟動類
package com.badao.hello.spring.cloud.zuul;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.EnableEurekaClient;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;@SpringBootApplication@EnableEurekaClient@EnableZuulProxypublic class ZuulApplication { public static void main(String[] args) { SpringApplication.run(ZuulApplication.class, args); }}
至此整個服務體系的結構如下

效果
我們依次啟動Eureka服務、服務提供者、兩個服務消費者、zuul的Application啟動類

然后打開瀏覽器,輸入:
http://localhost:8761/
打開Eureka的服務與注冊發現中心,發現全部被注冊并發現

然后再打開瀏覽器輸入:
http://localhost:8769/api/a/hi?message=HelloZuulFromBadao

再打開瀏覽器輸入:
http://localhost:8769/api/b/hi?message=HelloZuulFromBadao

則Zuul的路由配置功能配置成功,
配置網關路由失敗時的回呼
有時如果因為網路、記憶體等原因導致網關路由失敗,則需要配置失敗時的回呼,
再新建fallback包,包下新建WebAdminFeignFallbackProvider
package com.badao.hello.spring.cloud.zuul.fallback;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;import org.springframework.http.HttpHeaders;import org.springframework.http.HttpStatus;import org.springframework.http.MediaType;import org.springframework.http.client.ClientHttpResponse;import org.springframework.stereotype.Component;import java.io.ByteArrayInputStream;import java.io.IOException;import java.io.InputStream;import java.util.HashMap;import java.util.Map;@Componentpublic class WebAdminFeignFallbackProvider implements FallbackProvider { @Override public String getRoute() { // ServiceId,如果需要所有呼叫都支持回退,則 return "*" 或 return null return "hello-spring-cloud-web-admin-feign"; } /** * 如果請求服務失敗,則回傳指定的資訊給呼叫者 * @param route * @param cause * @return */ @Override public ClientHttpResponse fallbackResponse(String route, Throwable cause) { return new ClientHttpResponse() { /** * 網關向 api 服務請求失敗了,但是消費者客戶端向網關發起的請求是成功的, * 不應該把 api 的 404,500 等問題拋給客戶端 * 網關和 api 服務集群對于客戶端來說是黑盒 * @return * @throws IOException */ @Override public HttpStatus getStatusCode() throws IOException { return HttpStatus.OK; } @Override public int getRawStatusCode() throws IOException { return HttpStatus.OK.value(); } @Override public String getStatusText() throws IOException { return HttpStatus.OK.getReasonPhrase(); } @Override public void close() { } @Override public InputStream getBody() throws IOException { ObjectMapper objectMapper = new ObjectMapper(); Map<String, Object> map = new HashMap<>(); map.put("status", 200); map.put("message", "無法連接,請檢查您的網路"); return new ByteArrayInputStream(objectMapper.writeValueAsString(map).getBytes("UTF-8")); } @Override public HttpHeaders getHeaders() { HttpHeaders headers = new HttpHeaders(); // 和 getBody 中的內容編碼一致 headers.setContentType(MediaType.APPLICATION_JSON_UTF8); return headers; } }; }}
代碼下載
https://download.csdn.net/download/badao_liumang_qizhi/11908425
轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/42037.html
標籤:架構設計
上一篇:資料一致性-對賬
