springboot 实现websocket

要在Spring Boot中实现WebSocket，可以遵循以下步骤：

1. 在pom.xml文件中添加spring-boot-starter-websocket依赖项。

2. 创建一个WebSocket配置类，使用@EnableWebSocket注解启用WebSocket，并继承WebSocketMessageBrokerConfigurer类。

3. 在配置类中，重写registerStompEndpoints()方法，用于注册WebSocket端点。可以使用withSockJS()方法启用SockJS支持，以便在不支持WebSocket的浏览器上提供备用传输选项。

4. 创建一个WebSocket处理器类，实现WebSocketHandler接口，并重写相关方法来处理WebSocket连接和消息。

5. 在处理器类中，可以使用@MessageMapping注解来定义处理特定消息的方法。

6. 运行Spring Boot应用程序，WebSocket将在指定的端点上启用。

以下是一个简单的示例代码：

// 1. 添加依赖
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

// 2. 创建WebSocket配置类
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

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

// 3. 创建WebSocket处理器类
@Component
public class WebSocketHandler implements WebSocketHandler {

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        // 处理连接建立后的操作
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        // 处理收到的消息
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        // 处理传输错误
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        // 处理连接关闭后的操作
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }
}

// 4. 处理特定消息的方法
@Controller
public class MessageController {

    @MessageMapping("/sendMessage")
    public void sendMessage(String message) {
        // 处理收到的消息
    }
}