目录

• 一、Zuul简介
• 二、请求路由
• 2.1传统路由
• 2.2面向服务的路由
• 三、路由规则
• 3.1默认路由规则
• 3.2自定义路由规则
• 四、Zuul的过滤器
• 五、设置熔断
• 六、实战
• 6.1pom文件
• 6.2配置文件
• 6.3过滤器配置
• 6.4熔断配置
• 6.5启动类

一、Zuul简介 Zuul作为微服务系统的网关组件，用于构建边界服务（Edge Service），致力于动态路由、过滤、监控、弹性伸缩和安全。其在微服务架构中有着重要的作用，主要体现在以下六个方面：
Zull、Ribbon以及Eureka相结合可以实现智能路由和负载均衡的功能，Zull可以按照某种策略将请求分发到不同的实例上；
网关作为边界服务，将内部服务的API接口进行聚合并统一对外暴露接口。保护内部服务的API接口，防止内部服务被外界调用泄露敏感信息；
网关可以对用户的身份权限进行认证，防止非法请求API接口；
网关可以实现监控功能，实时日志输出，对请求进行记录；
网关可以用来实现流量监控，在高流量的情况下，对服务进行降级；
API接口从内部服务分离出来，便于测试

二、请求路由 使用Spring Cloud Zuul实现路由的规则是十分简单的。路由方式包括两种：传统路由方式，面向服务的路由方式。

2.1 传统路由
下面我们看以下配置：

zuul.routes.holiday.path=/holiday/**zuul.routes.holiday.url=http://localhosst:8080/

该规则配置表示所有符合/holiday/** 规则的访问都会被路由转发到http://localhosst:8080/地址上，例如：当我们访问http://localhost:5555/holiday/getAllDays,API网关就会将请求转发到http://localhost:8080/holiday/getAllDays提供的微服务接口上。其中holiday为微服务的名称，可以任意定义，但是一组path和url映射关系的路由名称必须相同，下面面向服务的路由方式也是如此。

2.2 面向服务的路由
Spring Cloud Zuul 与 Spring Cloud Eureka 可以实现无缝对接实现面向服务的路由。我们让路由的path映射到具体的服务上，而具体的url交由Eureka的服务发现机制去自动维护。具体配置如下（其他配置参考下面的实战）：

zuul.routes.holiday.path=/holiday/**zuul.routes.holiday.service-id=holiday

通过上面的配置，我们不需要维护具体实例的位置,是得维护工作十分简单。另外，面向服务打的路由默认实现了负载均衡，而传统路由还需要手动添加所有实例的位置。

三、路由规则 Spring Cloud Zuul提供了默认的路由规则，当然我们也可以修改这个路由规则。

3.1 默认路由规则
Zull与Eureka的配合使用后，Zull会默认配置一个路由规则，这些默认规则的path会使用service-id配置的服务名作为请求的前缀。例如：有holiday服务，他的默认规则如下

zuul.routes.holiday.path=/holiday/**zuul.routes.holiday.service-id=holiday

由于默认情况下所有Eureka上的服务都会被Zuul自动创建映射关系进行路由，这会使得一些我们不希望对外开放的服务也被外部访问到。这个时候我们可以配置zuul.ignored-services参数来设置一个服务名匹配表达式进行判断，如果服务名匹配表达式，那么Zull将跳过这个服务，不为其创建路由规则。例如：zuul.ignored-services=*表示对所有的服务不自动创建路由规则，这样我们就需要为每个服配置路由规则。

3.2 自定义路由规则
有这样一个场景，由于业务的扩展，版本的升级，服务存在不同的版本。比如我们有这样的命名：holiday-v1、holiday-v2，默认情况下，Zuul自动为服务创建的路由表达式会采用服务名做前缀，针对holiday-v1就会产生/holiday-v1,/holiday-v2两个路径来做映射，但这样生成的表达式规则较为单一，不利于路径规则的管理。
通常,对于上面这种情况，我们希望是生成的路径为/v1/holiday，/v2/holiday。我们可以通过自定义路由规则来实现，具体代码如下：

@Beanpublic PatternServiceRouteMapper serviceRouteMapper(){return new PatternServiceRouteMapper("(?^.+)-(?v.+$)","${version}/${name}"); }

PatternServiceRouteMapper对象可以让开发者通过正则表达式来自定义服务于路由映射的生成关系。

四、Zuul的过滤器 Zull有请求过滤的功能,其过滤器可以在Http请求的发起和响应返回期间执行一系列的过滤器。
Zuul包扩以下四种过滤器：

• PRE：该类型的filters在Request routing到源web-service之前执行。可以进行一些权限认证，日志记录，或者额外给Request增加一些属性供后续的filter使用;
• ROUTING：该类型的filters用于把Request routing到源web-service，源web-service是实现业务逻辑的服务。这里使用HttpClient请求web-service;
• POST：该类型的filters在ROUTING返回Response后执行。用来实现对Response结果进行修改，收集统计数据以及把Response传输会客户端;
• ERROR：上面三个过程中任何一个出现错误都交由ERROR类型的filters进行处理。

Zuul过滤器具有以下关键特性：

• Type(类型)：Zuul过滤器的类型，这个类型决定过滤器在哪个阶段执行，例如：pre，post等阶段；
• Execution Order(执行顺序)：规定了过滤器的执行顺序，Order的值越小，越先执行；
• Criteria(标准)：Filters执行所需条件
• Action(行动)：如果符合执行条件，则执行Action（具体逻辑代码）

示例如下：

public class MyFilter extends ZuulFilter {@Overridepublic Object run() {RequestContext ctx = RequestContext.getCurrentContext(); HttpServletRequest request = ctx.getRequest(); System.out.println(String.format("%s AccessUserNameFilter request to %s", request.getMethod(), request.getRequestURL().toString())); // 获取请求的参数String username = request.getParameter("username"); // 如果请求的参数不为空，且值为chhliu时，则通过if(null != username && username.equals("chhliu")) {// 对该请求进行路由ctx.setSendZuulResponse(true); ctx.setResponseStatusCode(200); // 设值，让下一个Filter看到上一个Filter的状态ctx.set("isSuccess", true); return null; }else{// 过滤该请求，不对其进行路由ctx.setSendZuulResponse(false); // 返回错误码ctx.setResponseStatusCode(401); // 返回错误内容ctx.setResponseBody("{\"result\":\"username is not correct!\"}"); ctx.set("isSuccess", false); return null; }}@Overridepublic boolean shouldFilter() {// 是否执行该过滤器，此处为true，说明需要过滤return true; }@Overridepublic int filterOrder() {// 优先级为0，数字越大，优先级越低return 0; }@Overridepublic String filterType() {// 前置过滤器return "pre"; }}

Zuul请求的生命周期如图所示：

文章图片


五、设置熔断 通常在服务无法提供服务的时候，需要执行熔断。zuul上实现熔断需要实现FallbackProvider的接口。实现接口中的两个方法:getRoute()用于指定应用在哪个服务上；fallbackResponse()进入熔断功能的执行逻辑。示例如下：

@Componentpublic class CustomZuulFallbackHandler implements FallbackProvider {private final Logger logger = LoggerFactory.getLogger(FallbackProvider.class); /*** 指定处理的service** @return*/@Overridepublic String getRoute() {return "*"; }public ClientHttpResponse fallbackResponse(String route) {return new ClientHttpResponse() {@Overridepublic HttpStatus getStatusCode() throws IOException {return HttpStatus.OK; }@Overridepublic int getRawStatusCode() throws IOException {return 200; }@Overridepublic String getStatusText() throws IOException {return "OK"; }@Overridepublic void close() {}@Overridepublic InputStream getBody() throws IOException {return new ByteArrayInputStream((route+" is unavailable.").getBytes()); }@Overridepublic HttpHeaders getHeaders() {HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); return headers; }}; }@Overridepublic ClientHttpResponse fallbackResponse(String route, Throwable cause) {if (cause != null) {String reason = cause.getMessage(); logger.info("Excption {}",reason); }return fallbackResponse(route); }}

六、实战
6.1 pom文件

com.southgis.ibase.parentparentWebService2.0.1-SNAPSHOT../../parent/parentWebService/pom.xml4.0.0api-gatewaycom.southgis.ibase.systemassistance2.0.1-SNAPSHOTwar网关服务org.springframework.cloudspring-cloud-starter-netflix-eureka-serverorg.springframework.cloudspring-cloud-config-clientorg.springframework.cloudspring-cloud-starter-netflix-zuulorg.springframework.bootspring-boot-starter-weborg.springframework.retryspring-retryorg.jasig.cas.clientcas-client-coreorg.springframework.bootspring-boot-starter-testtestapiGatewayorg.springframework.bootspring-boot-maven-plugincom.southgis.ibase.systemassistance.ApiGatewayCustomApplicationrepackage

6.2 配置文件
bootstrap.properties

#服务名 对应配置文件中的{application}部分spring.application.name=apiGateway#对应前配置文件中的{profile}部分spring.cloud.config.profile=dev2#配置访问路径server.servlet.context-path=/eureka-server#注册中心eureka.client.serviceUrl.defaultZone=http://localhost:8080/eureka-server/eureka#为监控端点 /info和/health端点也加上类似的前缀management.server.servlet.context-path=/apiGatewayeureka.instance.statusPageUrlPath=${management.server.servlet.context-path}/actuator/infoeureka.instance.healthCheckUrlPath=${management.server.servlet.context-path}/actuator/health#通过服务连接配置中心#spring.cloud.config.discovery.enabled=true#spring.cloud.config.discovery.serviceId=config-serverspring.cloud.config.uri = http://localhost:8080/config-server#配置文件获取失败快速返回spring.cloud.config.failFast=true#日志配置#logging.config=classpath:logback-spring.xml#logging.path=D:/ibase/logs/holiday#logging.pattern.console=[%d{yyyy-MM-dd HH:mm:ss}] -- [%-5p]: [%c] -- %m%n#logging.pattern.file=[%d{yyyy-MM-dd HH:mm:ss}] -- [%-5p]: [%c] -- %m%n

apiGateway-dev2.properties

#访问端口server.port=8080#设置session超时时间为540分钟server.servlet.session.timeout=PT540M#zuul默认为所有服务开启默认的路由，为了服务安全，此处关闭zuul.ignored-services=*#代码字典服务路由zuul.routes.codedict.path=/codedict/**zuul.routes.codedict.service-id=codedict#是否转发后还带转发特征的字符zuul.routes.codedict.strip-prefix=false#行政区划服务路由zuul.routes.adminzone.path=/adminzone/**zuul.routes.adminzone.service-id=adminzonezuul.routes.adminzone.strip-prefix=false#是否开启路由重试zuul.retryable=true#对当前服务的重试次数ribbon.MaxAutoRetries=2#切换实例的重试次数ribbon.MaxAutoRetriesNextServer=0#请求处理的超时时间ribbon.ReadTimeout=6000#请求连接的超时时间ribbon.ConnectTimeout=6000#对所有操作请求都进行重试ribbon.OkToRetryOnAllOperations=true#将 hystrix 的超时时间设置成 5000 毫秒(hystrix超时时间小于ribbon连接超时时间，先走hystrix)hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

6.3 过滤器配置

@Configurationpublic class ApiGatewayFilter extends ZuulFilter {@Overridepublic String filterType() {return "pre"; }@Overridepublic int filterOrder() {return 0; }@Overridepublic boolean shouldFilter() {return true; }@Overridepublic Object run() throws ZuulException {RequestContext context = RequestContext.getCurrentContext(); HttpServletRequest request = context.getRequest(); Principal principal = request.getUserPrincipal(); //获取用户的登录idString userId = principal.getName(); context.addZuulRequestHeader("X-AUTH-ID",userId); return null; }}

在这里我们将获取的登录用户id设置到了请求头中传递给内部服务，内部服务可以通过下面的代码进行获取：

String user = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest().getHeader("X-AUTH-ID");

6.4 熔断配置

@Componentpublic class CustomZuulFallbackHandler implements FallbackProvider {private final Logger logger = LoggerFactory.getLogger(FallbackProvider.class); /*** 指定处理的service** @return*/@Overridepublic String getRoute() {return "*"; }public ClientHttpResponse fallbackResponse(String route) {return new ClientHttpResponse() {@Overridepublic HttpStatus getStatusCode() throws IOException {return HttpStatus.OK; }@Overridepublic int getRawStatusCode() throws IOException {return 200; }@Overridepublic String getStatusText() throws IOException {return "OK"; }@Overridepublic void close() {}@Overridepublic InputStream getBody() throws IOException {return new ByteArrayInputStream((route+" is unavailable.").getBytes()); }@Overridepublic HttpHeaders getHeaders() {HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); return headers; }}; }@Overridepublic ClientHttpResponse fallbackResponse(String route, Throwable cause) {if (cause != null) {String reason = cause.getMessage(); logger.info("Excption {}",reason); }return fallbackResponse(route); }}

6.5 启动类

** * 路由网关服务部署启动类 * * @author simon **/@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)@EnableZuulProxy@EnableEurekaClient@SpringCloudApplicationpublic class ApiGatewayMicroApplication {public static void main(String[] args) {SpringApplication.run(ApiGatewayMicroApplication.class, args); }}

【关于服务网关Spring|关于服务网关Spring Cloud Zuul(Finchley版本)】以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

推荐阅读

• 

  电子烟的好处
• 

  做什么行业会利润高又赚钱？
• 

  乳胶内衣怎么清洗晾晒
• 

  梦见买枕巾是什么意思 梦见枕巾是怎么回事
• 

  涉嫌非法种植毒品原植物法定刑罚内容是多少
• 

  自己读书感悟的名言
• 

  投稿|何时起数码玩家已不再期待Android新版本？
• 

  支付宝基金过年期间休市吗
• 

  犯七是什么意思,有什么讲究 犯七是什么意思
• 

  如何选购新鲜白萝卜
• 

  米兔|小米新品儿童手表发售，米兔儿童电话手表5C入手体验
• 

  秦书记 青岛高速公路 青岛高速公路最新消息今天
• 

  法院对串通投标罪规定定罪量刑标准是怎样
• 

  嵌怎么读 嵌字是什么意思
• 

  苹果11网络特别差是什么原因
• 

  贵阳市少年儿童图书馆春节活动一览
• 

  solidworks2012热分析
• 

  2023年南四湖禁渔/禁采时间 南四湖鱼馆怎么样
• 

  奥迪车质量怎么样? 奥迪车质量怎么样
• 

  2021送同事元宵节祝福语

• 强烈建议在win8.1系统里把无用的服务停用
• 投稿|千亿新蓝海！中国第三方医疗服务产业发展现状分析
• 啥是ddos 攻击？详解D拒绝服务攻击的现状与防备机制
• XP系统节省资源可自行设置服务
• 关于Android教学的思考1
• 服务器角色换位“乾坤大挪移心经”
• 使用Apache Web服务器进行Django配置
• Android 上传文件到服务器
• Win8.1纯净版系统安全之设置页面代理服务器
• 基于知名微服务框架go-micro开发gRPC应用程序