在Java中實現一個類似socket.io的實時聊天室可以借助Java的WebSocket技術來實現。WebSocket是一種在客戶端和服務器之間進行全雙工通信的協議，可以實現實時聊天功能。
以下是一個簡單的Java實時聊天室的實現示例：
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
@ServerEndpoint("/chat")
public class ChatServer {
@OnOpen
public void onOpen(Session session) {
// 添加新連接到會話管理器中
ChatSessionManager.addSession(session);
}
@OnMessage
public void onMessage(String message, Session session) {
// 將消息發送給所有連接
ChatSessionManager.broadcast(message);
}
}
import java.util.HashSet;
import javax.websocket.Session;
public class ChatSessionManager {
private static final HashSet<Session> sessions = new HashSet<>();
public static void addSession(Session session) {
sessions.add(session);
}
public static void broadcast(String message) {
sessions.forEach(session -> {
session.getAsyncRemote().sendText(message);
});
}
}
<!DOCTYPE html>
<html>
<head>
<title>Chat Room</title>
</head>
<body>
<input type="text" id="message" />
<button onclick="sendMessage()">Send</button>
<div id="chat"></div>
<script>
const socket = new WebSocket('ws://localhost:8080/chat');
socket.onmessage = function(event) {
document.getElementById('chat').innerHTML += '<p>' + event.data + '</p>';
};
function sendMessage() {
const message = document.getElementById('message').value;
socket.send(message);
document.getElementById('message').value = '';
}
</script>
</body>
</html>
在上面的示例中，我們創建了一個WebSocket服務器來處理客戶端的連接和消息傳輸，然后使用會話管理器類來管理所有連接。客戶端通過WebSocket連接到服務器，發送和接收消息。
需要注意的是，上面的示例只是一個簡單的實現，并沒有處理連接斷開、錯誤處理等邏輯。在實際應用中，還需要添加更多的功能來完善聊天室的功能。
