java调用websocket接口

import java.net.URI;
import javax.websocket.ContainerProvider;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;
import javax.websocket.OnOpen;
import javax.websocket.OnMessage;
import javax.websocket.OnClose;
import javax.websocket.ClientEndpoint;
import javax.websocket.EndpointConfig;
import javax.websocket.Session;
import javax.websocket.DeploymentException;
import java.io.IOException;
import java.net.URISyntaxException;

// 定义一个客户端 WebSocket 端点
@ClientEndpoint
public class MyWebSocketClient {

    // 当连接建立时调用
    @OnOpen
    public void onOpen(Session session) {
        System.out.println("Connected to endpoint: " + session.getBasicRemote());
    }

    // 当接收到消息时调用
    @OnMessage
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }

    // 当连接关闭时调用
    @OnClose
    public void onClose() {
        System.out.println("Connection closed.");
    }

    // 主方法，用于启动 WebSocket 客户端
    public static void main(String[] args) {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        try {
            // 连接到指定的 WebSocket 服务器
            Session session = container.connectToServer(MyWebSocketClient.class, URI.create("ws://example.com/websocket"));

            // 发送消息到 WebSocket 服务器
            session.getBasicRemote().sendText("Hello WebSocket Server!");

            // 保持程序运行一段时间以接收响应
            Thread.sleep(5000);

            // 关闭会话
            session.close();
        } catch (DeploymentException | IOException | URISyntaxException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

解释说明：

1. 导入必要的包：引入了 javax.websocket 包中的类，用于创建和管理 WebSocket 连接。
2. 定义 WebSocket 客户端端点：使用 @ClientEndpoint 注解定义了一个 WebSocket 客户端类 MyWebSocketClient。
3. 连接事件处理：
   • @OnOpen：当连接建立时调用，打印连接信息。
   • @OnMessage：当接收到消息时调用，打印接收到的消息。
   • @OnClose：当连接关闭时调用，打印关闭信息。
4. 主方法：
   • 使用 ContainerProvider.getWebSocketContainer() 获取 WebSocket 容器。
   • 使用 connectToServer 方法连接到指定的 WebSocket 服务器。
   • 使用 session.getBasicRemote().sendText 方法发送消息到服务器。
   • 使用 Thread.sleep 保持程序运行一段时间以接收响应。
   • 最后关闭会话。

请根据实际需求修改 WebSocket 服务器的 URL 和其他逻辑。