Websocket服务接入

此篇文介绍如何将 Websocket 服务接入到 Apache ShenYu 网关，Apache ShenYu 网关使用 Websocket 插件来接入 Websocket服务。

接入前，请正确启动 shenyu-admin，并开启 Websocket插件，在网关端和 Websocket服务端引入相关依赖。可以参考前面的 Websocket快速开始 。

应用客户端接入的相关配置请参考：客户端接入配置。

数据同步的相关配置请参考：数据同步配置。

在网关中引入 Websocket 插件

引入网关对 Websocket的代理插件，在网关的 pom.xml 文件中增加如下依赖，默认已引入该依赖：

  1.         <!--shenyu websocket plugin start-->
  2.         <dependency>
  3.             <groupId>org.apache.shenyu</groupId>
  4.             <artifactId>shenyu-spring-boot-starter-plugin-websocket</artifactId>
  5.             <version>${project.version}</version>
  6.         </dependency>
  • 重启你的网关服务。

Websocket服务接入网关

参考示例： shenyu-examples-websocket，包含 annotation websocket、spring native websocket、spring reactive websocket三种实现方式的示例

  1. 在由 Websocket构建的服务中，引入如下依赖：
  1.         <dependency>
  2.             <groupId>org.apache.shenyu</groupId>
  3.             <artifactId>shenyu-spring-boot-starter-client-websocket</artifactId>
  4.             <version>${shenyu.version}</version>
  5.         </dependency>
  1. 在 application.yaml 配置文件增加如下配置：
  1. shenyu:
  2.   register:
  3.     registerType: http
  4.     serverLists: http://localhost:9095 # shenyu-admin服务端口
  5.     props:
  6.       username: admin
  7.       password: 123456
  8.   client:
  9.     websocket:
  10.       props:
  11.         contextPath: /ws-annotation
  12.         appName: ws-annotation
  13.         port: 8001 # 需要和服务端口保持一致
  1. 在 Websocket服务接口实现类上加上 @ShenyuSpringWebSocketClient 注解，启动你的服务，成功注册后，在 shenyu-admin管理系统进入 插件列表 -> Proxy -> Websocket，会看到自动注册的选择器和规则信息。

示例：

  1. @ShenyuSpringWebSocketClient("/myWs")
  2. @ServerEndpoint("/myWs")
  3. public class WsServerEndpoint {
  4.     @OnOpen
  5.     public void onOpen(final Session session) {
  6.         LOG.info("connect successful");
  7.     }
  10.     @OnClose
  11.     public void onClose(final Session session) {
  12.         LOG.info("connect closed");
  13.     }
  16.     @OnMessage
  17.     public String onMsg(final String text) {
  18.         return "server send message：" + text;
  19.     }
  20. }

用户请求

需要通过 ws 协议来请求你的 Websocket服务。Apache ShenYu网关会配置一个路由前缀，这个路由前缀就是接入网关配置文件中的 contextPath。比如： ws://localhost:9195/ws-annotation/myWs，之后就可以正常建立连接发送和接收消息。