使用Java WebSocket进行实时通信问题：示例与解析

原创矫情吗；* 2024-09-16 06:03 65阅读 0赞

WebSocket是一种在单个TCP连接上进行全双工通信的协议。以下是一个简单的Java WebSocket示例，以及其解析过程：

1. **创建WebSocket服务器**：
```java
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;

public class SimpleWebSocketServer {
    @OnOpen
    public void onOpen(Session session) {
        System.out.println("WebSocket opened: " + session.getId());
    }

// Other event handlers (OnMessage, OnClose)

@OnClose
    public void onClose(Session session) {
        System.out.println("WebSocket closed: " + session.getId());
    }
}
```
2. **创建WebSocket客户端**：
```java
import javax.websocket.ClientEndpoint;
import javax.websocket.MessageType;
import java.util.concurrent.Future;

public class SimpleWebSocketClient {
    @ClientEndpoint(value = "ws://example.com/websocket"))
    public WebSocketClient wsClient;

// Send a message to the server
    public Future<String> sendMessage(String message) {
        return wsClient.sendTextMessageAsync(message, MessageType.Text));
    }

// Receive a message from the server
    public Future<String> receiveMessage() {
        return wsClient.receiveTextMessageAsync();
    }
}
```
3. **发送和接收消息**：
```java
// 初始化WebSocket客户端
SimpleWebSocketClient wsClient = new SimpleWebSocketClient();
wsClient.wsClient.open();

// 发送消息到服务器
String messageToServer = "Hello, Server!";
Future<String> sendMessageResponse = wsClient.sendMessage(messageToServer));
System.out.println("Sent to server: " + sendMessageResponse.get());

// 接收服务器的消息
Future<String> receiveMessageResponse = wsClient.receiveMessage();
if (receiveMessageResponse != null) {
    System.out.println("Received from server: " + receiveMessageResponse.get());
}
```
以上就是使用Java WebSocket进行实时通信的基本示例和解析过程。