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

目录
  • zuul集成Eureka
  • Zuul路由配置
    • 1. 指定具体服务路由
    • 2. 路由前缀
  • Zuul过滤器
    • 过滤器类型
    • 使用过滤器

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内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • SpringCloud Eureka服务治理之服务注册服务发现

    目录 什么是Eureka Eureka核心概念服务注册和服务发现 服务注册 服务发现 Eureka实战 Eureka服务端单节点构建 Eureka服务端集群构建 Eureka客户端构建 什么是Eureka Netflix Eureka 是一款由 Netflix 开源的基于 REST 服务的注册中心,用于提供服务发现功能.Spring Cloud Eureka 是 Spring Cloud Netflix 微服务套件的一部分,基于 Netflix Eureka 进行了二次封装,主要负责完成微服务架

  • spring cloud eureka 服务启动失败的原因分析及解决方法

    目录 环境: 错误log 环境: <spring-boot-version>2.3.5.RELEASE</spring-boot-version> <spring-cloud-version>Hoxton.SR8</spring-cloud-version> 错误log Unable to start web server; nested exception is org.springframework.boot.web.server.WebServerEx

  • 基于多网卡环境下Eureka服务注册IP的选择问题

    目录 多网卡环境下Eureka服务注册IP选择 问题场景 问题原因 解决方案 在Eureka中使用IP注册服务 eureka服务端配置 客户端配置 admin服务端配置 客户端配置 多网卡环境下Eureka服务注册IP选择 问题场景 服务器上分别配置了eth0和eth1两块网卡,只有eth1的地址可供其它机器访问,在这种情况下,服务注册时Eureka Client会自动选择eth0作为服务ip, 导致其它服务无法调用. 问题原因 由于官方并没有写明Eureka Client探测本机IP的逻辑,所

  • 如何从eureka获取服务的ip和端口号进行Http的调用

    目录 eureka获取服务ip和端口号进行Http调用 eureka页面中显示ip+端口 eureka获取服务ip和端口号进行Http调用 我告诉你们为啥我要先从eureka首先获取 goods的服务ip, 在用ip的方式使用http调用goods的服务. 因为公司的规定, 不让我们用Feigin. 我TMD的都震惊了, 我都不知道为啥. 我也不想写同事的ip地址, 做配置, 因为都去eureka里面注册了, 所以就这样调用了, 真是蛋疼.  这种微服务, 这种奇葩的方式.. package c

  • FeignClient如何脱离eureka自定义URL

    目录 FeignClient脱离eureka自定义URL 需求 方法一: FeignClient注解中添加URL属性 方法二: eureka禁用ribbon,并手动配置服务列表 feign不使用eureka main server端代码 Client端代码 FeignClient脱离eureka自定义URL 需求 Spring Cloud环境中的FeignClient有时候需要调用特定主机的接口,但是默认是从eureka上的注册列表自动获取到的负载均衡过后的URL,这时怎么办呢? 方法一: Fe

  • Eureka源码阅读之环境搭建及工程结构

    目录 1. 源码阅读环境搭建 1.1 源码下载: 2. 工程结构速览 3. 调试须知 1. 源码阅读环境搭建 ide:IntelliJ IDEA 2020.1 包管理:gradle eureka版本:1.10.11 Spring Cloud : 2020.0.2 Spring Boot :2.4.4 1.1 源码下载: 下载完源码之后,需要更改一下几个地方: build.gradle增加阿里云镜像仓库,将如下插件版本改一下,否则导入idea会报错: maven { url 'https://ma

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

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

  • Spring超详细讲解创建BeanDefinition流程

    目录 一.前期准备 1.1 环境依赖 1.2 实体类 1.3 applicationContext.xml 1.4 测试代码 二.探究过程 2.1 目标 2.2 BeanDefinition的创建过程 2.2.1 回顾bean对象的创建 2.2.2 AbstractApplicationContext 2.2.3 AbstractXmlApplicationContext 2.2.4 AbstractBeanDefinitionReader 2.2.5 XmlBeanDefinitionRead

  • Spring Cloud 系列之注册中心 Eureka详解

    1.1 简介 1.1.1 概述   Netflix Eureka 是由 Netflix 开源的一款基于 REST 的服务发现组件,包括 Eureka Server 及 Eureka Client.2012 年 9 月在 GitHub 上发布 1.1.2 版本,目前 Netflix 以宣布闭源,所以市面上还是以 1.x 版本为主.Eureka 提供基于 REST 的服务,在集群中主要用于服务管理.Eureka 提供了基于 Java 语言的客户端组件,客户端组件实现了负载均衡的功能,为业务组件的集群

  • Spring Cloud Gateway替代zuul作为API网关的方法

    目录 第一,pom文件 第二,项目结构 第三,项目代码和运行截图 运行效果图 参考文档: 本文简要介绍如何使用Spring Cloud Gateway 作为API 网关(不是使用zuul作为网关),关于Spring Cloud Gateway和zuul的性能比较本文不再赘述,基本可以肯定Spring Cloud Finchley版本的gateway比zuul 1.x系列的性能和功能整体要好. 特别提醒:Spring Cloud Finchley版本中,即使你引入了spring-cloud-sta

  • Spring Cloud 网关服务 zuul 动态路由的实现方法

    zuul动态路由 网关服务是流量的唯一入口.不能随便停服务.所以动态路由就显得尤为必要. 数据库动态路由基于事件刷新机制热修改zuul的路由属性. DiscoveryClientRouteLocator 可以看到DiscoveryClientRouteLocator 是默认的刷新的核心处理类. //重新加载路由信息方法 protected方法.需要子方法重新方法. protected LinkedHashMap<String, ZuulRoute> locateRoutes() //触发刷新的

  • Spring超详细讲解BeanUtils改造

    目录 1.基本原理 2.使用 3.性能 4.提醒 1.基本原理 原理:https://www.jb51.net/article/252384.htm 浅拷贝:https://www.jb51.net/article/221283.htm BeanUtils.copyProperties();确实为我们做了很多事情,虽然不能完美完成深拷贝,但是对于 po.vo.dto 的拷贝已经足够用了.但是其还是有一些不够完美的地方. 不足几点如下: 不能拷贝 list,而拷贝 list 的情况又大量存在,因此

  • c++详细讲解构造函数的拷贝流程

    #include <iostream> #include <string> using namespace std; void func(string str){ cout<<str<<endl; } int main(){ string s1 = "http:www.biancheng.net"; string s2(s1); string s3 = s1; string s4 = s1 + " " + s2; fu

  • Spring超详细讲解事务

    目录 什么是事务 事务的四个特性(ACID) Spring对事务的支持 编程式事务管理 声明式事务管理 基于注解的声明式事务管理 Spring事务管理的三个接口 Spring事务属性 什么是事务 一个数据库事务是一个被视为一个工作单元的逻辑上的一组操作,这些操作要么全部执行,要么全部不执行. 需要注意的是,并不是所有的数据库(引擎)都支持事务,比如说MySQL的MyISAM存储引擎 事务的四个特性(ACID) 原子性:事务是一个原子性操作,一个事务由一系列操作组成,这一系列操作要么全部执行完成,

  • Spring超详细讲解事务和事务传播机制

    目录 为什么需要事务 Spring 声明事务 Transactional参数说明 propagation isolation timeout 事务回滚失效解决方案 @Transactional工作原理 Spring 事务的传播机制 为什么需要事务传播机制? 传播机制的类型 为什么需要事务 事务是将一组操作封装成一个执行单元,要么全部成功,要么全部失败.如果没有事务,转账操作就会出现异常,因此需要保证原子性. Spring 声明事务 只需要在方法上添加@Transactional注解就可以实现,无

  • Spring超详细讲解面向对象到面向切面

    目录 前言 一.OOP&AOP 二.AOP核心 三.第一个AOP案例 1.环境准备 2.AOP实现步骤 四.切入点表达式 1.语法格式 2.通配符 五.AOP通知类型 环境准备 环绕通知 1.返回后通知 2.异常后通知 前言 Object object = new Object(); 世间万物的本质都可看作类的对象,面向对象(OOP)的模式让程序易维护.易复用.易扩展,而面向切面(AOP)则是面向对象的补充,让对象的功能更加强大 对比前面的日志框架技术二者非常相似,他的特点就是在不影响业务的前提

随机推荐