在Java中实现WebSocket连接和操作也相对简单，可以使用Java的WebSocket库，例如Java-WebSocket来创建WebSocket客户端。以下是一个示例，演示如何创建一个WebSocket工具类来连接到WebSocket服务器并发送和接收消息：
首先，确保您已添加Java-WebSocket库的依赖。您可以在Maven或Gradle中添加以下依赖：
Maven:
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.5.1</version>
</dependency>
Gradle:
implementation group: 'org.java-websocket', name: 'Java-WebSocket', version: '1.5.1'
接下来，创建一个WebSocket工具类的示例代码如下：
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import java.net.URI;
public class WebSocketClientExample extends WebSocketClient {
public WebSocketClientExample(URI serverUri) {
super(serverUri);
}
@Override
public void onOpen(ServerHandshake serverHandshake) {
System.out.println("Connected to server");
}
@Override
public void onMessage(String message) {
System.out.println("Received message: " + message);
// 在这里处理接收到的消息
}
@Override
public void onClose(int code, String reason, boolean remote) {
System.out.println("Connection closed: " + reason);
}
@Override
public void onError(Exception ex) {
System.err.println("Error occurred: " + ex.getMessage());
}
public static void main(String[] args) {
String serverUrl = "wss://example.com/websocket";
WebSocketClientExample client = new WebSocketClientExample(URI.create(serverUrl));
try {
client.connect();
} catch (Exception e) {
e.printStackTrace();
}
// 发送消息
client.send("Hello, WebSocket!");
// 可以在此处添加其他逻辑
// 关闭连接
client.close();
}
}
在上述示例中，我们创建了一个名为WebSocketClientExample的类，它继承自WebSocketClient，并覆盖了一些回调方法来处理连接状态、接收消息和错误处理。通过实例化该类并调用connect方法，您可以在Java中创建WebSocket连接并与服务器进行通信。
请将serverUrl替换为您要连接的WebSocket服务器的URL，并根据您的需求添加其他逻辑。这只是一个基本示例，您可以根据具体需求扩展和优化这个工具类。
