WebSocket 是一種雙向通訊協議，允許 Web 用戶端和伺服器之間建立低延遲、持久連接，廣泛用於建立即時通訊應用程序，如聊天和線上遊戲。在 Java 中，可以使用 WebSocket API 或第三方函式庫，如 Spring WebSocket。使用 WebSocket API 建立連線涉及以下步驟：建立 HTTP 連線、握手和升級至 WebSocket。常見的使用案例是建立多人聊天應用程序，其中伺服器端點透過 Servlet 處理訊息，而客戶端可以透過 JavaScript WebSocket 物件連接到伺服器並發送和接收訊息。
Java 網路程式設計中的WebSocket 和即時通訊
WebSocket 是一個雙向全雙工通訊協議，允許在Web 客戶端和伺服器之間建立低延遲、持久連線。它廣泛用於建立即時通訊應用程序，如聊天、即時協作和線上遊戲。
WebSocket 協定簡介
WebSocket 是一種協議，它在基於 HTTP 的協定之上（通常是 WebSocket）運行。建立 WebSocket 連線涉及以下步驟：
在 Java 中使用 WebSocket
要在 Java 中使用 WebSocket，可以利用 Java WebSocket API 或第三方函式庫，如 Spring WebSocket。本節將探討使用 WebSocket API 的範例。
// 创建 WebSocket 服务器端点
WebSocketServer ws = new WebSocketServer() {
@Override
public void onOpen(WebSocket websocket, ClientEndpointConfig cec) {
System.out.println("客户端已连接");
}
@Override
public void onMessage(String message, WebSocket websocket) {
System.out.println("收到客户端消息：" + message);
}
@Override
public void onClose(WebSocket websocket) {
System.out.println("客户端已断开连接");
}
@Override
public void onError(WebSocket websocket, Throwable cause) {
System.err.println("WebSocket 发生错误：" + cause.getMessage());
}
};
ws.start();// 创建 WebSocket 客户端端点
WebSocketClient wsClient = new WebSocketClient() {
@Override
public void onOpen(ServerEndpointConfig sec) {
System.out.println("连接到服务器");
}
@Override
public void onMessage(String message, Session session) {
System.out.println("收到服务器消息：" + message);
}
@Override
public void onClose(Session session, CloseReason closeReason) {
System.out.println("连接已关闭");
}
@Override
public void onError(Session session, WebSocketError error) {
System.err.println("WebSocket 发生错误：" + error.getMessage());
}
};
wsClient.open("ws://localhost:8080/websocket");實戰案例：聊天應用程式
使用 WebSocket 可以輕鬆建立多人聊天應用程式。以下是一個範例：
// 服务器端：
@WebServlet("/chat")
public class ChatServlet extends HttpServlet {
private Set<WebSocket> webSockets = new HashSet<>();
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) {
String message = req.getParameter("message");
for (WebSocket ws : webSockets) {
ws.sendString(message);
}
}
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
req.setAttribute("ws", new WebSocket(req, resp));
req.getRequestDispatcher("/chat.jsp").forward(req, resp);
}
public void onOpen(WebSocket socket) {
webSockets.add(socket);
}
public void onClose(WebSocket socket) {
webSockets.remove(socket);
}
}
// 客户端：
<script type="text/javascript">
var ws = new WebSocket("ws://localhost:8080/chat");
ws.onopen = function() {
console.log("连接已建立");
};
ws.onmessage = function(event) {
console.log("收到消息：" + event.data);
};
ws.onclose = function() {
console.log("连接已关闭");
};
function sendMessage() {
var message = document.getElementById("message").value;
ws.send(message);
}
</script>以上是Java 網路程式設計中的 WebSocket 與即時通信的詳細內容。更多資訊請關注PHP中文網其他相關文章！
