spring-cloud(五)路由閘道器(zuul)(Finchley版本)
在微服務架構中,需要幾個基礎的服務治理元件,包括服務註冊與發現、服務消費、負載均衡、斷路器、智慧路由、配置管理等,由這幾個基礎元件相互協作,共同組建了一個簡單的微服務系統
在Spring Cloud微服務系統中,一種常見的負載均衡方式是,客戶端的請求首先經過負載均衡(zuul、Ngnix),再到達服務閘道器(zuul叢集),然後再到具體的服。,服務統一註冊到高可用的服務註冊中心叢集,服務的所有的配置檔案由配置服務管理(下一篇文章講述),配置服務的配置檔案放在git倉庫,方便開發人員隨時改配置
Zuul的主要功能是路由轉發和過濾器。路由功能是微服務的一部分,比如/api/user轉發到到user服務,/api/shop轉發到到shop服務。zuul預設和Ribbon結合實現了負載均衡的功能。
zuul有以下功能:
- Authentication
- Insights
- Stress Testing
- Canary Testing
- Dynamic Routing
- Service Migration
- Load Shedding
- Security
- Static Response handling
- Active/Active traffic management
建立service-zuul工程
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> <groupId>com.xuxu</groupId> <artifactId>zuul-server</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <parent> <groupId>com.xuxu</groupId> <artifactId>springcloud01</artifactId> <version>1.0-SNAPSHOT</version> </parent> <dependencies> <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-netflix-zuul</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies> </project>
application.yml
eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ server: port: 8769 spring: application: name: zuul-server zuul: routes: api-a: path: /api-a/** serviceId: ribbon-server api-b: path: /api-b/** serviceId: feign-server
首先指定服務註冊中心的地址為http://localhost:8761/eureka/,服務的埠為8769,服務名為zuul-service;以/api-a/ 開頭的請求都轉發給ribbon-server服務;以/api-b/開頭的請求都轉發給feign-service服務;
啟動類中新增 @EnableZuulProxy
@SpringBootApplication
@EnableZuulProxy
@EnableDiscoveryClient
@EnableEurekaClient
public class ZuulServerApplication {
public static void main(String[] args) {
SpringApplication.run(ZuulServerApplication.class, args);
}
}
啟動所有服務
這說明zuul起到了路由的作用
zuul不僅只是路由,並且還能過濾,做一些安全驗證
@Component
public class Myfilter extends ZuulFilter {
@Override
public String filterType() {
return "pre";
}
@Override
public int filterOrder() {
return 0;
}
@Override
public boolean shouldFilter() {
return true;
}
@Override
public Object run() throws ZuulException {
RequestContext requestContext = RequestContext.getCurrentContext();
HttpServletRequest request = requestContext.getRequest();
String method = request.getMethod();
String url = request.getRequestURL().toString();
int port = request.getLocalPort();
System.out.println("request--:"+url+"--method--:"+method+"--port--:"+port);
Object token = request.getParameter("token");
if(token==null){
requestContext.setSendZuulResponse(false);
requestContext.setResponseStatusCode(401);
String error = "token is null";
try {
Writer wirter = requestContext.getResponse().getWriter();
wirter.write(error);
wirter.close();
} catch (IOException e) {
}
}
return null;
}
}
filterType:返回一個字串代表過濾器的型別,在zuul中定義了四種不同生命週期的過濾器型別,具體如下:
- pre:路由之前
- routing:路由之時
- post: 路由之後
- error:傳送錯誤呼叫
filterOrder:過濾的順序
shouldFilter:這裡可以寫邏輯判斷,是否要過濾,本文true,永遠過濾。
run:過濾器的具體邏輯。可用很複雜,包括查sql,nosql去判斷該請求到底有沒有許可權訪問。
訪問http://localhost:8769/api-a/hi?name=123
訪問http://localhost:8769/api-a/hi?name=123&token=123