springboot 后端创建websocket请求，带请求头信息

在 Spring Boot 中创建 WebSocket 请求并携带自定义请求头，通常需要使用 Spring WebFlux 或者整合第三方库如 Reactor Netty。以下是一个基本步骤示例：

1. 添加依赖：首先，在你的 `pom.xml` 或 `build.gradle` 文件中添加相关的 WebSocket 支持依赖。例如，如果你使用的是 Spring WebFlux，加上以下依赖：

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

2. 创建 WebSocket 服务：定义一个 `ServerWebSocketHandler` 接口的实现类，这是处理 WebSocket 连接的地方。在初始化时，你可以获取 `ServerWebExchange` 对象，该对象包含请求头信息：

   @Bean
   public ServerWebExchangeFilterFunction addRequestHeaderToWebSocket(ServerWebSocketHandler handler) {
       return exchange -> Mono.just(handler).flatMap(h -> h.handleRequest(exchange.mutate()
           .request(exchange.getRequest().mutate().headers(headers -> headers.add("CustomHeader", "Value"))))
           .map(serverHttpResponse -> serverHttpResponse)));
   }

这里我们创建了一个 Filter Function，它会在每个 WebSocket 请求之前添加一个名为 "CustomHeader" 的头。

3. 注册WebSocket配置：在应用启动时，注册这个过滤器到 WebSocket 路由器上：

   @Configuration
   public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
       //...
       @Override
       public void configureMessageBroker(MessageBrokerRegistry config) {
           //...
           config.serverSendChannelPrefix("/topic");
           config.setApplicationDestinationPrefixes("/app");
       }

       @Override
       public void registerStompEndpoints(StompEndpointRegistry registry) {
           registry.addEndpoint("/ws").withSockJS();
           registry.enableSimpleBroker("/topic");
       }

       @Bean
       public WebSocketHandler webSocketHandler() {
           return new MyWebSocketHandler();
       }

       @Bean
       public ServerWebExchangeFilterFunction requestHeaderWebSocketFilter() {
          return addRequestHeaderToWebSocket(webSocketHandler());
       }
   }

4. 定义 WebSocket 处理程序（MyWebSocketHandler）：在这个类中处理具体的 WebSocket 消息收发。

现在，每次从 `/ws` 发送 WebSocket 请求时，都会带着你添加的 "CustomHeader" 请求头信息。