springboot+websocket 做客户端

你可以使用Spring Boot和WebSocket来创建WebSocket客户端。下面是一个简单的示例代码：

首先，确保你的Spring Boot项目中已经添加了WebSocket的依赖。

在你的代码中，创建一个WebSocket客户端类，可以使用`WebSocketClient`接口的实现类`StandardWebSocketClient`。然后，通过调用`doHandshake()`方法来连接到WebSocket服务器。

import org.springframework.web.socket.client.WebSocketClient;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import org.springframework.web.socket.client.WebSocketConnectionManager;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.handler.TextWebSocketHandler;

public class WebSocketClientExample {
    public static void main(String[] args) {
        WebSocketClient webSocketClient = new StandardWebSocketClient();
        WebSocketConnectionManager connectionManager = new WebSocketConnectionManager(webSocketClient, new MyWebSocketHandler(), "ws://localhost:8080/websocket-endpoint");
        connectionManager.start();
    }
}

class MyWebSocketHandler extends TextWebSocketHandler {
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        System.out.println("Connected to WebSocket server!");
        
        // 发送消息到服务器
        session.sendMessage(new TextMessage("Hello, Server!"));
    }
    
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        System.out.println("Received message: " + message.getPayload());
        
        // 关闭连接
        session.close();
    }
}

在上述代码中，`MyWebSocketHandler`是一个自定义的处理器，继承自`TextWebSocketHandler`。你可以根据自己的需求重写其中的方法来处理连接建立、接收消息等事件。

在`WebSocketConnectionManager`的构造函数中，需要传入一个WebSocket客户端实例、自定义的处理器和WebSocket服务器的URL。你可以将`ws://localhost:8080/websocket-endpoint`替换为你实际的WebSocket服务器URL。

运行上述代码后，客户端将会连接到WebSocket服务器，并发送一条消息。当从服务器接收到消息时，将会打印出来，并关闭连接。

希望对你有所帮助！如有问题，请随时提问。