簡(jiǎn)介

Spring Cloud Gateway是Spring Cloud官方推出的第二代網(wǎng)關(guān)框架，取代Zuul網(wǎng)關(guān)。網(wǎng)關(guān)作為流量的，在微服務(wù)系統(tǒng)中有著非常作用，網(wǎng)關(guān)常見(jiàn)的功能有路由轉(zhuǎn)發(fā)、權(quán)限校驗(yàn)、限流控制等作用

Git地址

https://gitee.com/wqrzsy/lp-demo/tree/master/lp-springboot-gateway

更多demo請(qǐng)關(guān)注

springboot demo實(shí)戰(zhàn)項(xiàng)目
java 腦洞
java 面試寶典
開(kāi)源工具

項(xiàng)目分析

1. 項(xiàng)目包含四個(gè)項(xiàng)目

• lp-eureka 注冊(cè)服務(wù)中心
• lp-gateway 網(wǎng)關(guān)
• lp-test-service 提供測(cè)試服務(wù)
• lp-springboot-admin 監(jiān)控

啟動(dòng)順序 lp-eureka -> lp-gateway -> lp-springboot-admin -> lp-test-service

2. lp-springboot-admin
   Spring Boot Admin 用于監(jiān)控基于 Spring Boot 的應(yīng)用，它是在 Spring Boot Actuator 的基礎(chǔ)上提供簡(jiǎn)潔的可視化 WEB UI。

詳細(xì) ：

3. lp-gateway

跨域的設(shè)置

/**
     * 設(shè)置跨域
     * @return
     */
    @Bean
    public WebFilter corsFilter() {
        return (ServerWebExchange ctx, WebFilterChain chain) -> {
            ServerHttpRequest request = ctx.getRequest();
            // 判斷是否是跨域請(qǐng)求
            if (CorsUtils.isCorsRequest(request)) {
                HttpHeaders requestHeaders = request.getHeaders();
                ServerHttpResponse response = ctx.getResponse();
                HttpMethod requestMethod = requestHeaders.getAccessControlRequestMethod();
                HttpHeaders headers = response.getHeaders();
                // 設(shè)置跨域?qū)傩?                headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, requestHeaders.getOrigin());
                headers.addAll(HttpHeaders.ACCESS_CONTROL_ALLOW_HEADERS, requestHeaders
                        .getAccessControlRequestHeaders());
                if (requestMethod != null) {
                    headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_METHODS, requestMethod.name());
                }
                headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS, "true");
                headers.add(HttpHeaders.ACCESS_CONTROL_EXPOSE_HEADERS, "*");
                headers.add(HttpHeaders.ACCESS_CONTROL_MAX_AGE, MAX_AGE);
                // 判斷是否是返回
                if (request.getMethod() == HttpMethod.OPTIONS) {
                    response.setStatusCode(HttpStatus.OK);
                    return Mono.empty();
                }
            }
            return chain.filter(ctx);
        };
    }

自定義過(guò)濾器： 域名過(guò)濾器

添加GateWay域名到Request中給下流服務(wù)器使用

@Component
public class RealmNameGatewayFilterFactory extends AbstractGatewayFilterFactory<Object> {

    private static final Logger logger = LoggerFactory.getLogger(RealmNameGatewayFilterFactory.class);

    @Override
    public GatewayFilter apply(Object config) {
        return (exchange, chain) -> {
            ServerHttpRequest host = exchange.getRequest().mutate().headers(httpHeaders -> {
                URI requestURI = exchange.getRequest().getURI();
                String realmName = requestURI.getHost();
                Assert.notNull(realmName, "host 為空");
                realmName = realmName + ":" + requestURI.getPort();
                httpHeaders.add("realmName", realmName);
                logger.info("headers:" + httpHeaders.toString());
            }).build();
            //將現(xiàn)在的request 變成 change對(duì)象
            ServerWebExchange build = exchange.mutate().request(host).build();
            return chain.filter(build);
        };
    }

}

分流，通過(guò)配置導(dǎo)向不同服務(wù)，并在轉(zhuǎn)發(fā)時(shí)去掉導(dǎo)向標(biāo)識(shí)

      #配置路由
      routes:

        - id: service
          #eureka上的服務(wù)名
          uri: lb://LP-TEST-SERVICE
          predicates:
            - Path=/qa/**
          filters:
            # 去掉/qa/ 比如訪問(wèn)url是/qa/test 經(jīng)過(guò)gateway后，后面服務(wù)拿到的就只有/test
            - StripPrefix=1
      # 設(shè)置默認(rèn)過(guò)濾器，設(shè)置域名過(guò)濾器為默認(rèn)過(guò)濾
      default-filters:
        - RealmName

2. 測(cè)試

http://localhost:8000/qa/test/swagger-ui.html

demo項(xiàng)目導(dǎo)入

PS ：本項(xiàng)目使用了JDK11，主要導(dǎo)入的時(shí)候要先安裝JDK11
參考： http://www.itdecent.cn/p/cd0275a2f5fb

如果這篇文章對(duì)你有幫助請(qǐng)給個(gè)star

image.png