在Spring Cloud微服務(wù)系統(tǒng)中，一種常見的負載均衡方式是，客戶端的請求首先經(jīng)過負載均衡（zuul账忘、Ngnix）惭每，再到達服務(wù)網(wǎng)關(guān)（zuul集群），然后再到具體的服務(wù)围段。服務(wù)統(tǒng)一注冊到高可用的服務(wù)注冊中心集群顾翼，服務(wù)的所有的配置文件由配置服務(wù)管理（下一篇文章講述），配置服務(wù)的配置文件放在git倉庫奈泪，方便開發(fā)人員隨時改配置适贸。
一、zuul簡介
Zuul的主要功能是路由轉(zhuǎn)發(fā)和過濾器涝桅。路由功能是微服務(wù)的一部分拜姿，比如／api/account轉(zhuǎn)發(fā)到到account服務(wù)，/api/shop轉(zhuǎn)發(fā)到到shop服務(wù)冯遂。zuul默認和Ribbon結(jié)合實現(xiàn)了負載均衡的功能蕊肥。
- Authentication
- Insights
- Stress Testing
- Canary Testing
- Dynamic Routing
- Service Migration
- Load Shedding
- Security
- Static Response handling
- Active/Active traffic management
創(chuàng)建項目和別的服務(wù)模塊類似，添加pom組件增加：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</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-zuul</artifactId>
</dependency>
在其入口applicaton類加上注解@EnableZuulProxy蛤肌，開啟zuul的功能：
@EnableZuulProxy
@EnableEurekaClient
@SpringBootApplication
public class ServiceZuulApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceZuulApplication.class, args);
}
}
配置文件application.yml配上以下代碼：
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
server:
port: 8769
spring:
application:
name: service-zuul
zuul:
routes:
api-a:
path: /api-a/**
serviceId: service-ribbon
api-b:
path: /api-b/**
serviceId: service-feign
首先指定服務(wù)注冊中心的地址為http://localhost:8761/eureka/壁却，服務(wù)的端口為8769，服務(wù)名為service-zuul裸准；以/api-a/ 開頭的請求都轉(zhuǎn)發(fā)給service-ribbon服務(wù)展东；以/api-b/開頭的請求都轉(zhuǎn)發(fā)給service-feign服務(wù)；
二炒俱、服務(wù)過濾：
一個簡單的安全驗證：
@Component
public class MyFilter extends ZuulFilter{
private static Logger log = LoggerFactory.getLogger(MyFilter.class);
@Override
public String filterType() {
return "pre";
}
@Override
public int filterOrder() {
return 0;
}
@Override
public boolean shouldFilter() {
return true;
}
@Override
public Object run() {
RequestContext ctx = RequestContext.getCurrentContext();
HttpServletRequest request = ctx.getRequest();
log.info(String.format("%s >>> %s", request.getMethod(), request.getRequestURL().toString()));
Object accessToken = request.getParameter("token");
if(accessToken == null) {
log.warn("token is empty");
ctx.setSendZuulResponse(false);
ctx.setResponseStatusCode(401);
try {
ctx.getResponse().getWriter().write("token is empty");
}catch (Exception e){}
return null;
}
log.info("ok");
return null;
}
}
- filterType：返回一個字符串代表過濾器的類型盐肃，在zuul中定義了四種不同生命周期的-過濾器類型，具體如下：
- pre：路由之前
- routing：路由之時
- post： 路由之后
- error：發(fā)送錯誤調(diào)用
- filterOrder：過濾的順序
- shouldFilter：這里可以寫邏輯判斷权悟，是否要過濾砸王，本文true,永遠過濾。
- run：過濾器的具體邏輯僵芹〈τ玻可用很復(fù)雜，包括查sql拇派，nosql去判斷該請求到底有沒有權(quán)限訪問荷辕。
