SpringCloud：Spring Cloud Gateway中如何接入注册中心

心已赠人 2023-07-17 14:25 18阅读 0赞

**目录**

一、Service Discovery

1、Netflix Eureka

二、Load Balancing

1、blocking ribbon

2、reactive loadbalancer

三、例子

1、TestServer

2、ServerRegistry

3、GatewayServer

--------------------

Spring Cloud Gateway若需要接入注册中心（注册中心接口：ServiceRegistry）并获取其中的服务信息；同时将接收到的请求，正确的转发到这些服务对应的后端的服务器中，就需要配置如下两个组件：

>  *  Service Discovery           \# 从ServiceRegistry获取服务及服务对应的可访问服务器信息
>  *  Load Balancing               \# 根据配置的负载规则，从服务对应的可访问服务器中选取一个，将请求转发到这个服务器

Spring Cloud对这两种组件提供了抽象API，可以在spring-cloud-commons中找到。接口分别为：

> org.springframework.cloud.client.discovery.DiscoveryClient  
> org.springframework.cloud.client.loadbalancer.LoadBalancerClient

Spring Cloud Gateway的基础配置如下：  
Maven配置

> <dependency>  
>     <groupId>org.springframework.boot</groupId>  
>     <artifactId>spring-boot-starter</artifactId>  
> </dependency>  
> <dependency>  
>     <groupId>org.springframework.boot</groupId>  
>     <artifactId>spring-boot-starter-webflux</artifactId>  
> </dependency>  
> <dependency>  
>     <groupId>org.springframework.cloud</groupId>  
>     <artifactId>spring-cloud-starter</artifactId>  
>     <version>$\{spring-cloud.version\}</version>  
> </dependency>  
> <dependency>  
>     <groupId>org.springframework.cloud</groupId>  
>     <artifactId>spring-cloud-starter-gateway</artifactId>  
>     <version>$\{spring-cloud.version\}</version>  
> </dependency>

application.properties配置

> \# 此参数默认为true，因此可以不设置  
> spring.cloud.gateway.enabled=true

以上两种组件，有多种第三方组件提供了这些功能，Spring Cloud对这些组件提供了相应的封装。下面分别介绍如何配置这两个组件。

## 一、Service Discovery ##

Spring Cloud支持的组件为：

>  *  Netflix Eureka
>  *  Consul
>  *  Zookeeper

下面以Netflix Eureka为例，介绍一下如何配置

### 1、Netflix Eureka ###

Maven配置

> <dependency>  
>     <groupId>org.springframework.cloud</groupId>  
>     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>  
>     <version>$\{spring-cloud.version\}</version>  
> </dependency>

application.properties配置

> spring.cloud.discovery.enabled=true  
> spring.cloud.service-registry.auto-registration.enabled=false
> 
> eureka.client.enabled=true  
> eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/  
> \# eureka.instance.hostname=localhost  
> \# eureka.instance.metadataMap.zone=

配置是从如下类中初始化的：

> org.springframework.cloud.gateway.discovery.GatewayDiscoveryClientAutoConfiguration

其中会加载：

> org.springframework.cloud.netflix.eureka.reactive.EurekaReactiveDiscoveryClient

默认情况下，Spring Cloud Gateway使用的配置等同于如下内容，它们是写在代码中的，这个默认配置一般就可以满足使用要求了，不需要再对它进行配置：

> spring.cloud.gateway.discovery.locator.predicates\[0\].name: Path  
> spring.cloud.gateway.discovery.locator.predicates\[0\].args\[pattern\]: "'/'+serviceId+'/\*\*'"  
> spring.cloud.gateway.discovery.locator.predicates\[1\].name: Host  
> spring.cloud.gateway.discovery.locator.predicates\[1\].args\[pattern\]: "'\*\*.foo.com'"  
> spring.cloud.gateway.discovery.locator.filters\[0\].name: Hystrix  
> spring.cloud.gateway.discovery.locator.filters\[0\].args\[name\]: serviceId  
> spring.cloud.gateway.discovery.locator.filters\[1\].name: RewritePath  
> spring.cloud.gateway.discovery.locator.filters\[1\].args\[regexp\]: "'/' + serviceId + '/(?<remaining>.\*)'"  
> spring.cloud.gateway.discovery.locator.filters\[1\].args\[replacement\]: "'/$\{remaining\}'"

其中，"'/'+serviceId+'/\*\*'"会被***SpEL***解析，***SpEL***会将serviceId替换成请求URL中的实际serviceId。

如果特殊需要，也可能改变以上配置，比如要针对TestServer服务，可以这样配置：

> spring.cloud.gateway.discovery.locator.predicates\[0\].name=Path  
> spring.cloud.gateway.discovery.locator.predicates\[0\].args\[pattern\]="/TestServer/\*\*"  
> spring.cloud.gateway.discovery.locator.predicates\[1\].name=Host  
> spring.cloud.gateway.discovery.locator.predicates\[1\].args\[pattern\]="\*\*"  
> spring.cloud.gateway.discovery.locator.filters\[0\].name=RewritePath  
> spring.cloud.gateway.discovery.locator.filters\[0\].args\[regexp\]="/TestServer/(?<remaining>.\*)"  
> spring.cloud.gateway.discovery.locator.filters\[0\].args\[replacement\]="/$\{remaining\}"

比如接收到如下请求：

> http://www.test.com/TestServer/info.jsp

Spring Cloud Gateway会将此请求转发到如下地址：

> http://IP:port/info.jsp

IP:port是部署TestServer服务的服务器的ip和port

## 二、Load Balancing ##

Spring Cloud Gateway接收到请求后，从把请求URL转化为如下形式交由LoadBalancerClient处理，比如：

> http://www.test.com/TestServer/info.jsp

会转化为：

> lb://TestServer/info.jsp

然后将由LoadBalancerClient处理。

Spring Cloud Gateway当前支持两种组件：

>  *  blocking ribbon
>  *  reactive loadbalancer

### 1、blocking ribbon ###

application.properties配置

> spring.cloud.loadbalancer.ribbon.enabled=true  \#此为默认配置

此配置会使用*org.springframework.cloud.gateway.filter.LoadBalancerClientFilter*，它由*org.springframework.cloud.gateway.config.GatewayLoadBalancerClientAutoConfiguration* 初始化。  
使用此配置后，需要使用Netflix Ribbon组件，因此要添加依赖。  
Maven配置

> <dependency>  
>     <groupId>org.springframework.cloud</groupId>  
>     <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>  
>     <version>$\{spring-cloud.version\}</version>  
> </dependency>

与ribbon的相关配置ribbonPing和ribbonServerList，会在*org.springframework.cloud.netflix.ribbon.eureka.EurekaRibbonClientConfiguration*中初始化：  
ribbonPing：

> com.netflix.niws.loadbalancer.NIWSDiscoveryPing       \#将由Eureka来决定服务器是否正常

ribbonServerList：

> org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList   \#从Eureka client中获取服务器列表

它是对com.netflix.niws.loadbalancer.DiscoveryEnabledNIWSServerList的扩展，DiscoveryEnabledNIWSServerList将从Eureka client中获取服务器列表

其它与ribbon的相关配置，仍会使用org.springframework.cloud.netflix.ribbon.RibbonClientConfiguration初始化。

ribbon中一些重要类的功能说明：

>  *  ZonePreferenceServerListFilter  只会使用指定区域内的服务器
>  *  ZoneAffinityServerListFilter         优先使用指定区域内的服务器，若指定区域内无服务器可用，则选择一个别的区域内的服务器。
>  *  ZoneAvoidanceRule
> 
> 1.  ZoneAvoidancePredicate    当一个zone的度量统计值超过一个阈值时，这个zone下的所有server将被过滤掉
> 2.  AvailabilityPredicate            过滤掉已熔断的server，和并发连接数据过大的server
> 
>  *  ZoneAwareLoadBalancer           针对不同的zone创建不同的LoadBalancer实例来进行处理

### 2、reactive loadbalancer ###

application.properties配置

> spring.cloud.loadbalancer.ribbon.enabled=false  \#此为官方文档推荐配置

此配置会使用*org.springframework.cloud.gateway.filter.ReactiveLoadBalancerClientFilter*，它由*org.springframework.cloud.gateway.config.GatewayReactiveLoadBalancerClientAutoConfiguration* 初始化。  
此配置只会用到Spring Cloud自己的实现。  
Maven配置

> <dependency>  
>     <groupId>org.springframework.cloud</groupId>  
>     <artifactId>spring-cloud-starter-loadbalancer</artifactId>  
>     <version>$\{spring-cloud.version\}</version>  
> </dependency>

其中使用的LoadBalancer：org.springframework.cloud.loadbalancer.core.RoundRobinLoadBalancer

## 三、例子 ##

### 1、TestServer ###

Maven

> <properties>  
>     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
>     <springCloud.version>2.2.1.RELEASE</springCloud.version>  
> </properties>
> 
> <parent>  
>     <groupId>org.springframework.boot</groupId>  
>     <artifactId>spring-boot-starter-parent</artifactId>  
>     <version>2.2.1.RELEASE</version>  
>     <relativePath />  
> </parent>
> 
>   
> <dependencies>  
>     <dependency>  
>         <groupId>org.springframework.boot</groupId>  
>         <artifactId>spring-boot-starter-web</artifactId>
> 
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.boot</groupId>  
>         <artifactId>spring-boot-starter-actuator</artifactId>  
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.cloud</groupId>  
>         <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>  
>         <version>$\{springCloud.version\}</version>  
>         <exclusions>  
>             <exclusion>  
>                 <groupId>org.springframework.cloud</groupId>  
>                 <artifactId>spring-cloud-netflix-ribbon</artifactId>  
>             </exclusion>  
>         </exclusions>  
>     </dependency>  
> </dependencies>

bootstrap.properties

> server.port=8081
> 
> spring.application.name=TestServer
> 
> spring.cloud.discovery.enabled=true  
> spring.cloud.service-registry.auto-registration.enabled=true

application.properties

> eureka.client.enabled=true  
> eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
> 
> eureka.client.register-with-eureka=true  
> eureka.client.fetch-registry=true
> 
> \# hostname为此实例提供给外部调用的域名
> 
> eureka.instance.hostname=localhost

Java

package com.test.server;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.autoconfigure.task.TaskSchedulingAutoConfiguration;
    import org.springframework.boot.autoconfigure.web.servlet.error.ErrorMvcAutoConfiguration;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.context.ConfigurableApplicationContext;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @EnableDiscoveryClient
    @SpringBootApplication(exclude = { TaskSchedulingAutoConfiguration.class, ErrorMvcAutoConfiguration.class })
    @RestController
    public class AppBoot {
    
    	public static void main(String[] args) {
    		ConfigurableApplicationContext ctx = SpringApplication.run(AppBoot.class, args);
    		ctx.registerShutdownHook();
    	}
    
    	@RequestMapping("/home")
    	public String home() {
    		String home ="home:server1:" + System.currentTimeMillis();
    		System.out.print(home);
    		
    		return home;
    	}
    	
    	
    	@RequestMapping("/info")
    	public String info() {
    		String info ="info:server1:" + System.currentTimeMillis();
    		System.out.print(info);
    		
    		return info;
    	}
    }

可以多配置一些server，只要server.port不重复就行。

### 2、ServerRegistry ###

application.properties

> server.port=8761
> 
> spring.application.name=ServiceRegistryServer
> 
> eureka.client.register-with-eureka=false  
> eureka.client.fetch-registry=false
> 
> eureka.instance.hostname=localhost

Maven

> <properties>  
>     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
>     <spring-cloud.version>2.2.1.RELEASE</spring-cloud.version>  
> </properties>
> 
> <parent>  
>     <groupId>org.springframework.boot</groupId>  
>     <artifactId>spring-boot-starter-parent</artifactId>  
>     <version>2.2.1.RELEASE</version>  
>     <relativePath />  
> </parent>
> 
>   
> <dependencies>  
>     <dependency>  
>         <groupId>org.springframework.boot</groupId>  
>         <artifactId>spring-boot-starter-web</artifactId>  
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.cloud</groupId>  
>         <artifactId>spring-cloud-starter</artifactId>  
>             <version>$\{spring-cloud.version\}</version>  
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.cloud</groupId>  
>         <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>  
>             <version>$\{spring-cloud.version\}</version>  
>     </dependency>  
> </dependencies>

Java

package com.test.server;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer
    public class ServiceRegistryEurekaApp {
    
    	public static void main(String[] args) throws Exception {
    		SpringApplication.run(ServiceRegistryEurekaApp.class, args);
    	}
    }

### 3、GatewayServer ###

application.properties

> server.port=8070  
> spring.application.name=gatewayServer
> 
>   
> spring.cloud.discovery.enabled=true  
> spring.cloud.service-registry.auto-registration.enabled=false
> 
> eureka.client.enabled=true  
> eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
> 
>   
> eureka.instance.hostname=localhost  
> spring.cloud.loadbalancer.ribbon.enabled=true
> 
>   
> \# unit: ms  
> spring.cloud.gateway.httpclient.connect-timeout=10000  
> spring.cloud.gateway.httpclient.response-timeout=5s

Maven

> <properties>  
>     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
>     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>  
>     <java.version>1.8</java.version>  
>     <spring-cloud.version>2.2.1.RELEASE</spring-cloud.version>  
> </properties>
> 
> <parent>  
>     <groupId>org.springframework.boot</groupId>  
>     <artifactId>spring-boot-starter-parent</artifactId>  
>     <version>2.2.1.RELEASE</version>  
>     <relativePath />  
> </parent>
> 
> <dependencies>  
>     <dependency>  
>         <groupId>org.springframework.boot</groupId>  
>         <artifactId>spring-boot-starter</artifactId>  
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.boot</groupId>  
>         <artifactId>spring-boot-starter-webflux</artifactId>  
>     </dependency>
> 
>     <dependency>  
>         <groupId>org.springframework.cloud</groupId>  
>         <artifactId>spring-cloud-starter</artifactId>  
>         <version>$\{spring-cloud.version\}</version>  
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.cloud</groupId>  
>         <artifactId>spring-cloud-starter-gateway</artifactId>  
>         <version>$\{spring-cloud.version\}</version>  
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.cloud</groupId>  
>         <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>  
>         <version>$\{spring-cloud.version\}</version>  
>     </dependency>  
>     <dependency>  
>         <groupId>org.springframework.cloud</groupId>  
>         <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>  
>         <version>$\{spring-cloud.version\}</version>  
>     </dependency>
> 
> </dependencies>

Java

通过访问：http://localhost:8070/TestServer/info，就可以看到返回的结果了。

参考文档  
Spring Cloud Gateway  
[https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.2.RELEASE/reference/html][https_cloud.spring.io_spring-cloud-static_spring-cloud-gateway_2.2.2.RELEASE_reference_html]  
Spring Cloud Netflix  
[https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.2.2.RELEASE/reference/html][https_cloud.spring.io_spring-cloud-static_spring-cloud-netflix_2.2.2.RELEASE_reference_html]  
Spring Cloud Commons  
[https://cloud.spring.io/spring-cloud-static/spring-cloud-commons/2.2.2.RELEASE/reference/html][https_cloud.spring.io_spring-cloud-static_spring-cloud-commons_2.2.2.RELEASE_reference_html]

[https_cloud.spring.io_spring-cloud-static_spring-cloud-gateway_2.2.2.RELEASE_reference_html]: https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.2.RELEASE/reference/html
[https_cloud.spring.io_spring-cloud-static_spring-cloud-netflix_2.2.2.RELEASE_reference_html]: https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.2.2.RELEASE/reference/html
[https_cloud.spring.io_spring-cloud-static_spring-cloud-commons_2.2.2.RELEASE_reference_html]: https://cloud.spring.io/spring-cloud-static/spring-cloud-commons/2.2.2.RELEASE/reference/html