【SpringCloud】15网关Zuul了解一下promiseful的博客-

3. 优点

a: 解决耦合,减少了客户端与各个微服务之间的交互次数。

b: 易于监控,可在微服务网关收集监控数据并将其推送到外部系统进行分析。

c: 易于认证。可在微服务网关上进行认证,然后再将请求转发到后端的微服务,无须在每个微服务中进行认证。

二、Zuul网关

1、Zuul 是Netflix开源的一个API网关,本质上是一个Web Servlet应用。Zuul也是Spring Cloud全家桶中的一员, 它可以和Eureka(注册中心)、Ribbon(负载均衡)、Hystrix(限流)等组件配合使用。

2、代码托管地址

3、核心功能 过滤器

1. 验证与安全保障: 识别面向各类资源的验证要求并拒绝与要求不符的请求。

2. 审查与监控: 在边缘位置追踪有意义数据及统计结果,从而带来准确的生产状态结论。

3. 动态路由: 以动态方式根据需要将请求路由至不同后端集群处。

4. 压力测试: 逐渐增加指向集群的负载流量,从而计算性能水平。

5. 负载分配: 为每一种负载类型分配对应容量，并弃用超出限定值的请求。

6. 静态响应处理: 在边缘位置直接建立部分响应，从而避免其流入内部集群。

7. 注：以上介绍来自Zuul官方文档,但其实开源版本的Zuul以上功能一个都没有——开源的Zuul只是几个Jar包而已,以上能力指的应该是Netflix官方自用的Zuul的能力。

4、小试牛刀

1. 基于Spring boot 搭建 goods server、orders server

2. 依赖

<dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-zuul</artifactId> <version>2.2.2.RELEASE</version> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> <version>2.2.2.RELEASE</version> </dependency> </dependencies> 

3. 配置文件

application.yml spring:   application:     name: zuul-service  eureka:   client:     service-url:       defaultZone: http://localhost:8761/eureka  server:   port: 6069 

4. 启动代理

import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.zuul.EnableZuulProxy; @SpringBootApplication @EnableZuulProxy public class ZuulServiceApplication { public static void main(String[] args) {         SpringApplication.run(ZuulServiceApplication.class, args); } } 

5. 启动Eureka 、Zuul 、启动两个服务 goods server、orders server

6. 访问

https://localhost:8081/orders-server/goods

https://localhost:8082/goods-server/orders

5、ZuulFilter接口

1. filterType：过滤器的类型(Type)它决定过滤器在请求的哪个生命周期中执行。

2. filterOrder：过滤器的执行顺序(Execution Order)当请求在一个阶段中存在多个过滤器时,需要根据该方法返回的值来依次执行。

3. shouldFilter：判断该过滤器是否需要被执行(Criteria)这里我们直接返回了true,因此该过滤器对所有的请求都生效。生产环境根据需求+函数判断。

4. run：过滤器的具体执行逻辑(Action)

6、ZuulFilter 代码实现

 package com.haoxiansheng.springcloud.filter; import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.exception.ZuulException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import javax.servlet.http.HttpServletRequest; import java.io.IOException; import java.util.Objects; /**  * @author haoxiansheng  */ @Component public class LoginFilter extends ZuulFilter {     Logger logger = LoggerFactory.getLogger(getClass()); /**      *  请求路由前调用      * @return      */ @Override public String filterType() { return "pre"; } /**      * int 值来定义过滤器的执行顺序，数值越小优先级越高      * @return      */ @Override public int filterOrder() { return 0; } /**      * 该过滤器是否执行， true 执行 false 不执行      * @return      */ @Override public boolean shouldFilter() { return true; } /**      * 业务逻辑      * @return      * @throws ZuulException      */ @Override public Object run() throws ZuulException {         RequestContext context = RequestContext.getCurrentContext();         HttpServletRequest request = context.getRequest(); //获取请求参数token的值         String token =request.getParameter("token"); if (Objects.isNull(token)){             logger.warn("此操作需要先登录系统。。。");             context.setSendZuulResponse(false);             context.setResponseStatusCode(200); try { //响应结果                 context.getResponse().getWriter().write("token is empty"); } catch (IOException e){                 e.printStackTrace(); } return null; }         logger.info("ok"); return null; } } 

7、启动再次测试

1. 不正确的访问

https://localhost:8082/goods-server/orders
响应 401

2. 正确访问

https://localhost:8082/goods-server/orders?accessToken=flame
响应 成功

8、Filter的生命周期