java发送websocket请求
时间: 2023-08-04 13:10:51 浏览: 89
以下是一个简单的 Java WebSocket 客户端的示例代码:
```java
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Scanner;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
public class WebSocketExample extends WebSocketClient {
public WebSocketExample(URI serverUri) {
super(serverUri);
}
@Override
public void onOpen(ServerHandshake handshakedata) {
System.out.println("Connected to server: " + getURI().toString());
}
@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. Code: " + code + ", Reason: " + reason + ", Remote: " + remote);
}
@Override
public void onError(Exception ex) {
System.out.println("Error occurred: " + ex.getMessage());
}
public static void main(String[] args) throws URISyntaxException {
WebSocketExample client = new WebSocketExample(new URI("ws://localhost:8080/ws"));
client.connect();
Scanner scanner = new Scanner(System.in);
while (true) {
String input = scanner.nextLine();
if (input.equals("exit")) {
client.close();
break;
}
client.send(input);
}
scanner.close();
}
}
```
在这个示例中,我们使用了 `org.java_websocket` 库,它是一个轻量级的 Java WebSocket 客户端和服务器实现。我们创建了一个名为 `WebSocketExample` 的类,它继承自 `WebSocketClient`,并重写了它的四个方法。
我们首先创建了一个 `WebSocketExample` 对象,并调用了它的 `connect()` 方法来连接 WebSocket 服务器。然后我们使用 `Scanner` 类获取用户输入,并将其发送到服务器上,直到用户输入 `exit` 为止。最后我们关闭了 `Scanner` 对象,并调用了 `close()` 方法关闭 WebSocket 连接。
在你的代码中,需要将 `ws://localhost:8080/ws` 替换为你要连接的 WebSocket 服务器的 URL。
阅读全文