<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.sam</groupId>
 <artifactId>api-gateway</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>1.5.1.RELEASE</version>
 </parent>
 <properties>
  <javaVersion>1.8</javaVersion>
 </properties>
 <!-- 使用dependencyManagement進(jìn)行版本管理 -->
 <dependencyManagement>
  <dependencies>
   <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-dependencies</artifactId>
    <version>Camden.SR6</version>
    <type>pom</type>
    <scope>import</scope>
   </dependency>
  </dependencies>
 </dependencyManagement>
 <dependencies>
  <!-- 引入zuul依賴 , 它依賴了spring-boot-starter-actuator/spring-boot-starter-hystrix/spring-boot-starter-ribbon-->
  <dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-zuul</artifactId>
  </dependency>
 </dependencies>
</project>

/**
 * @EnableZuulProxy 開(kāi)啟Zuul 的API網(wǎng)關(guān)服務(wù)功能
 *
 */
@EnableZuulProxy
@SpringCloudApplication
public class GateWayApp {

 public static void main(String[] args) {
  SpringApplication.run(GateWayApp.class, args);
 }
}

server.port=5555
spring.application.name=api-gateway
#增加路由規(guī)則的配置
#通過(guò)zuul.routes.<route>.path和zuul.routes.<route>.url進(jìn)行配置，<route>為路由的名字，可以任意指定，但是一組path和url的路由名要相同
#如下面的例子：所有滿足/api-a/** 規(guī)則的訪問(wèn)都會(huì)被路由轉(zhuǎn)發(fā)到//localhost:9001的地址
#也就是說(shuō)，我們?cè)L問(wèn)http://localhost:5555/api-a/hello的時(shí)候，API網(wǎng)關(guān)服務(wù)就會(huì)將該請(qǐng)#求路由到 http://localhost:9001/hello提供的微服務(wù)接口上
zuul.routes.api-a.path=/api-a/**
zuul.routes.api-a.url=http://localhost:9001
zuul.routes.api-b.path=/api-b/**
zuul.routes.api-b.url=http://localhost:9090

<!-- 引入eureka依賴 -->
  <dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-eureka</artifactId>
  </dependency>

server.port=5555
spring.application.name=api-gateway
zuul.routes.api-a.path=/api-a/**
#這里用serviceId代替url，用服務(wù)名代替ip+端口號(hào)
zuul.routes.api-a.serviceId=hello-service
eureka.client.service-url.defaultZone=http://localhost:1111/eureka

zuul.routes.hello-service.path=/hello-service/**
zuul.routes.hello-service.serviceId=hello-service

server.port=5555
spring.application.name=api-gateway
eureka.client.service-url.defaultZone=http://localhost:1111/eureka

/**
 * 繼承ZuulFilter，并且實(shí)現(xiàn)其4個(gè)接口
 *
 * 用來(lái)進(jìn)行請(qǐng)求過(guò)濾
 *
 */
public class AccessFilter extends ZuulFilter {
 Logger logger = LoggerFactory.getLogger(AccessFilter.class);
 /* 
  * shouldFilter 判斷該過(guò)濾器是否需要被執(zhí)行
  * 
  * 這里直接返回true，表示該過(guò)濾器對(duì)所有請(qǐng)求都會(huì)生效。
  * 實(shí)際運(yùn)用中我們可以利用該函數(shù)指定過(guò)濾器的有效范圍
  */
 @Override
 public boolean shouldFilter() {
  return true;
 }
 /*
  * 過(guò)濾器的具體邏輯
  * 
  * 這里我們通過(guò)ctx.setSendZuulResponse(false)讓zuul過(guò)來(lái)請(qǐng)求，不對(duì)其進(jìn)行路由
  * 然后通過(guò)ctx.setResponseStatusCode(401)設(shè)置了返回的錯(cuò)誤碼
  * 
  */
 @Override
 public Object run() {
  RequestContext context = RequestContext.getCurrentContext();
  HttpServletRequest request = context.getRequest();
  Object accessToken = request.getParameter("accessToken");
  logger.info("send {} request to {}", request.getMethod(),request.getRequestURL().toString());
  if(accessToken == null) {
   context.setSendZuulResponse(false);
   context.setResponseStatusCode(401);
  }
  return null;
 }
 /* filterType 返回過(guò)濾器類型
  * 他決定了過(guò)濾器在請(qǐng)求的哪個(gè)生命周期中執(zhí)行。這里定義為pre，代表會(huì)在請(qǐng)求被路由前執(zhí)行。
  * 
  * pre:請(qǐng)求執(zhí)行之前filter 
  * route: 處理請(qǐng)求，進(jìn)行路由 
  * post: 請(qǐng)求處理完成后執(zhí)行的filter 
  * error:出現(xiàn)錯(cuò)誤時(shí)執(zhí)行的filter
  */
 @Override
 public String filterType() {
  return "pre";
 }
 /* 
  * filterOrder 返回過(guò)濾器的執(zhí)行順序
  * 
  * 當(dāng)請(qǐng)求在一個(gè)階段有多個(gè)過(guò)濾器是，需要根據(jù)該方法的返回值來(lái)一次執(zhí)行
  * 
  */
 @Override
 public int filterOrder() {
  return 0;
 }
}

/**
 * @EnableZuulProxy 開(kāi)啟Zuul 的API網(wǎng)關(guān)服務(wù)功能
 *
 */
@EnableZuulProxy
@SpringCloudApplication
public class GateWayApp {
 //追加bean的是實(shí)現(xiàn)
 @Bean
 public AccessFilter accessFilter() {
  return new AccessFilter();
 }
 
 public static void main(String[] args) {
  SpringApplication.run(GateWayApp.class, args);
 }
}