java发送websocket请求
时间: 2023-08-04 20:10:34 浏览: 50
以下是使用Java发送WebSocket请求的示例代码:
```java
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Scanner;
import java.util.concurrent.CountDownLatch;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
public class WebSocketExample {
public static void main(String[] args) throws URISyntaxException, InterruptedException {
Scanner scanner = new Scanner(System.in);
System.out.print("Enter WebSocket URL: ");
String url = scanner.nextLine();
final CountDownLatch latch = new CountDownLatch(1);
WebSocketClient client = new WebSocketClient(new URI(url)) {
@Override
public void onOpen(ServerHandshake handshakedata) {
System.out.println("WebSocket connection opened");
latch.countDown();
}
@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("WebSocket connection closed");
}
@Override
public void onError(Exception ex) {
System.out.println("WebSocket error: " + ex.getMessage());
}
};
client.connect();
latch.await();
System.out.println("WebSocket connection established");
while (true) {
System.out.print("Enter message to send (or exit to quit): ");
String input = scanner.nextLine();
if ("exit".equalsIgnoreCase(input)) {
break;
}
client.send(input);
}
client.close();
System.out.println("WebSocket connection closed");
}
}
```
此代码使用Java-WebSocket库,可从Maven中央库下载。在此示例中,用户输入WebSocket URL,然后建立WebSocket连接。在连接建立后,用户可以通过输入消息来向服务器发送消息。当用户输入“exit”时,连接将关闭。