springboot怎么使用websocket

使用 Spring Boot 来实现 WebSocket 可以分为以下几个步骤：

1. 添加依赖

首先需要在 pom.xml 文件中添加 Spring Boot WebSocket 的依赖：

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

2. 创建 WebSocket 配置类

我们需要创建一个 WebSocket 配置类，这个类需要使用 @Configuration 注解进行标注，同时需要继承 WebSocketConfigurer 接口，并实现其中的 registerWebSocketHandlers 方法。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
 
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new MyWebSocketHandler(), "/my-websocket");
    }
}

在 registerWebSocketHandlers 方法中，我们需要将我们自己实现的 WebSocket 处理程序注册到指定的路径上，这里我们将 MyWebSocketHandler 注册到了 /my-websocket 路径上。

3. 实现 WebSocket 处理程序

我们需要自己实现 WebSocket 处理程序，这个处理程序需要继承 AbstractWebSocketHandler 类，并重写其中的 handleTextMessage 方法。

public class MyWebSocketHandler extends AbstractWebSocketHandler {
 
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        System.out.println("Received message: " + message.getPayload());
        session.sendMessage(new TextMessage("Hello, " + message.getPayload() + "!"));
    }
}

在 handleTextMessage 方法中，我们可以处理客户端发送过来的消息，并将消息发送回客户端。

4. 编写客户端代码

最后，我们需要编写客户端代码来连接 WebSocket 服务器，并发送消息。这里我们使用了 Java 的 WebSocket API。

public class MyWebSocketClient {
 
    public static void main(String[] args) throws Exception {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        Session session = container.connectToServer(new Endpoint() {
            @Override
            public void onOpen(Session session, EndpointConfig config) {
                try {
                    session.getBasicRemote().sendText("World");
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }, URI.create("ws://localhost:8080/my-websocket"));
        session.addMessageHandler(new MessageHandler.Whole<String>() {
            @Override
            public void onMessage(String message) {
                System.out.println("Received message: " + message);
            }
        });
    }
}

在这个客户端代码中，我们首先连接到了 WebSocket 服务器，然后发送了一个消息，并在收到服务器返回的消息时打印出来。

以上就是使用 Spring Boot 实现 WebSocket 的步骤。