SpringCloud之GateWay快速入门_springcloudgateway(eureka)教程

在本项目中只是简单的引入的Spring Cloud GateWay的依赖，来实现路由跳转，更复杂的使用将会在下一篇文章中教大家使用。

GateWay 快速入门

首先我们创建一个简单的SpringBoot工程，pom依赖如下：

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Greenwich.SR2</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

关于Spring Cloud GateWay 配置路由有两种方式，分别是注解和配置文件来进行配置。

注意这里的核心依赖是：

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-gateway</artifactId>
    </dependency>
</dependencies>
1
2
3
4
5
6

编程式

首先我们在启动类中使用@Bean来注入RouteLocator来配置路由，完整配置如下:

@SpringBootApplication
public class GatewayApplication {

    public static void main(String[] args) {
        SpringApplication.run( GatewayApplication.class, args );
    }

    @Bean
    public RouteLocator redirectRouteLocator(RouteLocatorBuilder builder) {
        return builder.routes()
                .route("path_router", r -> r.path("/get")
                .uri("http://httpbin.org"))
                .build();
    }

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

上面这段配置的意思是，配置了一个 id 为 path_route 的路由规则，当访问地址 http://localhost:8080/get 时会自动转发到地址：http://httpbin.org/get 。配置完成启动项目即可在浏览器访问进行测试，当我们访问地址http://localhost:8080/get 时页面展示如下信息：

配置文件方式

在resource 中使用.properties或者.yml,这里我用yml来演示,首先在application.yml中配置如下参数:

server:
  port: 8080
spring:
  cloud:
    gateway:
      routes:
        - id: path_route
          uri: http://httpbin.org
          predicates:
            - Path=/get
1
2
3
4
5
6
7
8
9
10

分别来解释下上面配置的作用：

1. id：我们自定义的路由 ID，保持唯一，代码中就是 route() 方法的第一个参数。
2. uri：需要转发的目标服务地址，r -> r.path("/get").uri("http://httpbin.org") 代码使用了函数时编程简化代码。
3. predicates：路由条件，Predicate 接受一个输入参数，返回一个布尔值结果。该接口包含多种默认方法来将 Predicate 组合成其他复杂的逻辑（比如：与，或，非）。
4. filters：过滤规则，本示例暂时没用。

配置完成之后我们把上启动类中的中的RouteLocator 配置全部注销掉, 然后重新启动，访问http://localhost:8080/get ，返回信息和上述返回的结果一致，这说明了通过配置的方式也可以到达路由转发的功能。在实际项目中为了方便维护，推荐使用配置文件的方式来配置。

两个 hello world 版的示例都体验完之后，基本可以了解 Spring Cloud GateWay 的工作机制，在日常项目中我们可根据不同的需求，配置不同的路由转发策略，大部分使用场景只需要调整不同的配置信息即可实现。

网关和注册中心

上面两种转发方式只适合在单一的项目中使用，如果在微服务架构中就会存在一个致命的问题，微服务架构中服务提供者是动态变化的，所以不能直接将目标服务器地址写在配置文件中。那么在微服务架构中如何解决这个问题呢，这个时候就需要和注册中心来配置使用，本文以 Eureka 和 Spring Cloud Gateway 为例给大家讲解。

当网关和注册中心结合起来使用时，把网关当作一个客户端注册到注册中心，然后网关从注册中心获取所有服务，并自动为这些服务提供路由转发功能。Spring Cloud Gateway 提供了此功能，在项目中只需要简单配置即可达到这样的效果，接下来进行演示。

首先我们创建一个名叫spring-cloud-gateway-eureka的maven工程， 做为父工程，然后创建一个eureka-server 的SpringBoot工程，做为注册中心，并且做为子项目。然后我们创建一个rest-provider-1的SpringBoot工程，做为服务提供者，并且做为子项目。然后我们再创建一个rest-consumer-1的SpringBoot工程，做为服务消费者，并且做为子项目。 对于eureka和provider以及consumer的创建我就不阐述了，非常的简单。不清楚的可以参考最下面的源码。 然后我们再创建一个user的普通maven工程，并且提供一个简单的UserVo类。

下面是UserVO内容：

public class UserVo {
     private String nickname;
     private String age;
     private String address;
     private String job;
 }
1
2
3
4
5
6

省略get/set方法

我们在rest-provier-1中提供一个getUser服务，服务编写如下:

@RestController
public class ProviderController {
    private Logger log = LoggerFactory.getLogger(this.getClass());
    @RequestMapping(value = "/getUser",method = RequestMethod.POST)
    public ResponseEntity<Object> getUser(@RequestBody UserVo user) {
        log.info("provider中到getUser服务被调用了");
        user.setAddress(user.getAddress());
        user.setAge(user.getAge());
        user.setJob(user.getJob());
        user.setNickname(user.getNickname());
        return new ResponseEntity<Object>(user, HttpStatus.OK);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13

再rest-consumer-1 中使用feign消费我们rest-provier-1 中提供的服务:
FeignService

@FeignClient("rest-provider-1")
public interface FeignService {
    @GetMapping("/getUser")
    ResponseEntity<Object> getUser(@RequestBody UserVo user);
}
1
2
3
4
5

消费

@RestController
public class ConsumerController {
    @Autowired
    FeignService feignService;

    @RequestMapping(value = "/getUser",method = RequestMethod.POST)
    public ResponseEntity<Object> getUser(@RequestBody UserVo user) {
       Object result =  feignService.getUser(user);
        return new ResponseEntity<Object>(result, HttpStatus.OK);
    }
}
1
2
3
4
5
6
7
8
9
10
11

分别启动eureka-server 、 rest-provider-1、rest-consumer-1 然后通过postman 或者其它http请求工具、对http://localhost:8002/getUser 进行测试，返回下面结果,我们对准备工作就完成了。

然后我们创建eureka-gateway的SpringBoot项目，做为子项目。

eureka-gateway依赖如下:

<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Greenwich.SR2</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

创建好项目后，我们将eureka-gateway注册到eureka-server中，并且配置网关：

spring:
  application:
    name: eureka-gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true
          
server:
  port: 8888

eureka:
  client:
    service-url:
      defaultZone: http://localhost:1111/eureka/

logging:
  level:
    org.springframework.cloud.gateway: debug
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

上面gateway配置说明:

spring.cloud.gateway.discovery.locator.enabled
1

是否开启通过注册中心进行路由转发的功能，通过 serviceId 转发到服务，默认为 false。

logging.level.org.springframework.cloud.gateway
1

调整 gateway 包的 log 级别，以便排查问题。

然后启动eureka-gateway，然后我们访问http://localhost:1111/：

看到都注册上去了后，我们用网关访问我们的服务http://localhost:8888/REST-CONSUMER-1/getUser 注意这里的服务名称必须大写，可以通过配置来支持小写。

我们用postman 之类的工具，来发起请求：

响应结果如下：

说明我们通过路由转发功能调用了 CONSUMER 的 hello 服务，并且我们在配置文件中只是配置了注册中心的地址，并没有配置具体的服务提供者信息。

通过上面的实验说明 Spring Cloud Gateway 和 Eureka 已经深度融合，只需要在 Gateway 中配置好注册中心的地址，即可代理注册中心的所有服务提供者，省掉了中间繁琐的配置。

注意访问的格式是这样的：http://网关地址：端口/服务中心注册 serviceId/具体的 url

总结

本节课为大家演示了如何使用 Spring Cloud Gateway。Spring Cloud Gateway 默认有两种使用方式，一种是通过编码的方式来实现，一种是通过配置文件的方式来实现，推荐使用配置文件的方式来使用，便于后期修改维护。Spring Cloud Gateway 支持和注册中心结合起来使用，只要将 Spring Cloud Gateway 注册到注册中心，即可自动代理注册中心中的所有服务，简化路由配置和使用方式。

源码地址

微服务网关快速实践: github
微服务网关调用服务:github