gateway是netty开发的天生支持websocket。zuul不支持，但是好像可以配置
注意: 如果网关中有登录验证，可能需要对websocket做放行
**

  1. gateway无任何配置的情况下 websocket （一个websocket服务下，多个服务没有测试）一切正常
    1. 设置跨域可能会出现websocket连接不上 ```yaml globalcors: corsConfigurations:
      1. '[/**]':
      2.   allowedHeaders: "*"
      3.   allowedOrigins: "*"
      4.   allowedMethods:
      5.     - GET
      6.       POST
      7.       DELETE
      8.       PUT
      9.       OPTION
  2.       1. 把 allowedMethods 改成 allowedMethods: "*"  就好了
  3.    1. gateway配置文件
  4. ```yaml
  5. server:
  6.   port: 9005
  8. spring:
  9.   application:
  10.     name: test-gateway
  11.   cloud:
  12.     nacos:
  13.       discovery:
  14.         server-addr: 127.0.0.1:8848 # 注册中心
  15.         group: websockt
  16.     #路由配置，user-service是我的服务名
  17.     gateway:
  18.       routes:
  19.         # ws表示websocket的转发
  20.         - id: test-websocket
  21.           uri: ws://127.0.0.1:9006
  22.           predicates:
  23.             - Path=/ws/**
  24.           filters:
  25.             - StripPrefix=1
  26.         # ws表示websocket的转发
  27.         - id: nocas-websocket
  28.           uri: ws://test-websocket
  29.           predicates:
  30.             - Path=/ser/ws/**
  31.           filters:
  32.             - StripPrefix=2
  33.         - id: api-websocket
  34.           uri: lb://test-websocket
  35.           predicates:
  36.             - Path=/api/**
  37.           filters:
  38.             - StripPrefix=1
  40.         # ws表示websocket的转发 -- 可以走 无均衡
  41.         - id: test-websocket2
  42.           uri: ws://127.0.0.1:9007
  43.           predicates:
  44.             - Path=/ws2/**
  45.           filters:
  46.             - StripPrefix=1
  47.         # ws表示websocket的转发 - 这是错误的写法
  48.         - id: nocas-websocket2
  49.           uri: ws://test-websocket2
  50.           predicates:
  51.             - Path=/ser2/ws/**
  52.           filters:
  53.             - StripPrefix=2
  54.         # ws表示websocket的转发 -- 可以走 有均衡 （还没测试均衡怎么玩）
  55.         - id: nocas2-websocket2
  56.           uri: lb:ws://test-websocket2
  57.           predicates:
  58.             - Path=/serlb/ws/**
  59.           filters:
  60.             - StripPrefix=2
  61.         # websocket项目中的正常接口地址    
  62.         - id: api-websocket2
  63.           uri: lb://test-websocket2
  64.           predicates:
  65.             - Path=/api2/**
  66.           filters:
  67.             - StripPrefix=1
  68.       discovery:
  69.         locator:
  70.           enabled: true
  71.           lower-case-service-id: true

b. websocket spring单机版的配置就行了

  1. <!--  我的websocket单机版直接使用的依赖 -->
  2.  <dependency>
  3.    <groupId>com.databstech</groupId>
  4.    <artifactId>util-websocket</artifactId>
  5.    <version>1.0.0</version>
  6.  </dependency>
  7. <!-- 如果是微服务记得加这个o  注册中心  要不然gateway 配置lb:服务名  是访问不到的 -->
  8. <dependency>
  9.   <groupId>com.alibaba.cloud</groupId>
  10.   <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  11.   <!-- 不放进jar包里 用户自己单独加入  -->
  12.   <!--<scope>provided</scope>-->
  13. </dependency>
  1. //util-websocket 配置过程
  3. /**------------------------最重要的注册类-------------------------------*/
  5. package com.databstech.utils.websocket.config;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  9. import org.springframework.web.socket.server.standard.ServerEndpointExporter;
  11. /**
  12.  * 
  13.  * 往 spring 容器中注入ServerEndpointExporter实例
  14.  *
  15.  * @ClassName : WebSocketConfig  //类名
  16.  * @Description : socket配置  //描述
  17.  * @Author : tn  //作者
  18.  * @Date: 2020-07-08 12:33  //时间
  19.  */
  20. @Configuration
  21. public class WebSocketConfig {
  23.     @Bean
  24.     public ServerEndpointExporter serverEndpointExporter(){
  25.         return new ServerEndpointExporter();
  26.     }
  27. }
  30. /**------------------------开始连接，断开连接，发送消息等-------------------------------*/
  32. package com.databstech.utils.websocket.service;
  34. import org.springframework.stereotype.Component;
  36. import javax.websocket.*;
  37. import javax.websocket.server.PathParam;
  38. import javax.websocket.server.ServerEndpoint;
  39. import java.io.IOException;
  40. import java.util.ArrayList;
  41. import java.util.HashMap;
  42. import java.util.List;
  43. import java.util.Map;
  44. import java.util.concurrent.atomic.AtomicInteger;
  46. /**
  47.  * 
  48.  * 包含接收消息，推送消息等接口
  49.  *
  50.  * @ClassName : WebSocketServer
  51.  * @Description : webSocker服务端
  52.  * @Author : tn
  53.  * @Date: 2020-07-08 12:36
  54.  */
  55. @Component
  56. @ServerEndpoint(value = "/socket/{name}")
  57. public class WebSocketServer {
  59.     //静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
  60.     private static AtomicInteger online = new AtomicInteger();
  62.     //concurrent包的线程安全Set，用来存放每个客户端对应的WebSocketServer对象。
  63.     //不允许多端登陆
  64. //    private static Map<String, Session> sessionPools = new HashMap<>();
  66.     //允许多端登陆
  67.     private static Map<String, List<Session>> sessionPoolsS = new HashMap<>();
  69.     /**
  70.      * 发送消息方法
  71.      * @param session 客户端与socket建立的会话
  72.      * @param message 消息
  73.      * @throws IOException 抛出异常
  74.      */
  75.     public void sendMessage(Session session, String message) throws IOException {
  76.         if(session != null){
  77.             session.getBasicRemote().sendText(message);
  78.         }
  79.     }
  82.     /**
  83.      * 连接建立成功调用
  84.      * @param session 客户端与socket建立的会话
  85.      * @param userName 客户端的userName
  86.      */
  87.     @OnOpen
  88.     public void onOpen(Session session, @PathParam(value = "name") String userName){
  90.         List<Session> sessionsArray = new ArrayList<>();
  91.         //获取session
  92.         List<Session> sessions = sessionPoolsS.get(userName);
  93.         //存在session
  94.         if(sessions==null){
  95.             sessionsArray.add(session);
  96.         }else {
  97.             sessionsArray.addAll(sessions);
  98.             sessionsArray.add(session);
  99.         }
  102.         sessionPoolsS.put(userName, sessionsArray);
  103.         addOnlineCount();
  104.         System.out.println(userName + "加入webSocket！当前人数为" + online);
  105.         try {
  106.             sendMessage(session, "欢迎" + userName + "加入连接！");
  107.         } catch (IOException e) {
  108.             e.printStackTrace();
  109.         }
  110.     }
  112.     /**
  113.      * 关闭连接时调用
  114.      * @param userName 关闭连接的客户端的姓名
  115.      */
  116.     @OnClose
  117.     public void onClose(@PathParam(value = "name") String userName, Session session){
  119.         //获取session
  120.         List<Session> sessions = sessionPoolsS.get(userName);
  121.         if(session==null){
  122.             sessionPoolsS.remove(userName);
  123.         }else {
  124.             sessions.remove(session);
  125.             sessionPoolsS.put(userName, sessions);
  126.         }
  127.         subOnlineCount();
  128.         System.out.println(userName + "断开webSocket连接！当前人数为" + online);
  129.     }
  131.     /**
  132.      * 收到客户端消息时触发（群发）
  133.      * @param message
  134.      */
  135.     @OnMessage
  136.     public void onMessage(String message){
  137.         for (List<Session> session: sessionPoolsS.values()) {
  138.             try {
  139.                session.forEach(sessionf -> {
  140.                    try {
  141.                        sendMessage(sessionf, message);
  142.                    } catch (IOException e) {
  143.                        e.printStackTrace();
  144.                    }
  145.                });
  146.             } catch(Exception e){
  147.                 e.printStackTrace();
  148.                 continue;
  149.             }
  150.         }
  151.     }
  153.     /**
  154.      * 发生错误时候
  155.      * @param session session
  156.      * @param throwable throwable
  157.      */
  158.     @OnError
  159.     public void onError(Session session, Throwable throwable){
  160.         System.out.println("发生错误");
  161.         throwable.printStackTrace();
  162.     }
  164.     /**
  165.      * 给指定用户发送消息
  166.      * @param userName 用户名
  167.      * @param message 消息
  168.      */
  169.     public void sendInfo(String userName, String message){
  170.         List<Session> session = sessionPoolsS.get(userName);
  171.         if(session!=null){
  172.             try {
  173.                 session.forEach(sessionf -> {
  174.                     try {
  175.                         sendMessage(sessionf, message);
  176.                     } catch (IOException e) {
  177.                         e.printStackTrace();
  178.                     }
  179.                 });
  180.             }catch (Exception e){
  181.                 e.printStackTrace();
  182.             }
  183.         }
  184.     }
  186.     public static void addOnlineCount(){
  187.         online.incrementAndGet();
  188.     }
  190.     public static void subOnlineCount() {
  191.         online.decrementAndGet();
  192.     }
  195. }
  198. /**------------------------内部默认的接口-----------------------------------------------*/
  200. package com.databstech.utils.websocket.controller;
  202. import com.databstech.utils.websocket.service.WebSocketServer;
  203. import io.swagger.annotations.ApiImplicitParam;
  204. import io.swagger.annotations.ApiImplicitParams;
  205. import io.swagger.annotations.ApiOperation;
  206. import org.springframework.web.bind.annotation.RequestMapping;
  207. import org.springframework.web.bind.annotation.RequestMethod;
  208. import org.springframework.web.bind.annotation.RequestParam;
  210. /**
  211.  * @ClassName : SocketController   接口
  212.  * @Description : socket  //描述
  213.  * @Author : tn  //作者
  214.  * @Date: 2020-07-08 12:40  //时间
  215.  */
  216. public interface SocketController {
  218.     /**
  219.      * 给指定用户推送消息
  220.      * @param userName 用户名
  221.      * @param message 消息
  222.      */
  223.     @RequestMapping(value = "/only", method = RequestMethod.GET)
  224.     @ApiOperation("给指定用户推送消息")
  225.     @ApiImplicitParams({
  226.             @ApiImplicitParam(name="userName", value="用户名",  dataType="String", required=true),
  227.             @ApiImplicitParam(name="message", value="消息", dataType="String", required=true)
  228.     })
  229.     default void onlyUserSocket(@RequestParam String userName, @RequestParam String message, WebSocketServer webSocketServer){
  230.         webSocketServer.sendInfo(userName, message);
  231.     }
  233.     /**
  234.      * 给所有用户推送消息
  235.      * @param message 消息
  236.      */
  237.     @ApiOperation("给所有用户推送消息")
  238.     @ApiImplicitParams({
  239.             @ApiImplicitParam(name="message", value="消息", dataType="String", required=true)
  240.     })
  241.     @RequestMapping(value = "/all", method = RequestMethod.GET)
  242.     default void allUserSocket(@RequestParam String message, WebSocketServer webSocketServer){
  243.         webSocketServer.onMessage(message);
  244.     }
  245. }
  250. // 依赖 
  252.    <!--引入websocket依赖 -->
  253.        <dependency>
  254.             <groupId>org.springframework.boot</groupId>
  255.             <artifactId>spring-boot-starter-websocket</artifactId>
  256.         </dependency>
  257.         <dependency>
  258.             <groupId>io.swagger</groupId>
  259.             <artifactId>swagger-annotations</artifactId>
  260.             <version>1.5.22</version>
  261.             <scope>provided</scope>
  262.         </dependency>

  1. 本来运行的也好好的，但是用了 gateway 聚合了swagger之后从网关访问就是一个接着一个的错误！

    1. 错误如下

      1. java.lang.ClassCastException: org.apache.catalina.connector.ResponseFacade cannot be cast to reactor.netty.http.server.HttpServerResponse
      2. at org.springframework.web.reactive.socket.server.upgrade.ReactorNettyRequestUpgradeStrategy.getNativeResponse(ReactorNettyRequestUpgradeStrategy.java:124) ~[spring-webflux-5.2.4.RELEASE.jar:5.2.4.RELEASE]
      3. Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
      4. Error has been observed at the following site(s):
      5. |_ checkpoint ⇢ org.springframework.cloud.gateway.filter.WeightCalculatorWebFilter [DefaultWebFilterChain]
      6. |_ checkpoint ⇢ org.springframework.boot.actuate.metrics.web.reactive.server.MetricsWebFilter [DefaultWebFilterChain]
      7. |_ checkpoint ⇢ HTTP GET "/ws/socket/tn" [ExceptionHandlingWebHandler]

    2. 层层测试

      1. gateway 原生配置 - 正常转发了
      2. gateway 结合 nacos 配置动态路由 - 也正常转发了
      3. gateway 配置全局异常 - 正常转发
      4. gateway 配置了swagger后 - 也正常转发
      5. 配置了简单的 GatewayFilter（全局拦截）- 也正常 ```java package com.tn.gateway3.filter;

import org.apache.commons.lang.StringUtils; import org.springframework.cloud.gateway.filter.GatewayFilter; import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory; import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.stereotype.Component;

/**

  • @author fsl
  • @description: SwaggerHeaderFilter

  • @date 2019-06-0310:47 */ @Component public class SwaggerHeaderFilter extends AbstractGatewayFilterFactory { private static final String HEADER_NAME = “X-Forwarded-Prefix”;

    private static final String URI = “/v2/api-docs”;

    @Override public GatewayFilter apply(Object config) {

    1.  return (exchange, chain) -> {
    2.      ServerHttpRequest request = exchange.getRequest();
    3.      String path = request.getURI().getPath();
    4.      if (!StringUtils.endsWithIgnoreCase(path,URI )) {
    5.          return chain.filter(exchange);
    6.      }
    7.      return chain.filter(exchange);
    8.  };

    } }

    2.    1. 配置了复杂的  GatewayFilter（全局拦截）- 也正常
    3.    2. 我将所有配置集成起来打成jar后，第三方使用websocket使用出现报错
    4.    3. 我将自己配置 gateway-doc 的 jar 包 进行拆解   
    5.       1. 发现是我配置的 gateway-doc 里的登录拦截器用的 JWT包 发生的问题
    6.       2. **fuck 原来是因为gateway是netty写的跟web犯冲，我JWT项目中引入了**
    7. ```xml
    8.   <dependency>
    9.          <groupId>org.apache.tomcat.embed</groupId>
    10.          <artifactId>tomcat-embed-core</artifactId>
    11.          <version>8.5.43</version>
    12.      </dependency>

    因为我jwt中有个 gettoken的方法使用到了 HttpServletRequest ，现在我他这个方法改了改成了 ```java /**

    • 获取token
    • @param request 请求头

    • @return 返回token */ public static String getToken(ServerHttpRequest request) { final String tokenName = “token”; //从请求头获取token return Optional.ofNullable(request.getHeaders().get(tokenName))

      1.      .map(t -> t.get(0))
      2.      .orElse(null);

      }

依赖

org.springframework spring-web 5.2.8.RELEASE 
  1. nacos 上 websockt相关的 gateway.yaml配置
  2. ```yaml
  3. spring:
  4.   cloud:
  5.     gateway:
  6.        routes:
  7.         # ws表示websocket的转发
  8.         - id: test-websocket
  9.           uri: ws://127.0.0.1:9006
  10.           predicates:
  11.             - Path=/ws/**
  12.             - DocName=noSwagger
  13.           filters:
  14.             - StripPrefix=1
  15.         # ws表示websocket的转发
  16.         - id: nocas-websocket
  17.           uri: ws://test-websocket
  18.           predicates:
  19.             - Path=/ser/ws/**
  20.             - DocName=noSwagger
  21.           filters:
  22.             - StripPrefix=2
  23.         - id: api-websocket
  24.           uri: lb://test-websocket
  25.           predicates:
  26.             - Path=/api/**
  27.             - DocName=websocket
  28.           filters:
  29.             - StripPrefix=1
  31.         # ws表示websocket的转发
  32.         - id: test-websocket2
  33.           uri: ws://127.0.0.1:9007
  34.           predicates:
  35.             - Path=/ws2/**
  36.             - DocName=noSwagger
  37.           filters:
  38.             - StripPrefix=1
  39.         # ws表示websocket的转发 - 这是错误的
  40.         - id: nocas-websocket2
  41.           uri: ws://test-websocket2
  42.           predicates:
  43.             - Path=/ser2/ws/**
  44.             - DocName=noSwagger
  45.           filters:
  46.             - StripPrefix=2
  47.         - id: nocas2-websocket2
  48.           uri: lb:ws://test-websocket2
  49.           predicates:
  50.             - Path=/serlb/ws/**
  51.             - DocName=noSwagger
  52.           filters:
  53.             - StripPrefix=2
  54.         - id: api-websocket2
  55.           uri: lb://test-websocket2
  56.           predicates:
  57.             - Path=/api2/**
  58.             - DocName=noSwagger
  59.           filters:
  60.             - StripPrefix=1
  61.         # 测试动态路由    
  62.         - id: dy-routes
  63.           uri: lb://dy-routes
  64.           predicates:
  65.             - Path=/dy/**
  66.             - DocName=noSwagger
  67.           filters:
  68.             - StripPrefix=1
  69.        default-filters:
  70.         # - StripPrefix=2
  71.         # - RewritePath=/api/(?<segment>.*), /$\{segment}
  72.         # - name: SwaggerHeaderFilter
  73.         - name: AuthFilter
  74.           args:
  75.             excludePatterns:  #不做权限校验的路径
  76.               - /serlb/ws/socket/**