简介
加入zuul后的架构
快速入门
- 添加Zuul依赖
- 编写zuul启动类
- 编写zuul配置文件
- 编写路由规则
面向服务的路由
- 添加Eureka客户端依赖
- 开启Eureka客户端发现功能
- 添加Eureka配置，获取服务信息
- 修改映射配置，通过服务名称获取
简化的路由配置
过滤器
- 使用场景
- 自定义过滤器

简介

在这里插入图片描述

加入zuul后的架构

在这里插入图片描述
不管是来自于客户端（PC或移动端）的请求，还是服务内部调用。一切对服务的请求都会经过Zuul这个网关，然后再由网关来实现鉴权、动态路由等等操作。Zuul就是我们服务的统一入口。

快速入门

创建zuul服务

添加Zuul依赖

<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>

编写zuul启动类

通过 @EnableZuulProxy 注解开启Zuul的功能：

@SpringBootApplication
@EnableZuulProxy //开启zuul
public class ZuulServiceApplication {public static void main(String[] args) {SpringApplication.run(ZuulServiceApplication.class);}
}

编写zuul配置文件

server:port: 10000
spring:application:name: zuul-service

编写路由规则

zuul:routes:user-service:  #没用path: /user-service/**  # 服务实例IDurl: http://127.0.0.1:8080 # 服务代理的具体地址order-service: #没用path: /order-service/**  # 服务实例IDurl: http://127.0.0.1:9090 # 服务代理的具体地址

面向服务的路由

在刚才的路由规则中，我们把路径对应的服务地址写死了！如果同一服务有多个实例的话，这样做显然就不合理了。
我们应该根据服务的名称，去Eureka注册中心查找服务对应的所有实例列表，然后进行动态路由才对！

添加Eureka客户端依赖

<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

开启Eureka客户端发现功能

在zuul服务启动类加注解@EnableDiscoveryClient //开启euerka客户端发现功能

@SpringBootApplication
@EnableDiscoveryClient //开启euerka客户端发现功能
@EnableZuulProxy //开启zuul
public class ZuulServiceApplication {public static void main(String[] args) {SpringApplication.run(ZuulServiceApplication.class);}
}

添加Eureka配置，获取服务信息

#    Eureka配置-- 目前先注册自己保证不报错
eureka:client:service-url:defaultZone: http://localhost:10086/eureka

修改映射配置，通过服务名称获取

因为已经有了Eureka客户端，我们可以从Eureka获取服务的地址信息，因此映射时无需指定IP地址，而是通过服务名称来访问，而且Zuul已经集成了Ribbon的负载均衡功能。

zuul:routes:order-service:path: /1/**#url: order-service  #无负载serviceId: order-service #有负载

简化的路由配置

我们关于user-service的配置可以简化为一条：

zuul:routes:order-service: /1/**user-service: /2/**

省去了对服务名称的配置。

过滤器

Zuul作为网关的其中一个重要功能，就是实现请求的鉴权。而这个动作我们往往是通过Zuul提供的过滤器来实现的。

使用场景

场景非常多：

请求鉴权：一般放在pre类型，如果发现没有访问权限，直接就拦截了
异常处理：一般会在error类型和post类型过滤器中结合来处理。
服务调用时长统计：pre和post结合使用。

自定义过滤器

接下来我们来自定义一个过滤器，模拟一个登录的校验。基本逻辑：如果请求中有access-token参数，则认为请求有效，放行。
创建一个LoginFilter：

@Component
@Log4j2
public class LoginFilter extends ZuulFilter {@Overridepublic String filterType() {return FilterConstants.PRE_TYPE;}@Overridepublic int filterOrder() {return -1;}@Overridepublic boolean shouldFilter() {return true;}@SneakyThrows@Overridepublic Object run() throws ZuulException {log.warn("========================================");//1）获取Zuul提供的请求上下文对象RequestContext ctx = RequestContext.getCurrentContext();//2）从上下文中获取request对象HttpServletRequest request = ctx.getRequest();HttpServletResponse response = ctx.getResponse();response.setContentType("application/json;charset=utf-8");// 3) 从请求中获取token//获取tokenString token = request.getHeader("token");log.info("token:{}",token);String requestURI = request.getRequestURI();if(requestURI.equals("/1/login")){return null;}//判断token是否正常if(StringUtils.isEmpty(token)){Result result = new Result(401,"token丢失");String json = new ObjectMapper().writeValueAsString(result);// 没有token，登录校验失败，拦截ctx.setSendZuulResponse(false);// 返回401状态码（未授权）。也可以考虑重定向到登录页。ctx.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());ctx.setResponseBody(json);//拦截//return false;}//处理token是否有效boolean b = JwtUtil.checkToken(token);if(!b){Result result = new Result(401,"token失效");String json = new ObjectMapper().writeValueAsString(result);// 没有token，登录校验失败，拦截ctx.setSendZuulResponse(false);// 返回401状态码（未授权）。也可以考虑重定向到登录页。ctx.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());ctx.setResponseBody(json);//拦截//return false;}return null;}
}