当前位置：首页 > news >正文

微服务网关

news 来源：原创 2025/4/30 17:05:25

一、网关

1、网关概述

2、微服务网关的作用

3、网关作用的一些实现

1、使用 Spring Cloud Gateway 解决跨域

2、微服务网关过滤器

一、网关

1、网关概述

不同的微服务一般会有不同的网络地址，而外部客户端可能需要调用多个服务的接口才能完成一个业务需求，如果让客户端直接与各个微服务通信，会有以下的问题：

客户端会多次请求不同的微服务，增加了客户端的复杂性
存在跨域请求，在一定场景下处理相对复杂
认证复杂，每个服务都需要独立认证
难以重构，随着项目的迭代，可能需要重新划分微服务。例如，可能将多个服务合并成一个或者将一个服务拆分成多个。如果客户端直接与微服务通信，那么重构将会很难实施

以上这些问题可以借助网关解决。

网关是介于客户端和服务器端之间的中间层，所有的外部请求都会先经过网关这一层。也就是说，API 的实现方面更多的考虑业务逻辑，而安全、性能、监控可以交由网关来做，这样既提高业务灵活性又不缺安全性，典型的架构图如图所示：

2、微服务网关的作用

请求路由
API 网关会根据客户端的请求，将请求转发到适当的微服务。请求可以是基于 URL 路径、请求方法、请求头等规则来分配给不同的微服务。
负载均衡
网关可以实现负载均衡，将客户端的请求均匀分发到多个后端服务实例，防止某个实例过载。
身份验证与授权
网关通常会作为安全网关，负责对所有进来的请求进行身份验证（如 OAuth、JWT 等）。确保用户具有访问特定微服务的权限。
请求聚合
在微服务架构中，一个业务流程可能需要与多个微服务交互。API 网关可以将多个微服务的响应聚合成一个响应返回给客户端，减少客户端的请求次数。
服务发现
API 网关可以与服务注册与发现机制（如 Eureka、Consul 等）结合，动态地根据服务的可用性将请求路由到正确的微服务实例。
限流与熔断
网关可以在高流量情况下进行请求限流，防止后端服务过载。同时，网关还可以与熔断器结合，处理服务的故障，确保系统的稳定性。
协议转换
网关可以支持不同协议之间的转换。例如，将客户端的 HTTP 请求转发给后端的 gRPC 或 WebSocket 服务。
缓存与性能优化
API 网关能够缓存一些常见的请求和响应，减少对后端服务的访问，提高性能。
监控与日志记录
API 网关可以记录请求和响应日志，进行性能监控，帮助开发和运维人员快速排查问题。

3、网关作用的一些实现

1、使用 Spring Cloud Gateway 解决跨域

Spring Cloud Gateway 是一个支持 CORS 配置的 API 网关，可以通过简单的配置解决跨域问题。你可以在 application.yml 或 Java 配置类中指定跨域的规则。

spring:
  cloud:
    gateway:
      routes:
        - id: user-service
          uri: lb://USER-SERVICE
          predicates:
            - Path=/user/**
          filters:
            - name: CORS
              args:
                allowedOrigins: "*"
                allowedMethods: "GET, POST, PUT, DELETE, OPTIONS"
                allowedHeaders: "*"
                allowCredentials: "true"

说明：

allowedOrigins：允许的来源，* 表示允许所有来源（可以配置为具体域名来限制来源）。
allowedMethods：允许的 HTTP 方法。
allowedHeaders：允许的请求头。
allowCredentials：是否允许携带 Cookies 等凭证。

2、微服务网关过滤器

我们可以通过网关过滤器，实现一些逻辑的处理，比如ip黑白名单拦截、特定地址的拦截等。下面的代码中做了ip显示和url显示两个过滤器，并且设定的先后顺序。

ip：

@Component
public class IpFilter implements GlobalFilter, Ordered {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {

        System.out.println("经过第1个过滤器IpFilter");
        ServerHttpRequest request = exchange.getRequest();
        InetSocketAddress remoteAddress = request.getRemoteAddress();
        System.out.println("ip:"+remoteAddress.getHostName());
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        return 1;
    }
}

url：

@Component
public class UrlFilter implements GlobalFilter, Ordered {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        System.out.println("经过第2个过滤器UrlFilter");
        ServerHttpRequest request = exchange.getRequest();
        String url = request.getURI().getPath();
        System.out.println("url:"+url);
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        return 2;
    }
}

启动网关之后发送请求到网关观察控制台输出即可。