一、概述

1.关于Spring Cloud Finchley

Spring Cloud Finchley是6月19日Spring官方正式发布GA版本,Finchley.Release支持了Spring Boot2.0,要求起步JDK8,支持JDK9,Finchley版本带了新的子项目，包括对原先版本的子项目的升级，原先支持的组件现在已经全部为2.0.0.Release，并且在官方的版本生命周期公告中说明，Camden release已经到了终止状态，Dalston release将于2018年12月结束，Edgware release将遵循Spring Boot 1.5.x系列的生命周期结束。Spring Boot2.0的新特性本文不再赘述，本文主要介绍Spring Cloud新的开源子项目Spring Cloud Gateway。

2.关于Spring Cloud Gateway

Spring Cloud Gateway是由spring官方基于Spring5.0,Spring Boot2.0,Project Reactor等技术开发的网关，目的是代替原先版本中的Spring Cloud Netfilx Zuul,目前Netfilx已经开源了Zuul2.0,但Spring 没有考虑集成，而是推出了自己开发的Spring Cloud GateWay。该项目提供了一个构建在Spring Ecosystem之上的API网关，旨在提供一种简单而有效的途径来发送API，并向他们提供交叉关注点，例如：安全性，监控/指标和弹性.

二、实践

以下将介绍Spring Cloud Gateway的一些重点功能和扩展方式，关于基础使用不再文中赘述，如有需要请查阅相关文档。

1.自定义GatewayFilter

GatewayFiltery有两种类型的filter，分别为pre和post类型,以下提供一个demo的配置

定义PreGatewayFilter：

public class PreGatewayFilterFactory extends AbstractGatewayFilterFactory {
 
      public PreGatewayFilterFactory() {
          super(Config.class);
      }
 
      public GatewayFilter apply() {
          return apply(o -> {
          });
      }
      @Override
      public GatewayFilter apply(Config config) {
          // grab configuration from Config object
          return (exchange, chain) -> {
              //If you want to build a "pre" filter you need to manipulate the
              //request before calling change.filter  ServerHttpRequest.Builder builder = exchange.getRequest().mutate();
              builder.header("GatewayFilter", "PreGatewayFilterFactory success");
              //use builder to manipulate the request
              return chain.filter(exchange.mutate().request(builder.build()).build());
          };
      }
      public static class Config {
            //Put the configuration properties for your filter here
      }
}

定义PostGatewayFilter：

public class PostGatewayFilterFactory extends AbstractGatewayFilterFactory {
 
    private Logger logger = LoggerFactory.getLogger(PostGatewayFilterFactory.class);
 
    public PostGatewayFilterFactory() {
        super(Config.class);
    }
 
    public GatewayFilter apply() {
        return apply(o -> {
        });
    }
 
    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) -> {
            logger.info("PostGatewayFilter...");
            return chain.filter(exchange).then(Mono.fromRunnable(() -> {
                ServerHttpResponse response = exchange.getResponse();
                //Manipulate the response in some way
            }));
        };
    }
 
    public static class Config {
        //Put the configuration properties for your filter here
    }
}

自定义GatewayFilter需要在RouteLocator中配置为具体Route项加入，下文RouteLocator配置中会提供demo。

2.全局过滤器（GlobalFilter）

@Configuration
public class GlobalRouteFilter implements GlobalFilter {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest.Builder builder = exchange.getRequest().mutate();
        builder.header("GlobalFilter","GlobalFilter success");
        chain.filter(exchange.mutate().request(builder.build()).build());
        return chain.filter(exchange.mutate().request(builder.build()).build());
    }
}

自定义GlobalFilter只要使用了@Configuration注解或者配置为一个spring bean就会生效，不需要在RouteLocator中配置。

3.请求限流过滤器（RequestRateLimiter）

目前限流Spring Cloud提供了redis的实现，不过可以自定义RequestRateLimiter的实现。Spring Cloud提供的redis实现基于lua加redis桶实现，需要引入Redis的依赖和Redis的相关数据源配置，Redis依赖如下：

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
    </dependency>

Redis限流有两个参数需要配置，redis-rate-limiter.replenishRate是您希望允许用户每秒处理多少个请求，而不会丢失任何请求；redis-rate-limiter.burstCapacity是用户允许在一秒钟内完成的最大请求数，这是令牌桶可以容纳的令牌的数量，将此值设置为零将阻止所有请求。

过滤器采用可选的keyResolver参数特定于限流，可选参数可以自定义设置，以下为一个根据romoteAddress的demo配置（注意需要配置为一个spring bean）：

@Configuration
public class RequestRateLimiterConfig {
    @Bean
    public KeyResolver addressKeyResolver() {
        return exchange -> Mono.just(exchange.getRequest().getRemoteAddress().getAddress().getHostAddress());
    }
}

RequestRateLimiter属于GatewayFilter Factories一种，所以需要在RouteLocator中加入为具体Route项加入或者在配置文件application.yml中配置：

如采用redis限流application.yml配置如下：

    spring:
      cloud:
        gateway:
          routes:
          - id: requestratelimiter_route
            uri: http://example.org
            filters:
            - name: RequestRateLimiter
              args:
                redis-rate-limiter.replenishRate: 10
                redis-rate-limiter.burstCapacity: 20

如果自定义RequestRateLimiter的application.yml配置如下：

    spring:
      cloud:
        gateway:
          routes:
          - id: requestratelimiter_route
            uri: http://example.org
            filters:
            - name: RequestRateLimiter
              args:
                rate-limiter: "#{@myRateLimiter}"
                key-resolver: "#{@userKeyResolver}"

使用SpEL按名称引用bean。＃{@ myRateLimiter}是引用名为myRateLimiter的bean的SpEL表达式。

使用RouteLocator中加入为具体Route项配置在下文RouteLocator配置中会提供demo.

4.权重路由（WeightRoutePredicateFactory)

WeightRoutePredicateFactory是一个路由断言工厂，采用分组的方式来实现权重路由,同样可以采用application.yml或者RouteLocator进行配置：

    spring:
      application:
        name: gateway
      cloud:
        gateway:
          routes:
          - id: provide1
            uri: http://localhost:8080/provide
            predicates:
            - Path=/test
            - Weight=provide, 90
          - id: provide2
            uri: http://localhost:8081/provide
            predicates:
            - Path=/test
            - Weight=provide, 10

RouteLocator配置下文中会提供demo。

5.Hystrix GatewayFilter Factory、 LoadBalancerClient Filter、DiscoveryClient Route Definition Locator的使用

Spring Cloud Gateway提供的这三个功能比较重要且基本都会用到，但比较简单放一块来说明。

Hystrix GatewayFilter Factory需要引入如下依赖：

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>

配置如下：

    hystrix:
      command:
        default:
          execution:
            isolation:
              thread:
                timeoutInMilliseconds: 3000

DiscoveryClient Route Definition Locatorr需要在启动类加上@EnableDiscoveryClient注解并在配置文件中添加eureka或其他注册中心的配置，并且加入如下配置：

    spring:
      cloud:
        gateway:
          discovery:
            locator:
              enabled: true

eureka的依赖如下：

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

LoadBalancerClient Filter的使用比较简单，只需在url前加上lb,以下是这三部分综合使用的一个demo

    spring:
      cloud:
        gateway:
          discovery:
            locator:
              enabled: true
          routes:
          - id: Hystrix
            uri: lb://user
            predicates:
            - Path=/test/**
            filters:
            - name: Hystrix
              args:
                name: fallbackcmd
                fallbackUri: forward:/fallback

其中user是一个向注册中心注册名为user的服务。

7.Websocket Routing Filter

websocket的路由也比较简单在url前加上ws,如果还要使用LoadBalancerClient Filter和DiscoveryClient Route只需 lb:ws: //serviceid 这样写url就可以。

8.RouteLocator

Spring Cloud Gateway为了在Java中进行简单的配置，在RouteLocatorBuilder bean中定义了流畅的API,以下提供与上文相关的demo配置：

    @Configuration
    public class RoutesConfig {
 
        @Autowired
        private KeyResolver addressKeyResolver;
 
        @Bean
        public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
            return builder.routes()
                    //权重路由
                    .route(r->r.weight("provide",90).and().path("/test/weight").filters(f -> f.retry(3).filter(new PreGatewayFilterFactory().apply()).filter(new PostGatewayFilterFactory().apply()).requestRateLimiter().rateLimiter(RedisRateLimiter.class,config -> config.setBurstCapacity(1).setReplenishRate(1)).configure(config -> config.setKeyResolver(addressKeyResolver)).stripPrefix(1).hystrix(config -> config.setFallbackUri("forward:/fallback").setName("fallbackcmd"))).uri("http://localhost:3001/test/weight"))
                    .route(r->r.weight("provide",5).and().path("/test/weight").filters(f -> f.retry(3).filter(new PreGatewayFilterFactory().apply()).filter(new PostGatewayFilterFactory().apply()).requestRateLimiter().rateLimiter(RedisRateLimiter.class,config -> config.setBurstCapacity(1).setReplenishRate(1)).configure(config -> config.setKeyResolver(addressKeyResolver)).stripPrefix(1).hystrix(config -> config.setFallbackUri("forward:/fallback").setName("fallbackcmd"))).uri("http://localhost:3002/test/weight"))
                    //集成了可能会用到的各种filter
                    .route(r -> r.path("/test/**").filters(f -> f.retry(3).filter(new PreGatewayFilterFactory().apply()).filter(new PostGatewayFilterFactory().apply()).requestRateLimiter().rateLimiter(RedisRateLimiter.class,config -> config.setBurstCapacity(1).setReplenishRate(1)).configure(config -> config.setKeyResolver(addressKeyResolver)).stripPrefix(1).hystrix(config -> config.setFallbackUri("forward:/fallback").setName("fallbackcmd"))).uri("lb://user"))
                    .build();
        }
    }

 

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

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

更多推荐

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

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

avatar 云原生

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

企业级ELK Stack构建介绍

avatar 云原生

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

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

avatar 云原生