springboot websocket客户端接收数据

在Spring Boot中使用WebSocket作为客户端接收实时数据通常涉及以下几个步骤：

1. 添加依赖：首先，在项目的pom.xml或build.gradle文件中添加WebSocket相关的依赖，如Spring Websocket或SockJS等。对于Spring Boot，你可以使用`spring-boot-starter-websocket`。

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

2. 配置Starter：在application.properties或application.yml中配置WebSocket支持。

server.webSocket.enabled=true

3. 创建WebSocketClient：创建一个实现了`CloseableSession`接口的类，并通过`WebSocketTemplate`来操作WebSocket连接。

@Autowired
private WebSocketOperations webSocketOperations;

public void subscribeToChannel(ChannelName channel) {
    StompHeaderAccessor accessor = StompHeaderAccessor.createFrameHeader();
    accessor.setCommand(StompCommand.SUBSCRIBE);
    accessor.setDestination("/app/" + channel);

    this.websocketOperations.sendTextMessage(accessor.getMessage(), null); // 发送订阅请求
}

4. 接收消息：在客户端，你需要监听WebSocket的消息事件，例如`MessageReceivedEvent`。

@EventListener
public void onMessageReceived(MessageReceivedEvent event) {
    String message = event.getMessage().getBody(String.class);
    System.out.println("Received message: " + message);
}

5. 关闭连接：当不再需要连接时，记得调用`close()`方法关闭WebSocket连接。

@Override
public void onClose(CloseReason reason) {
    if (reason.getCloseCode() == CloseCodes.NORMALClosure.getValue()) {
        log.info("Connection closed normally");
    } else {
        log.error("Unexpected close reason: {}", reason);
    }
    webSocketOperations.close();
}