Spring Cloud Gateway

如何启动 Spring Cloud Gateway

1、新建 Maven 工程，添加相关依赖 pom.xml

1. <?xml version="1.0" encoding="UTF-8"?>

2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

3.         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd">

4.    <modelVersion>4.0.0</modelVersion>

6.    <groupId>com.anoyi</groupId>

7.    <artifactId>core-gateway</artifactId>

8.    <version>0.0.1-SNAPSHOT</version>

10.    <name>core-gateway</name>

11.    <description>gateway for miroservice</description>

13.    <properties>

14.        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

15.        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

16.        <java.version>1.8</java.version>

17.    </properties>

19.    <dependencyManagement>

20.        <dependencies>

21.            <dependency>

22.                <groupId>org.springframework.cloud</groupId>

23.                <artifactId>spring-cloud-gateway</artifactId>

24.                <version>2.0.0.RELEASE</version>

25.                <type>pom</type>

26.                <scope>import</scope>

27.            </dependency>

28.        </dependencies>

29.    </dependencyManagement>

31.    <dependencies>

33.        <dependency>

34.            <groupId>org.springframework.cloud</groupId>

35.            <artifactId>spring-cloud-starter-gateway</artifactId>

36.        </dependency>

38.    </dependencies>

40.    <build>

41.        <plugins>

42.            <plugin>

43.                <groupId>org.springframework.boot</groupId>

44.                <artifactId>spring-boot-maven-plugin</artifactId>

45.            </plugin>

46.        </plugins>

47.    </build>

49. </project>

2、添加启动类 Application.java

1. import org.springframework.boot.SpringApplication;

2. import org.springframework.boot.autoconfigure.SpringBootApplication;

3. import org.springframework.context.annotation.Configuration;

5. @Configuration

6. @SpringBootApplication

7. public class Application {

9.    public static void main(String[] args) {

10.        SpringApplication.run(Application.class, args);

11.    }

13. }

3、启动 Application（和 Spring Boot 项目一样）

访问 http://localhost:8080/ 报错 404，同时日志输出：

1. 2018-06-27 09:18:48.981  WARN 44156 --- [ctor-http-nio-2] .a.w.r.e.DefaultErrorWebExceptionHandler :

2. Failed to handle request [GET http://localhost:8080/]: Response status 404

配置服务的路由：配置文件方式

假设本地启动了另外两个 Spring Boot 服务，分别是 服务A( http://localhost:8081)、服务B( http://localhost:8082 )，下面通过 Spring Cloud Gateway 来路由到这两个服务。

1、在 resources 路径下添加配置文件 application.yml

1. spring:

2.  cloud:

3.    gateway:

4.      routes:

5.      - id: host_route

6.        uri: http://localhost:8081

7.        predicates:

8.        - Path=/a/**

9.        filters:

10.        - StripPrefix=1

11.      - id: host_route

12.        uri: http://localhost:8082

13.        predicates:

14.        - Path=/b/**

15.        filters:

16.        - StripPrefix=1

• id：固定，不同 id 对应不同的功能，可参考 官方文档

• uri：目标服务地址

• predicates：路由条件

• filters：过滤规则

2、重启 Gateway 服务

3、测试

访问 http://localhost:8080/a/ 路由到 服务A http://localhost:8081/

访问 http://localhost:8080/b/ 路由到 服务B http://localhost:8082/

其他地址，例如 http://localhost:8080/a/user/all 路由到 服务A http://localhost:8081/user/all

配置服务的路由：编码方式

实现如上服务路由，还可以通过编码的方式实现。

1、删除配置文件 application.yml

2、修改 Application.java， 添加自定义路由配置

1. import org.springframework.boot.SpringApplication;

2. import org.springframework.boot.autoconfigure.SpringBootApplication;

3. import org.springframework.cloud.gateway.filter.factory.StripPrefixGatewayFilterFactory;

4. import org.springframework.cloud.gateway.route.RouteLocator;

5. import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;

6. import org.springframework.context.annotation.Bean;

8. @SpringBootApplication

9. public class Application {

11.    @Bean

12.    public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {

13.        StripPrefixGatewayFilterFactory.Config config = new StripPrefixGatewayFilterFactory.Config();

14.        config.setParts(1);

15.        return builder.routes()

16.                .route("host_route", r -> r.path("/a/**").filters(f -> f.stripPrefix(1)).uri("http://localhost:8081"))

17.                .route("host_route", r -> r.path("/b/**").filters(f -> f.stripPrefix(1)).uri("http://localhost:8082"))

18.                .build();

19.    }

21.    public static void main(String[] args) {

22.        SpringApplication.run(Application.class, args);

23.    }

25. }

其他功能

http://cloud.spring.io/spring-cloud-gateway/single/spring-cloud-gateway.html

官方提供了大量的路由规则，比如Time、Host、Header 等等，同时也提供了大量的过滤器，比如AddRequestHeader、AddRequestParameter、AddResponseHeader 等等。仅通过简单的配置即可实现功能强大的网关服务。