SpringCloud实现Zuul集群(负载均衡)

亦凉 2021-10-18 14:18 465阅读 0赞

前言：  
在微服务架构中，有一个组件可以说是必不可少的，那就是微服务网关，微服务网关处理了负载均衡，缓存，路由，访问控制，服务代理，监控，日志等。API网关在微服务架构中正是以微服务网关的身份存在。  
一般在微服务架构中，网关都是部署多个服务的，以实现负载均衡和保证高可用。  
一、使用 Nginx+Zuul 实现网关集群  
1.互联网公司中网关都是集群         搭建集群: Nginx+Zuul 一主一备，或者轮询多个。  
2.在微服务中，所有服务请求都会统一请求到Zuul网关上。

图示：

过程：客户端发送请求统一到Nginx上，在使用Nginx实现反向代理和负载均衡，采用轮询算法转发到网关上。

1.创建Eurek注册中心、会员服务、订单服务 (略)  
搭建Zull集群前，应该对Eureka注册中心，以及创建SpringBoot项目应该有了解，这里就不一 一赘述了。  
实际上创建会员服务、订单服务这一步可以省略，因为我们仅仅是为了演示Zuul网关的负载均衡效果。

会员服务配置:

\#会员服务  
server:  
  port: 8082  
spring:  
  application:  
    name: member-service    \#服务名

\#Eureka配置  
eureka:  
  client:  
    service-url:  
      defaultZone: http://127.0.0.1:8761/eureka/     \#注册中心的地址  
  
订单服务:

\#订单服务  
server:  
  port: 8081  
spring:  
  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: 81  
spring:  
  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-service  
   api-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;

@Component  
public 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";  
     \*/  
    @Override  
    public 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;  
     \*/  
    @Override  
    public int filterOrder() \{  
        System.out.println("filterOrder()...");  
        return 0;  
    \}

/\*\*  
     \* 指定需要执行该Filter的规则  
     \* 返回true则执行run()  
     \* 返回false则不执行run()  
     \*/  
    @Override  
    public boolean shouldFilter() \{  
        System.out.println("shouldFilter()...");  
        return true;  
    \}

/\*\*  
     \* 该Filter具体的执行活动  
     \*/  
    @Override  
    public 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;  
    \}  
    server \{  
        listen       80;  
        server\_name  localhost;

\#charset koi8-r;

\#access\_log  logs/host.access.log  main;

location / \{  
            \#\#root   html;  
            \#指定上游负载均衡服务器  
            proxy\_pass http://backServer/;  
            index  index.html index.htm;  
        \}  
    \}  
  
双击nginx.exe启动Nginx服务器

二、 测试  
浏览器访问http://localhost/api-member  
我们可以看到两个网关分别输出了日志，实现了负载均衡

我们看到访问的次数不一样，这其实和使用Google浏览器有关，可以换其他浏览器试试。

三、补充  
Nginx和网关的区别在什么地方？

都可以实现反向代理。  
都可以实现负载均衡，Nginx是服务端负载均衡，Zuul是本地负载均衡。  
Nginx也可以实现网关，为什么不用Nginx实现网关呢？  
        因为微服务网关是针对整个微服务实现统一的请求拦截，网关基本上都是采用自己熟悉的语言开发的，目的方便易学。

网关的作用:

网关对所有服务会话进行拦截  
网关安全控制、统一异常处理、xxs、sql注入  
权限控制、黑名单和白名单、性能监控、日志打印等