SpringCloud 2.x学习笔记：17、Spring Cloud Gateway之服务注册与发现(Greenwich版本）完整代码

水深无声 2022-01-07 10:15 172阅读 0赞

一共三个模块，服务注册模块eureka-server、服务提供模块service-hello和网关模块service-gateway。

## 1、eureka-server模块 ##

### 1.1 pom ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>com.cntaiping.tpa</groupId>
        <artifactId>eureka-server</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
        <name>eureka-server</name>
        <description>Demo project for Spring Boot</description>
    
        <parent>
            <groupId>com.cntaiping.tpa</groupId>
            <artifactId>gateway</artifactId>
            <version>1.0-SNAPSHOT</version>
        </parent>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
        </dependencies>
    
    </project>

### 1.2 application.properties ###

server.port= 8761
    spring.application.name= eurka-server
    eureka.client.registerWithEureka= false
    eureka.client.fetchRegistry= false
    eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

### 1.3 Application ###

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

## 2、service-hello模块 ##

### 2.1 pom ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>com.cntaiping.tpa</groupId>
        <artifactId>service-hello</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
        <name>service-hello</name>
        <description>Demo project for Spring Boot</description>
    
        <parent>
            <groupId>com.cntaiping.tpa</groupId>
            <artifactId>gateway</artifactId>
            <version>1.0-SNAPSHOT</version>
        </parent>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
        </dependencies>
    
    </project>

### 2.2 application.properties ###

spring.application.name=service-hello
    server.port=8762
    eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

### 2.3 Application ###

package com.cntaiping.tpa.servicehello;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class ServiceHelloApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(ServiceHelloApplication.class, args);
        }
    
    }

### 2.4 Controller ###

package com.cntaiping.tpa.servicehello.controller;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class MessageController {
    
        @Value("${server.port}")
        String port;
    
        @GetMapping("/hello")
        public String hello(@RequestParam("name")String name){
            return "Hello, " + name + " ,I am from port:" + port;
        }
    
    }

## 3、service-gateway模块 ##

### 3.1 pom.xml ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>com.cntaiping.tpa</groupId>
        <artifactId>service-gateway</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
        <name>service-gateway</name>
        <description>Demo project for Spring Boot</description>
    
        <parent>
            <groupId>com.cntaiping.tpa</groupId>
            <artifactId>gateway</artifactId>
            <version>1.0-SNAPSHOT</version>
        </parent>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-gateway</artifactId>
            </dependency>
        </dependencies>
    
    </project>

### 3.2 application.yml ###

server:
      port: 8400
    
    spring:
      application:
        name: service-gateway
      cloud:
        gateway:
          discovery:
            locator:
              enabled: false
              lowerCaseServiceId: true
          routes:
          - id: service-hello
            uri: lb://SERVICE-HELLO
            predicates:
            - Path=/demo/**
            filters:
            - StripPrefix=1
    
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka/

说明：

*  `spring.cloud.gateway.discovery.locator.lowerCaseServiceId=true`是将请求路径上的服务名转换为小写，因为服务注册的时候，向注册中心注册时将服务名转成大写的了。
 *  `spring.cloud.gateway.discovery.locator.enabled=false`的作用是禁用`http://localhost:8400/service-hello/hello?name=1323`这样的请求地址。如果设置为true，spring cloud gateway自动根据服务发现为每一个服务创建了一个router，这个router将以服务名开头的请求路径转发到对应的服务。
 *  `lb://SERVICE-HELLO`即service-hello服务的负载均衡地址，并用StripPrefix的filter 在转发之前将/demo去掉。

### 3.3 Application类 ###

package com.cntaiping.tpa.servicegateway;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class ServiceGatewayApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(ServiceGatewayApplication.class, args);
        }
    }

## 4、运行效果 ##

[http://localhost:8761/][http_localhost_8761]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70]

[http://localhost:8400/demo/hello?name=chengyq][http_localhost_8400_demo_hello_name_chengyq]  
![localhost:8081/demo/hi?name=1323][localhost_8081_demo_hi_name_1323]

[http_localhost_8761]: http://localhost:8761/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70]: /images/20211223/9f649afa84d94b9aa0c2bd094a67ba24.png
[http_localhost_8400_demo_hello_name_chengyq]: http://localhost:8400/demo/hello?name=chengyq
[localhost_8081_demo_hi_name_1323]: /images/20211223/66432ccf5b94464e81f036593c544a48.png