SpringCloud Zuul实现动态路由

SpringCloud Zuul实现动态路由

前言

Zuul 是在Spring Cloud Netflix平台上提供动态路由,监控,弹性,安全等边缘服务的框架，是Netflix基于jvm的路由器和服务器端负载均衡器，相当于是设备和 Netflix 流应用的 Web 网站后端所有请求的前门。本文基于上篇（SpringCloud系列——Ribbon 负载均衡）实现Zuul动态路由

github地址：https://github.com/Netflix/zuul

官方文档：https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.1.0.RC2/single/spring-cloud-netflix.html

代码编写

首先我们在springCloud下面新建一个springboot项目：zuul-server，pom继承parent，并且在Eureka上面注册（还不会服务注册与发现的，请戳：SpringCloud系列——Eureka 服务注册与发现）

maven引入Zuul

org.springframework.cloud

spring-cloud-starter-netflix-zuul

配置文件

server.port=10010

spring.application.name=zuul-server

eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/

#健康检查（需要spring-boot-starter-actuator依赖）

eureka.client.healthcheck.enabled=true

# 续约更新时间间隔（默认30秒）

eureka.instance.lease-renewal-interval-in-seconds=10

# 续约到期时间（默认90秒）

eureka.instance.lease-expiration-duration-in-seconds=10

#zuul代理配置 zuul.routes.服务名.path,服务名要与注册的一致

#应用名映射

zuul.routes.myspringboot.path=/myspringboot/**

zuul.routes.myspringboot.service-id=myspringboot

#URL映射

#zuul.routes.myspringboot.path=/myspringboot/**

#zuul.routes.myspringboot-url.url=http://localhost:10087/

自定义Zuul过滤器

更多的检查规则后续慢慢健全

/**

* Zuul过滤器，实现了路由检查

*/

public class AccessFilter extends ZuulFilter {

/**

* 通过int值来定义过滤器的执行顺序

*/

@Override

public int filterOrder() {

// PreDecoration之前运行

return PRE_DECORATION_FILTER_ORDER - 1;

}

/**

* 过滤器的类型，在zuul中定义了四种不同生命周期的过滤器类型：

* public static final String ERROR_TYPE = "error";

* public static final String POST_TYPE = "post";

* public static final String PRE_TYPE = "pre";

* public static final String ROUTE_TYPE = "route";

*/

@Override

public String filterType() {

return PRE_TYPE;

}

/**

* 过滤器的具体逻辑

*/

@Override

public Object run() {

RequestContext ctx = RequestContext.getCurrentContext();

HttpServletRequest request = ctx.getRequest();

System.out.println(String.format("%s AccessFilter request to %s", request.getMethod(),request.getRequestURL().toString()));

String accessToken = request.getParameter("accessToken");

//有权限令牌

if (!StringUtils.isEmpty(accessToken)) {

ctx.setSendZuulResponse(true);

ctx.setResponseStatusCode(200);

//可以设置一些值

ctx.set("isSuccess", true);

return null;

} else {

ctx.setSendZuulResponse(false);

ctx.setResponseStatusCode(401);

ctx.setResponseBody("{\"result\":\"accessToken is not correct!\"}");

//可以设置一些值

ctx.set("isSuccess", false);

return null;

}

}

/**

* 返回一个boolean类型来判断该过滤器是否要执行

*/

@Override

public boolean shouldFilter() {

return true;

}

}

启动类

添加@EnableZuulProxy注解并使用自定义过滤器

@EnableZuulProxy

@SpringBootApplication

public class ZuulServerApplication {

public static void main(String[] args) {

SpringApplication.run(ZuulServerApplication.class, args);

}

@Bean

public AccessFilter accessFilter() {

return new AccessFilter();

}

}

效果演示

启动所有项目，我们在Eureka上注册了四个服务，相比上篇（SpringCloud系列——Ribbon 负载均衡）多了一个Zuul

浏览器访问 http://localhost:10010/myspringboot/feign/ribbon、http://localhost:10010/myspringboot/feign/ribbon?accessToken=123456http://

http://localhost:10010/ 这个端口对外暴露，相对于总入口，后面接不同的路径由，Zuul路由到对应的服务上

1、没有accessToken是，无法通过检查

2、携带accessToken时，可正常路由，并且Feign调用、Ribbon负载均衡

后记

我们为什么要使用Zuul呢？

1、请求校验、路由转发，接口校验与业务逻辑分离

2、隐藏诸多服务路径，只暴露统一入口，安全

更多Zuul配置，请看官方文档

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。