Java和WebSocket：如何实现实时游戏通信

服务器端代码

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;

@ServerEndpoint("/websocket")
public class WebSocketServer {
private static Set sessions = Collections.synchronizedSet(new HashSet());

@OnOpen
public void onOpen(Session session) {
sessions.add(session);
}

@OnMessage
public void onMessage(Session session, String message) throws IOException {
for (Session s : sessions) {
s.getBasicRemote().sendText(message);
}
}

@OnClose
public void onClose(Session session) {
sessions.remove(session);
}

@OnError
public void onError(Throwable t) {
t.printStackTrace();
}
}

登录后复制

客户端代码

import javax.websocket.*;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Scanner;

@ClientEndpoint
public class WebSocketClient {
Session session;

@OnOpen
public void onOpen(Session session) {
this.session = session;
}

@OnMessage
public void onMessage(String message) {
System.out.println("Received message: " + message);
}

@OnError
public void onError(Throwable t) {
t.printStackTrace();
}

@OnClose
public void onClose() {
System.out.println("Connection closed");
}

public void sendMessage(String message) {
try {
session.getBasicRemote().sendText(message);
} catch (IOException e) {
e.printStackTrace();
}
}

public static void main(String[] args) throws URISyntaxException {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
String uri = "ws://localhost:8080/websocket";
container.connectToServer(WebSocketClient.class, new URI(uri));

WebSocketClient client = new WebSocketClient();

System.out.println("Enter your message (type 'exit' to quit):");
Scanner scanner = new Scanner(System.in);
while (true) {
String input = scanner.nextLine();
if (input.equals("exit")) {
break;
}
client.sendMessage(input);
}

client.session.close();
}
}

登录后复制

在上述示例中，我们创建了一个WebSocketClient类，并使用@ClientEndpoint注解标注。该类定义了onOpen、onMessage、onClose和onError等方法，分别表示在连接建立、接收到消息、连接关闭和发生错误时的回调处理。sendMessage方法用于发送消息。在main方法中我们首先获取WebSocket容器，然后通过connectToServer方法连接到服务器，并使用sendMessage发送从键盘输入的消息。最后通过scanner.nextLine方法不断读取用户的输入，直到输入“exit”退出。

总结：通过Java和WebSocket，我们可以方便地实现实时游戏通信。通过WebSocket的全双工通信特性，我们可以在客户端和服务器之间实现双向的实时通信，并且可以传递较小的数据包。在本文中，我们通过Java API for WebSocket库提供的类和方法，实现了一个简单的实时游戏通信示例。这个示例可以作为学习和参考，帮助开发者更好地理解和应用Java和WebSocket实现实时游戏通信。

参考文献：