webflux 搭建websocket客户端

WebFlux是一个基于Spring框架的响应式Web MVC库，它专注于非阻塞、异步的网络编程，非常适合构建高性能的WebSocket应用程序。要在WebFlux中搭建WebSocket客户端，你可以按照以下步骤操作：

1. **添加依赖**：首先，在你的Maven或Gradle项目中添加Spring WebFlux和Spring WebSocket的依赖。例如，对于Maven：

   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-webflux</artifactId>
   </dependency>
   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-websocket</artifactId>
   </dependency>

2. **配置WebSocket支持**：在`application.yml`或`application.properties`文件中添加WebSocket配置，比如连接地址：

   spring:
     web:
       socket:
         enabled: true
         uri: /ws

3. **创建WebSocketClient**：使用Spring的`WebSocketClient`接口创建一个WebSocket连接。这通常通过工厂模式完成，例如：

   @Bean
   public ReactorNettyWebSocketClient webSocketClient() {
       return new ReactorNettyWebSocketClient();
   }

4. **处理WebSocket操作**：编写一个处理器类，实现`TextMessageHandler`或`BinaryMessageHandler`接口来处理接收到的消息。例如：

   @Component
   class MyWebSocketHandler implements TextMessageHandler {
       // 实现onTextMessage方法处理文本消息...
   }

   @Autowired
   private WebSocketClient webSocketClient;

   @PostConstruct
   void initWebSocket() {
       Flux<WebSocket> webSockets = webSocketClient.connectToServer(MyWebSocketHandler.class, URI.create("wss://your-server-url"));
       webSockets.doOnNext(webSocket -> webSocket.sendText("Hello Server!")); // 发送初始消息
   }

5. **启动服务**：运行你的Spring Boot应用，客户端将尝试连接到指定的WebSocket服务器。