springboot websocket 客户端

Spring Boot WebSocket 客户端可以让你的应用程序与另一个 WebSocket 服务器进行通信，以实现实时数据交换。在使用 Spring Boot WebSocket 客户端时，需要在 pom.xml 文件中添加 spring-boot-starter-websocket 依赖。

使用 Spring Boot WebSocket 客户端，你需要创建一个 WebSocket 客户端实例并连接到 WebSocket 服务器。然后你就可以使用 WebSocketSession 对象发送和接收消息了。通过 WebSocketSession 对象，你可以发送文本消息、二进制消息和 ping 消息。同时，你还可以通过 addMessageHandler() 方法注册一个消息处理器来处理从 WebSocket 服务器接收到的消息。

以下是一个示例代码，它演示了如何使用 Spring Boot WebSocket 客户端与 WebSocket 服务器进行通信：

@Component
public class MyWebSocketClient {

    private static final Logger LOGGER = LoggerFactory.getLogger(MyWebSocketClient.class);

    private final WebSocketClient webSocketClient;

    public MyWebSocketClient(WebSocketClient webSocketClient) {
        this.webSocketClient = webSocketClient;
    }

    public void connect() throws Exception {
        URI uri = new URI("ws://localhost:8080/my-websocket-endpoint");

        webSocketClient.doHandshake(new MyWebSocketHandler(), uri);
    }

    private class MyWebSocketHandler extends TextWebSocketHandler {

        @Override
        public void afterConnectionEstablished(WebSocketSession session) throws Exception {
            LOGGER.info("Connected to server!");
            session.sendMessage(new TextMessage("Hello, server!"));
        }

        @Override
        protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
            LOGGER.info("Received message: {}", message.getPayload());
        }
    }
}