java连接websocket代码
时间: 2023-05-21 14:03:13 浏览: 128
以下是一个简单的 Java WebSocket 连接代码示例:
```
import java.net.URI;
import java.net.URISyntaxException;
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 {
final CountDownLatch latch = new CountDownLatch(1);
WebSocketClient client = new WebSocketClient(new URI("ws://localhost:8080")) {
@Override
public void onOpen(ServerHandshake handshakedata) {
System.out.println("WebSocket opened: " + handshakedata.getHttpStatus() + " " + handshakedata.getHttpStatusMessage());
}
@Override
public void onMessage(String message) {
System.out.println("WebSocket message received: " + message);
}
@Override
public void onClose(int code, String reason, boolean remote) {
System.out.println("WebSocket closed: " + code + " " + reason);
latch.countDown();
}
@Override
public void onError(Exception ex) {
System.err.println("WebSocket error: " + ex.getMessage());
latch.countDown();
}
};
client.connect();
latch.await();
}
}
```
这个示例使用了 Java-WebSocket 库,它提供了一个 WebSocketClient 类,可以用来连接 WebSocket 服务器。在这个示例中,我们创建了一个 WebSocketClient 对象,指定了要连接的 WebSocket 服务器的 URI,然后实现了一些回调方法来处理 WebSocket 的事件,比如连接打开、收到消息、连接关闭等等。最后,我们调用了 connect() 方法来连接 WebSocket 服务器,并使用 CountDownLatch 来等待连接关闭。
阅读全文