springcloudgateway網(wǎng)關轉發(fā)websocket請求-創(chuàng)新互聯(lián)

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

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

1、springcloud gateway關鍵術語

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

2、springcloud gateway處理流程
客戶端向 Spring Cloud Gateway 發(fā)出請求。然后在 Gateway Handler Mapping 中找到與請求相匹配的路由，將其發(fā)送到 Gateway Web Handler。Handler 再通過指定的過濾器鏈來將請求發(fā)送到我們實際的服務執(zhí)行業(yè)務邏輯，然后返回。過濾器之間用虛線分開是因為過濾器可能會在發(fā)送代理請求之前（“pre”）或之后（“post”）執(zhí)行業(yè)務邏輯。
在這里插入圖片描述

3、在springcloud gateway網(wǎng)關中，在yml配置文件中通過如下配置對websocket請求進行轉發(fā)：

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

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

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)關中轉發(fā)websocket請求時，連上websocket后出現(xiàn)立馬斷開問題，報錯java.lang.UnsupportedOperationException，詳細如下：

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]

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

// 跨域配置源
        UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
        //設置跨域的配置信息
        CorsConfiguration corsConfiguration = new CorsConfiguration();
        // 允許所有請求來源進行跨域
        //corsConfiguration.addAllowedOrigin("*");
        ...

需改成reactor響應式方式，如下：

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

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

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

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

@Configuration
public class CorsConfig {

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

}

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

名稱欄目：springcloudgateway網(wǎng)關轉發(fā)websocket請求-創(chuàng)新互聯(lián)
URL網(wǎng)址：http://muchs.cn/article6/dphsig.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供Google、ChatGPT、移動網(wǎng)站建設、網(wǎng)站內(nèi)鏈、虛擬主機、用戶體驗

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容