SpringCloud之GateWay快速入门

在本项目中只是简单的引入的Spring Cloud GateWay的依赖，来实现路由跳转，更复杂的使用将会在下一篇文章中教大家使用。GateWay 快速入门首先我们创建一个简单的SpringBoot工程，pom依赖如下：<properties><java.version>1.8</java.version>&lt...

代码忘烦恼

3612人浏览 · 2019-09-08 15:14:02

代码忘烦恼 · 2019-09-08 15:14:02 发布

在本项目中只是简单的引入的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>

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

注意这里的核心依赖是：

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

编程式

首先我们在启动类中使用@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();
    }

}

上面这段配置的意思是，配置了一个 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

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

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

省略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);
    }
}

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

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

消费

@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);
    }
}

分别启动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>

创建好项目后，我们将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

上面gateway配置说明:

spring.cloud.gateway.discovery.locator.enabled

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

logging.level.org.springframework.cloud.gateway

调整 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

向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

云原生

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...