Java WebSocket聊天室实战：打造实时聊天应用

本教程将指导你使用 Java WebSocket API 构建一个简单的聊天室应用。

代码示例

以下是聊天室的 Java 代码：javaimport javax.websocket.*;import javax.websocket.server.ServerEndpoint;import java.io.IOException;import java.util.Collections;import java.util.HashSet;import java.util.Set;

@ServerEndpoint('/chat')public class ChatRoomWebSocket { private static Set sessions = Collections.synchronizedSet(new HashSet<>());

@OnOpen    public void onOpen(Session session) {        sessions.add(session);        System.out.println('New connection opened. Session ID: ' + session.getId());    }

@OnMessage    public void onMessage(String message, Session session) throws IOException {        System.out.println('Received message: ' + message);

    // 广播消息给所有连接的客户端        for (Session s : sessions) {            if (s.isOpen()) {                s.getBasicRemote().sendText(message);            }        }    }

@OnClose    public void onClose(Session session) {        sessions.remove(session);        System.out.println('Connection closed. Session ID: ' + session.getId());    }

@OnError    public void onError(Session session, Throwable error) {        System.err.println('Error occurred in session ' + session.getId() + ': ' + error.getMessage());    }}

代码解析

@ServerEndpoint('/chat'): 将ChatRoomWebSocket类标记为WebSocket端点，路径为/chat。* onOpen方法：当新的WebSocket连接建立时，将新的Session对象添加到sessions集合中。* onMessage方法：当接收到消息时，将消息广播给所有连接的客户端。* onClose方法：当WebSocket连接关闭时，将关闭的Session对象从sessions集合中移除。* onError方法：处理WebSocket连接期间发生的错误。

部署指南

使用支持WebSocket的Servlet容器，例如Apache Tomcat。2. 将代码编译成名为ChatRoomWebSocket.class的类文件。3. 将类文件打包成WAR文件。4. 将WAR文件部署到Tomcat中。5. 使用支持WebSocket的客户端连接到ws://localhost:8080/your-app-context/chat，其中your-app-context是应用的上下文路径。

总结

通过以上步骤，你就可以使用 Java WebSocket API 构建一个简单的聊天室应用，实现实时消息广播功能。