springboot2 springcloud Greenwich.SR3 构建微服务--11.gateway网关实现

秒速五厘米 2023-10-09 11:50 18阅读 0赞

Spring Cloud已经放弃Netflix Zuul了。现在Spring Cloud中引用的还是Zuul 1.x版本，而这个版本是基于过滤器的，是阻塞IO，不支持长连接。Zuul 2.x版本跟1.x的架构大一样，性能也有所提升。既然Spring Cloud已经不再集成Zuul 2.x了，那么是时候了解一下Spring Cloud Gateway了。

**Netflix Zuul 1.x  VS  Netflix Zuul 2.x**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70][]

**不过不用担心, 我们还有 Spring Cloud Gateway**

*  基于Spring Framework 5、Project Reactor和Spring Boot 2.0构建
 *  能够在任意请求属性上匹配路由
 *  predicates（谓词） 和 filters（过滤器）是特定于路由的
 *  集成了Hystrix断路器
 *  集成了Spring Cloud DiscoveryClient
 *  易于编写谓词和过滤器
 *  请求速率限制
 *  路径重写

**Route** ： 路由是网关的基本组件。它由ID、目标URI、谓词集合和过滤器集合定义。如果聚合谓词为true，则匹配路由

**Predicate** ： This is a Java 8 Function Predicate

**Filter** ： 是GatewayFilter的一个实例，在这里，可以在发送下游请求之前或之后修改请求和响应

原理

![format_png][]

客户端向Spring Cloud Gateway发出请求。如果Gateway Handler Mapping确定请求与路由匹配，则将其发送给Gateway Web Handler。这个Handler运行通过特定于请求的过滤器链发送请求。过滤器可以在发送代理请求之前或之后执行逻辑。执行所有的“pre”过滤逻辑，然后发出代理请求，最后执行“post”过滤逻辑。

下面开始干活了

1.新建一个项目, 添加依赖

<dependencies>
            <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>
        </dependencies>

2.修改配置文件

spring.application.name=ad-gateway2
    #下面这个配置了,但是没有生效....
    #server.servlet.context-path=/gateway2/
    server.port: 9001
    eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka
    #启用基于服务发现的路由定位
    spring.cloud.gateway.discovery.locator.enabled=true
    #启用服务实例id名称小写支持
    spring.cloud.gateway.discovery.locator.lowerCaseServiceId=true

3.添加启动类注解:

package com.onyx.ad.gateway2;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * @author zk
     * @Description:
     * @date 2019-09-25 11:36
     */
    @SpringBootApplication
    @EnableDiscoveryClient
    public class GatewayApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(GatewayApplication.class,args);
        }
    
    }

4.配置路由规则, 这里我就不写配置文件中写了,以bean的方式进行注入

package com.onyx.ad.gateway2.config;
    
    import org.springframework.cloud.gateway.route.RouteLocator;
    import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.reactive.function.BodyInserters;
    import org.springframework.web.reactive.function.server.RequestPredicates;
    import org.springframework.web.reactive.function.server.RouterFunction;
    import org.springframework.web.reactive.function.server.RouterFunctions;
    import org.springframework.web.reactive.function.server.ServerResponse;
    
    /**
     * @author zk
     * @Description:
     * @date 2019-09-25 12:16
     */
    @Configuration
    public class RouteConfig {
    
        @Bean
        public RouterFunction<ServerResponse> testFunRouterFunction() {
            RouterFunction<ServerResponse> route = RouterFunctions.route(
                    RequestPredicates.path("/test"), request -> ServerResponse.ok()
                            .body(BodyInserters.fromObject("I am testing")));
            return route;
        }
    
        /**
         * 路由规则
         * @param builder
         * @return
         */
        @Bean
        public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
            return builder.routes()
                    .route(r -> r.path("/test/custom").uri("http://ww.baidu.com"))
                                        //路由规则            //eureka中注册的服务提供者id
                    .route(r -> r.path("/ad-search/**").uri("lb://AD-SEARCH"))
                    .route(r->r.path("/ad-sponsor/**").uri("lb:/AD-SPONSOR"))
                    .build();
        }
    
    
    }

启动服务,

访问localhost:9001/test  还有   localhost:9001/test/custom 就可以访问到对应的页面, 这里先跳到百度去.

整个代码地址是:

https://github.com/changhe626/micro-service

Java Framework,欢迎各位前来交流java相关  
QQ群:965125360

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20190925142936224.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE=,size_16,color_FFFFFF,t_70
[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWcyMDE4LmNuYmxvZ3MuY29tL2Jsb2cvODc0OTYzLzIwMTkwNi84NzQ5NjMtMjAxOTA2MjcxNzQzMDkzODQtMjIxMzcwOTE3LnBuZw?x-oss-process=image/format,png