SpringCloud如何实现Zuul集群(负载均衡)
目录
- 前言:
- 一、使用 Nginx+Zuul 实现网关集群
- 1.创建Eurek注册中心、会员服务、订单服务 (略)
- 2. 创建Zuul服务
- 3. 下载Nginx服务器
- 二、 测试
- 三、补充
- Nginx和网关的区别在什么地方?
- Nginx也可以实现网关,为什么不用Nginx实现网关呢?
- 关于Nginx负载均衡故障转移:
前言: 在微服务架构中,有一个组件可以说是必不可少的,那就是微服务网关,微服务网关处理了负载均衡,缓存,路由,访问控制,服务代理,监控,日志等。API网关在微服务架构中正是以微服务网关的身份存在。
一般在微服务架构中,网关都是部署多个服务的,以实现负载均衡和保证高可用。
一、使用 Nginx+Zuul 实现网关集群 1.互联网公司中网关都是集群 搭建集群: Nginx+Zuul 一主一备,或者轮询多个。
2.在微服务中,所有服务请求都会统一请求到Zuul网关上。
图示:
文章图片
过程:客户端发送请求统一到Nginx上,在使用Nginx实现反向代理和负载均衡,采用轮询算法转发到网关上。
1.创建Eurek注册中心、会员服务、订单服务 (略)
搭建Zull集群前,应该对Eureka注册中心,以及创建SpringBoot项目应该有了解,这里就不一 一赘述了。
实际上创建会员服务、订单服务这一步可以省略,因为我们仅仅是为了演示Nginx对Zuul网关的负载均衡效果。
会员服务配置:
过程:客户端发送请求统一到Nginx上,在使用Nginx实现反向代理和负载均衡,采用轮询算法转发到网关上。1.创建Eurek注册中心、会员服务、订单服务 (略)
搭建Zull集群前,应该对Eureka注册中心,以及创建SpringBoot项目应该有了解,这里就不一 一赘述了。实际上创建会员服务、订单服务这一步可以省略,因为我们仅仅是为了演示Nginx对Zuul网关的负载均衡效果。
会员服务配置:
#会员服务server:port: 8082spring:application:name: member-service#服务名#Eureka配置eureka:client:service-url:defaultZone: http://127.0.0.1:8761/eureka/#注册中心的地址
订单服务:
#订单服务server:port: 8081spring:application:name: order-service#服务名#Eureka配置eureka:client:service-url:defaultZone: http://127.0.0.1:8761/eureka/#注册中心地址
2. 创建Zuul服务
application.yml文件中配置 (Zull的配置生产时一般是放到配置中心中)
#配置Zuul端口server:port: 81spring:application:name: zull-gateway-service#服务名#Eureka配置eureka:client:service-url:defaultZone: http://127.0.0.1:8761/eureka/#注册中心地址# 配置网关反向代理,例如访问/api-member/** 直接重定向到member-service服务,实现路由转发,隐藏服务的真实ip(服务都实在内网中)#zull根据服务名,去Eureka获取服务真实地址,并通过本地转发,而且默认开启Ribbon实现负载均衡#默认读取Eureka注册列表 默认30秒间隔zuul: routes:api-a: #会员服务网关配置path: /api-member/**#访问只要是/api-member/ 开头的直接转发到member-service服务#服务名serviceId: member-serviceapi-b: #订单服务网关配置path: /api-order/**serviceId: order-service
创建TokenFilet类继承ZuulFilter,在run方法中输入网关的端口,调用服务时方便查看Nginx转发到哪个网关
package com.example.zuul.filter; import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.exception.ZuulException; import io.micrometer.core.instrument.util.StringUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; import javax.servlet.http.HttpServletRequest; @Componentpublic class TokenFilter extends ZuulFilter { //统计当前Zuul调用次数int count = 0; //获取Zuul服务端口号@Value("${server.port}")private String prot; /*** 指定该Filter的类型* ERROR_TYPE = "error"; * POST_TYPE = "post"; * PRE_TYPE = "pre"; * ROUTE_TYPE = "route"; */@Overridepublic String filterType() {System.out.println("filterType()..."); return "pre"; }/*** 指定该Filter执行的顺序(Filter从小到大执行)* DEBUG_FILTER_ORDER = 1; * FORM_BODY_WRAPPER_FILTER_ORDER = -1; * PRE_DECORATION_FILTER_ORDER = 5; * RIBBON_ROUTING_FILTER_ORDER = 10; * SEND_ERROR_FILTER_ORDER = 0; * SEND_FORWARD_FILTER_ORDER = 500; * SEND_RESPONSE_FILTER_ORDER = 1000; * SIMPLE_HOST_ROUTING_FILTER_ORDER = 100; * SERVLET_30_WRAPPER_FILTER_ORDER = -2; * SERVLET_DETECTION_FILTER_ORDER = -3; */@Overridepublic int filterOrder() {System.out.println("filterOrder()..."); return 0; }/*** 指定需要执行该Filter的规则* 返回true则执行run()* 返回false则不执行run()*/@Overridepublic boolean shouldFilter() {System.out.println("shouldFilter()..."); return true; }/*** 该Filter具体的执行活动*/@Overridepublic Object run() throws ZuulException {// 获取上下文//RequestContext currentContext = RequestContext.getCurrentContext(); //HttpServletRequest request = currentContext.getRequest(); //获取userToken// String userToken = request.getParameter("userToken"); //System.out.println("userToken: "+userToken); //if (StringUtils.isEmpty(userToken)) {//不会继续执行调用服务接口,网关直接响应给客户端//currentContext.setSendZuulResponse(false); //currentContext.setResponseStatusCode(401); // currentContext.setResponseBody("userToken is Null"); // return null; // }else if(!userToken.equals("10010")){// currentContext.setSendZuulResponse(false); //currentContext.setResponseStatusCode(401); //currentContext.setResponseBody("userToken is Error"); //return null; //}// 否则正常执行业务逻辑,调用服务.....System.out.println("访问Zuul网关端口为:"+prot +"(total:"+ ( count++) +")"); return null; }}
启动两个Zuul服务,端口号分别为81和82
3. 下载Nginx服务器
这里演示使用Windows版本,Linux安装也很简单,后面操作都一样。
windows版下载地址:http://nginx.org/en/download.html
文章图片
下载好后解压,进入conf目录找到nginx.conf文件打开,配置如下:
#配置上游服务器 集群,默认轮询机制 upstream backServer{server 127.0.0.1:81; server 127.0.0.1:82; # 补充: backup表示从服务器或者叫备用服务器只有当主服务器(81、82端口)都不能访问时才会访问此(83端口)备用服务器 当主服务器恢复正常后 则访问主服务器#server 127.0.0.1:83 backup; }server {listen80; server_namelocalhost; #charset koi8-r; #access_loglogs/host.access.logmain; location / {##roothtml; #指定上游负载均衡服务器proxy_pass http://backServer/; indexindex.html index.htm; }}
双击nginx.exe启动Nginx服务器
二、 测试 浏览器访问http://localhost/api-member
我们可以看到两个网关分别输出了日志,实现了负载均衡
文章图片
文章图片
我们看到访问的次数不一样,这其实和使用Google浏览器有关,可以换其他浏览器试试。
三、补充
Nginx和网关的区别在什么地方?
1、都可以实现反向代理。
2、都可以实现负载均衡,Nginx是服务端负载均衡,Zuul是本地负载均衡。
Nginx也可以实现网关,为什么不用Nginx实现网关呢?
因为微服务网关是针对整个微服务实现统一的请求拦截,网关基本上都是采用自己熟悉的语言开发的,目的方便易学。
网关的作用:
1、网关对所有服务会话进行拦截
2、网关安全控制、统一异常处理、xxs、sql注入
3、权限控制、黑名单和白名单、性能监控、日志打印等
关于Nginx负载均衡故障转移:
设置备用服务器(主从架构),只有当所有主服务器不可用时才会负载到备服务器,当主服务器恢复正常时则负载到主服务器。
upstream backServer{server 127.0.0.1:81; server 127.0.0.1:82; # 补充: backup表示从服务器或者叫备用服务器只有当主服务器(81、82端口)都不能访问时才会访问此(83端口)备用服务器 当主服务器恢复正常后 则访问主服务器server 127.0.0.1:83 backup; }
设置Nginx转发请求超时时间
upstream backServer{server 127.0.0.1:81; server 127.0.0.1:82; server 127.0.0.1:83 backup; } location / {proxy_passhttp://backServer/; proxy_redirectdefault; proxy_connect_timeout 1; # 超时1s则转发到其他服务,宕机情况下也适用proxy_read_timeout 1; proxy_send_timeout 1;
【SpringCloud如何实现Zuul集群(负载均衡)】以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
推荐阅读
- 考研英语阅读终极解决方案——阅读理解如何巧拿高分
- 如何寻找情感问答App的分析切入点
- 关于QueryWrapper|关于QueryWrapper,实现MybatisPlus多表关联查询方式
- mybatisplus如何在xml的连表查询中使用queryWrapper
- MybatisPlus使用queryWrapper如何实现复杂查询
- python学习之|python学习之 实现QQ自动发送消息
- 孩子不是实现父母欲望的工具——林哈夫
- opencv|opencv C++模板匹配的简单实现
- Node.js中readline模块实现终端输入
- 如何在Mac中的文件选择框中打开系统隐藏文件夹