spring boot配置websocket

Spring Boot 配置 WebSocket 的过程通常包括以下几个步骤：

1. 添加依赖：在你的 `pom.xml` 或者 `build.gradle` 文件中添加 Spring Websocket 和相关的库，如 Stomp 或者 WebSocket 支持。

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

<!-- Gradle -->
implementation 'org.springframework.boot:spring-boot-starter-websocket'

2. 配置WebSocket：在 `application.yml` 或 `application.properties` 中，启用 WebSocket 并指定一个默认的端口（如果需要的话）。

server:
  port: 8080
  web:
    socket:
      port: 8080

3. 创建WebSocket处理器：创建一个实现了 `TextMessageHandler` 或 `BinaryMessageHandler` 接口的类，并实现消息处理逻辑。

import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.simp.SimpMessageSendingOperations;

@Service
public class ChatWebSocketHandler {
    private final SimpMessageSendingOperations messageSendingOperations;

    @Autowired
    public ChatWebSocketHandler(SimpMessageSendingOperations messageSendingOperations) {
        this.messageSendingOperations = messageSendingOperations;
    }

    @MessageMapping("/chat")
    public void handleMessage(String message) {
        // 处理接收到的消息，可能需要广播或发送给特定用户
        messageSendingOperations.convertAndSendToUser("user1", "/topic/chat", message);
    }
}

4. 注册WebSocket处理器：使用 `@EnableWebSocketMessageBroker` 注解和 `messageBroker` 配置来启用 WebSocket 消息代理。

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

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

5. 访问WebSocket：在前端，你可以使用 JavaScript 的 WebSocket API 或者第三方库（如 Socket.io）来连接到服务器。