springcloud gateway網(wǎng)關(guān)是所有微服務(wù)的統(tǒng)一入口。

站在用戶的角度思考問(wèn)題，與客戶深入溝通，找到怒江州網(wǎng)站設(shè)計(jì)與怒江州網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗(yàn)，讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個(gè)性化、用戶體驗(yàn)好的作品，建站類型包括：成都做網(wǎng)站、網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、域名注冊(cè)、虛擬主機(jī)、企業(yè)郵箱。業(yè)務(wù)覆蓋怒江州地區(qū)。

1、springcloud gateway關(guān)鍵術(shù)語(yǔ)

• Route：路由，網(wǎng)關(guān)配置的基本組成模塊。一個(gè)Route模塊由一個(gè) ID，一個(gè)目標(biāo) URI，一組斷言和一組過(guò)濾器定義。如果斷言為真，則路由匹配，目標(biāo)URI會(huì)被訪問(wèn)。
• Predicate：斷言，可以使用它來(lái)匹配來(lái)自 HTTP 請(qǐng)求的任何內(nèi)容。
• Filter：過(guò)濾器，可以使用它攔截和修改請(qǐng)求，并且對(duì)上游的響應(yīng)，進(jìn)行二次處理。過(guò)濾器為org.springframework.cloud.gateway.filter.GatewayFilter類的實(shí)例。

2、springcloud gateway處理流程
客戶端向 Spring Cloud Gateway 發(fā)出請(qǐng)求。然后在 Gateway Handler Mapping 中找到與請(qǐng)求相匹配的路由，將其發(fā)送到 Gateway Web Handler。Handler 再通過(guò)指定的過(guò)濾器鏈來(lái)將請(qǐng)求發(fā)送到我們實(shí)際的服務(wù)執(zhí)行業(yè)務(wù)邏輯，然后返回。過(guò)濾器之間用虛線分開(kāi)是因?yàn)檫^(guò)濾器可能會(huì)在發(fā)送代理請(qǐng)求之前（“pre”）或之后（“post”）執(zhí)行業(yè)務(wù)邏輯。

3、在springcloud gateway網(wǎng)關(guān)中，在yml配置文件中通過(guò)如下配置對(duì)websocket請(qǐng)求進(jìn)行轉(zhuǎn)發(fā)：

spring:
  cloud:
    gateway:
      routes:
        - id: websocket1
          uri: ws://127.0.0.1:9099 #使用方式1：websocket配置，直接地址
          #uri: lb:ws://serviceName #使用方式2：websocket配置，通過(guò)nacos注冊(cè)中心調(diào)用serviceName
          predicates: 
            - Path=/websocket

當(dāng)websocket服務(wù)為基于netty的socketio，netty需要單獨(dú)開(kāi)端口訪問(wèn)，上面方式要直接指定websocket服務(wù)的端口，多個(gè)websocket服務(wù)時(shí)，可以配置多個(gè)相同的路由規(guī)則，每個(gè)指定一個(gè)socketio服務(wù)，然后通權(quán)重實(shí)現(xiàn)負(fù)載均衡：

spring:
  cloud:
    gateway:
      routes:
        - id: websocket1
          uri: ws://127.0.0.1:8081
          predicates:
            - Path=/socket
            - Weight=group1,50
        - id: websocket2
          uri: ws://127.0.0.1:8082
          predicates:
            - Path=/socket
            - Weight=group1,50
        

4、在springcloud gateway網(wǎng)關(guān)中轉(zhuǎn)發(fā)websocket請(qǐng)求時(shí)，連上websocket后出現(xiàn)立馬斷開(kāi)問(wèn)題，報(bào)錯(cuò)java.lang.UnsupportedOperationException，詳細(xì)如下：

2022-12-26 22:01:23.433 ERROR 12636 --- [ctor-http-nio-6] o.s.w.s.adapter.HttpWebHandlerAdapter    : [6726d297-6] Error [java.lang.UnsupportedOperationException] for HTTP GET "/socket/?EIO=3&transport=websocket", but ServerHttpResponse already committed (200 OK)
2022-12-26 22:01:23.433 ERROR 12636 --- [ctor-http-nio-6] r.n.http.server.HttpServerOperations     : [6726d297-1, L:/10.8.0.78:9999 - R:/10.8.0.78:51969] Error finishing response. Closing connection

java.lang.UnsupportedOperationException: null
	at org.springframework.http.ReadOnlyHttpHeaders.put(ReadOnlyHttpHeaders.java:126) ~[spring-web-5.3.20.jar:5.3.20]
	Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Error has been observed at the following site(s):
	*__checkpoint ? org.springframework.web.cors.reactive.CorsWebFilter [DefaultWebFilterChain]
	*__checkpoint ? org.springframework.cloud.gateway.filter.WeightCalculatorWebFilter [DefaultWebFilterChain]
	
	*__checkpoint ? HTTP GET "/socket/?EIO=3&transport=websocket" [ExceptionHandlingWebHandler]
Original Stack Trace:
		at org.springframework.http.ReadOnlyHttpHeaders.put(ReadOnlyHttpHeaders.java:126) ~[spring-web-5.3.20.jar:5.3.20]

通過(guò)分析發(fā)現(xiàn)是gateway處理跨域時(shí)使用的是如下方式：

// 跨域配置源
        UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
        //設(shè)置跨域的配置信息
        CorsConfiguration corsConfiguration = new CorsConfiguration();
        // 允許所有請(qǐng)求來(lái)源進(jìn)行跨域
        //corsConfiguration.addAllowedOrigin("*");
        ...

需改成reactor響應(yīng)式方式，如下：

return (ServerWebExchange ctx, WebFilterChain chain) ->{
            ServerHttpRequest request = ctx.getRequest();
            // 使用SpringMvc自帶的跨域檢測(cè)工具類判斷當(dāng)前請(qǐng)求是否跨域
            if (!CorsUtils.isCorsRequest(request)) {
                return chain.filter(ctx);
            }
            HttpHeaders requestHeaders = request.getHeaders();                                  // 獲取請(qǐng)求頭
            ServerHttpResponse response = ctx.getResponse();                                    // 獲取響應(yīng)對(duì)象
            HttpMethod requestMethod = requestHeaders.getAccessControlRequestMethod();          // 獲取請(qǐng)求方式對(duì)象
            HttpHeaders headers = response.getHeaders();                                        // 獲取響應(yīng)頭
            headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, requestHeaders.getOrigin());   // 把請(qǐng)求頭中的請(qǐng)求源（協(xié)議+ip+端口）添加到響應(yīng)頭中（相當(dāng)于yml中的allowedOrigins）
            headers.addAll(HttpHeaders.ACCESS_CONTROL_ALLOW_HEADERS, requestHeaders.getAccessControlRequestHeaders());
            if (requestMethod != null) {
                headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_METHODS, requestMethod.name());    // 允許被響應(yīng)的方法（GET/POST等，相當(dāng)于yml中的allowedMethods）
            }
            headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS, "true");       // 允許在請(qǐng)求中攜帶cookie（相當(dāng)于yml中的allowCredentials）
            headers.add(HttpHeaders.ACCESS_CONTROL_EXPOSE_HEADERS, "*");             // 允許在請(qǐng)求中攜帶的頭信息（相當(dāng)于yml中的allowedHeaders）
            headers.add(HttpHeaders.ACCESS_CONTROL_MAX_AGE, "18000L");               // 本次跨域檢測(cè)的有效期(單位毫秒，相當(dāng)于yml中的maxAge)
            if (request.getMethod() == HttpMethod.OPTIONS) {                                    // 直接給option請(qǐng)求反回結(jié)果
                response.setStatusCode(HttpStatus.OK);
                return Mono.empty();
            }
            return chain.filter(ctx);                                                           // 不是option請(qǐng)求則放行
        };

5、springcloud gateway處理跨域，可以通過(guò)yml配置方式實(shí)現(xiàn)，如：

gateway:
      # 全局的跨域配置
      globalcors:
        # 解決options請(qǐng)求被攔截問(wèn)題
        add-to-simple-url-handler-mapping: true
        cors-configurations:
          # 攔截的請(qǐng)求
          '[/**]':
            # 允許跨域的請(qǐng)求
            #allowedOrigins: "*" # spring boot2.4以前的配置
            allowedOriginPatterns: "*" # spring boot2.4以后的配置
            # 允許請(qǐng)求中攜帶的頭信息
            allowedHeaders: "*"
            # 運(yùn)行跨域的請(qǐng)求方式
            allowedMethods: "*"
            # 是否允許攜帶cookie
            allowCredentials: true
            # 跨域檢測(cè)的有效期,單位s
            maxAge: 3600

也可以通過(guò)編碼的方式定義跨域配置類，如：

@Configuration
public class CorsConfig {

    @Bean
    public WebFilter corsFilter() {
        return (ServerWebExchange ctx, WebFilterChain chain) ->{
            ServerHttpRequest request = ctx.getRequest();
            // 使用SpringMvc自帶的跨域檢測(cè)工具類判斷當(dāng)前請(qǐng)求是否跨域
            if (!CorsUtils.isCorsRequest(request)) {
                return chain.filter(ctx);
            }
            HttpHeaders requestHeaders = request.getHeaders();                                  // 獲取請(qǐng)求頭
            ServerHttpResponse response = ctx.getResponse();                                    // 獲取響應(yīng)對(duì)象
            HttpMethod requestMethod = requestHeaders.getAccessControlRequestMethod();          // 獲取請(qǐng)求方式對(duì)象
            HttpHeaders headers = response.getHeaders();                                        // 獲取響應(yīng)頭
            headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, requestHeaders.getOrigin());   // 把請(qǐng)求頭中的請(qǐng)求源（協(xié)議+ip+端口）添加到響應(yīng)頭中（相當(dāng)于yml中的allowedOrigins）
            headers.addAll(HttpHeaders.ACCESS_CONTROL_ALLOW_HEADERS, requestHeaders.getAccessControlRequestHeaders());
            if (requestMethod != null) {
                headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_METHODS, requestMethod.name());    // 允許被響應(yīng)的方法（GET/POST等，相當(dāng)于yml中的allowedMethods）
            }
            headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS, "true");       // 允許在請(qǐng)求中攜帶cookie（相當(dāng)于yml中的allowCredentials）
            headers.add(HttpHeaders.ACCESS_CONTROL_EXPOSE_HEADERS, "*");             // 允許在請(qǐng)求中攜帶的頭信息（相當(dāng)于yml中的allowedHeaders）
            headers.add(HttpHeaders.ACCESS_CONTROL_MAX_AGE, "18000L");               // 本次跨域檢測(cè)的有效期(單位毫秒，相當(dāng)于yml中的maxAge)
            if (request.getMethod() == HttpMethod.OPTIONS) {                                    // 直接給option請(qǐng)求反回結(jié)果
                response.setStatusCode(HttpStatus.OK);
                return Mono.empty();
            }
            return chain.filter(ctx);                                                           // 不是option請(qǐng)求則放行
        };
    }

}

你是否還在尋找穩(wěn)定的海外服務(wù)器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機(jī)房具備T級(jí)流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確流量調(diào)度確保服務(wù)器高可用性，企業(yè)級(jí)服務(wù)器適合批量采購(gòu)，新人活動(dòng)首月15元起，快前往官網(wǎng)查看詳情吧

網(wǎng)站欄目：springcloudgateway網(wǎng)關(guān)轉(zhuǎn)發(fā)websocket請(qǐng)求-創(chuàng)新互聯(lián)
轉(zhuǎn)載來(lái)源：http://m.jcarcd.cn/article/dphsig.html