Spring Cloud详细讲解zuul集成Eureka流程

 更新时间:2022年06月23日 10:08:10   作者:桃花键神  
这篇文章主要介绍了Spring Cloud zuul集成Eureka,Eureka Client中内置一个负载均衡器,用来进行基本的负载均衡,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

zuul集成Eureka

通过刚才的示例,我们已经可以简单地使用 Zuul 进行路由的转发了,在实际使用中我们通常是用 Zuul 来代理请求转发到内部的服务上去,统一为外部提供服务。内部服务的数量会很多,而且可以随时扩展,我们不可能每增加一个服务就改一次路由的配置,所以也得通过结合 Eureka 来实现动态的路由转发功能。首先需要添加 Eureka 的依赖,代码如下所示。

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

说明:这里的eureka-client版本要使用2.2.9.RELEASE,否则会报错!

启动类不需要修改,因为 @EnableZuulProxy 已经自带了 @EnableDiscoveryClient。只需要在配置文件中增加Eureka 的地址即可:

eureka:
 client:
  service-url:
   defaultZone: http://admin:1357@localhost:8761/eureka

重启服务,我们可以通过默认的转发规则来访问 Eureka中的服务。访问规则是“网关服务地址+访问的服务名称+接口 URI”。

如上面的访问改为: http://localhost:7000/ws-user-server/user/23

Zuul路由配置

当 Zuul 集成 Eureka 之后,其实就可以为 Eureka 中所有的服务进行路由操作了,默认的转发规则就是“网关 服务地址+访问的服务名称+接口 URI”。在给服务指定名称的时候,应尽量短一点,这样的话我们就可以用默认的路由规则进行请求,不需要为每个服务都定一个路由规则,这样就算新增了服务,API 网关也不用修改和重启了。

1. 指定具体服务路由

我们可以为每一个服务都配置一个路由转发规则:

zuul:
 routes: #路由转发
  ws-user-server:
   path: /api-user/**

上述代码将ws-user-server 服务的路由地址配置成了api-user,也就是当需要访问 ws-user-server中的接口时,我们可以通过 api-user/user/20 来进行。这其实就是将服务名称变成了我们自定义的名称。注意: /api-user/** 后面一定要配置两个星号,两个星号表示可以转发任意层级的 URL,比如“/apiuser/user/1”。如果只配置一个星号,那么就只能转发一级,比如“/api-user/user”。默认的路由规则还适用!!!!

2. 路由前缀

有的时候我们会想在 API 前面配置一个统一的前缀,就可

以通过 Zuul 中的配置来实现:

zuul:
 prefix: /v1

上述访问地址变为: http://localhost:7000/v1/api-user/user/20

Zuul过滤器

过滤器类型

Zuul 中的过滤器跟我们之前使用的 javax.servlet.Filter不一样,javax.servlet.Filter 只有一种类型,可以通过配置 urlPatterns 来拦截对应的请求。

而 Zuul 中的过滤器总共有 4 种类型,且每种类型都有对应的使用场景。

1)pre

可以在请求被路由之前调用。适用于身份认证的场景,认证通过后再继续执行下面的流程。

2)route

在路由请求时被调用。适用于灰度发布场景,在将要路由的时候可以做一些自定义的逻辑。

3)post

在 route 和 error 过滤器之后被调用。这种过滤器将请求路由到达具体的服务之后执行。适用于需要添加响应头,记录响应日志等应用场景。

4)error

处理请求时发生错误时被调用。在执行过程中发送错误时会进入 error 过滤器,可以用来统一记录错误信息。

请求生命周期

过滤器执行的顺序,请求发过来首先到 pre 过滤器,再到 routing 过滤器,最后到 post 过滤器,任何一个过滤器有异常都会进入 error 过滤器。通过 com.netflix.zuul.http.ZuulServlet 也可以看出完整执行顺序,ZuulServlet 类似 Spring-MVC 的DispatcherServlet,所有的 Request 都要经过ZuulServlet 的处理。

ZuulServlet 的service实现:

public void service(ServletRequest servletRequest, ServletResponse servletResponse) throws ServletException, IOException { try { 
this.init((HttpServletRequest)servletReque st(HttpServletResponse)servletResponse); RequestContext context = RequestContext.getCurrentContext(); context.setZuulEngineRan(); try {this.preRoute(); } catch (ZuulException var13) { this.error(var13); this.postRoute(); return; }try {this.route(); } catch (ZuulException var12) { this.error(var12); this.postRoute(); return; }try {this.postRoute();} catch (ZuulException var11) { this.error(var11); } } catch (Throwable var14) { this.error(new ZuulException(var14, 500, "UNHANDLED_EXCEPTION_" + var14.getClass().getName())); } finally { RequestContext.getCurrentContext().unset() ; } }

使用过滤器

创建一个token验证的过滤器,继承抽象类ZuulFilter,

如下:

import com.netflix.zuul.ZuulFilter; 
import com.netflix.zuul.context.RequestContext; 
import com.netflix.zuul.exception.ZuulException; 
public class TokenFilter extends ZuulFilter {
/*** 过滤器类型,可选值有 pre、route、post、 error。* @return */ @Override 
public String filterType() { 
return "pre"; }
/*** 过滤器的执行顺序,数值越小,优先级越高。 * @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 requestContext=RequestContext.getCurrentCo ntext();String token= requestContext.getRequest().getHeader("tok en"); 
  //如果token没传或 失效 if(null==token){ requestContext.setSendZuulResponse(false); //告诉 Zuul 不需要将当前请求转发到后端的服务了 requestContext.setResponseBody(" {code:0,msg:'返回给客户端的数据'}"); requestContext.getResponse().setContentTyp e("application/json; charset=utf-8"); }return null; } }

使过滤器生效:

@Configuration 
public class FilterConfig { 
@Bean
 public TokenFilter tokenFilter(){
  return new TokenFilter(); 
  }
   }

到此这篇关于Spring Cloud详细讲解zuul集成Eureka流程的文章就介绍到这了,更多相关Spring Cloud Eureka内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 详解Java中LinkedHashMap

    详解Java中LinkedHashMap

    本文主要介绍了Java中LinkedHashMap的相关知识,具有很好的参考价值。下面跟着小编一起来看下吧
    2017-05-05
  • MyBatis存储过程、MyBatis分页、MyBatis一对多增删改查操作

    MyBatis存储过程、MyBatis分页、MyBatis一对多增删改查操作

    本文通过一段代码给大家介绍了MyBatis存储过程、MyBatis分页、MyBatis一对多增删改查操作,非常不错,具有参考借鉴价值,感兴趣的朋友一起看看吧
    2016-11-11
  • Java如何在List或Map遍历过程中删除元素

    Java如何在List或Map遍历过程中删除元素

    相信大家在日常的开发过程中,经常需要对List或Map里面的符合某种业务的数据进行删除,但是如果不了解里面的机制就容易掉入“陷阱”导致遗漏或者程序异常。下面这篇文章将会给大家详细介绍Java如何在List和Map遍历过程中删除元素,有需要的朋友们可以参考借鉴。
    2016-12-12
  • Java 信息摘要加密MD2、MD4、MD5实现详解

    Java 信息摘要加密MD2、MD4、MD5实现详解

    这篇文章主要介绍了Java 信息摘要加密MD2、MD4、MD5实现详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-07-07
  • java中for和forEach的速度比较实例Demo

    java中for和forEach的速度比较实例Demo

    for循环中的循环条件中的变量只求一次值,而foreach语句是java5新增,在遍历数组、集合的时候,foreach拥有不错的性能,这篇文章主要给大家介绍了关于java中for和forEach速度比较的相关资料,需要的朋友可以参考下
    2021-08-08
  • SpringBoot整合Vue实现微信扫码支付以及微信退款功能详解

    SpringBoot整合Vue实现微信扫码支付以及微信退款功能详解

    最近公司要在微信公众号上做一个活动预报名,活动的门票等需要在微信中支付,下面这篇文章主要给大家介绍了关于SpringBoot整合Vue实现微信扫码支付以及微信退款功能的相关资料,需要的朋友可以参考下
    2022-05-05
  • Java正则表达式处理特殊字符转义的方法

    Java正则表达式处理特殊字符转义的方法

    由于正则表达式定了一些特殊字符,而有时候需要对这些特殊字符进行匹配的话就需要进行转义了,下面这篇文章主要给大家介绍了Java正则表达式处理特殊字符转义的方法,需要的朋友可以参考借鉴,下面来一起看看吧。
    2017-01-01
  • java 使用idea将工程打成jar并创建成exe文件类型执行的方法详解

    java 使用idea将工程打成jar并创建成exe文件类型执行的方法详解

    这篇文章主要介绍了java 使用idea将工程打成jar并创建成exe文件类型执行,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧
    2020-09-09
  • java普通项目读取不到resources目录下资源文件的解决办法

    java普通项目读取不到resources目录下资源文件的解决办法

    这篇文章主要给大家介绍了关于java普通项目读取不到resources目录下资源文件的解决办法,Web项目中应该经常有这样的需求,在maven项目的resources目录下放一些文件,比如一些配置文件,资源文件等,需要的朋友可以参考下
    2023-09-09
  • Java 实现图片压缩的两种方法

    Java 实现图片压缩的两种方法

    这篇文章主要介绍了Java 实现图片压缩的两种方法,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下
    2020-09-09

最新评论