Java 网络编程中的 WebSocket 和实时通信-java教程-PHP中文网

Java 网络编程中的 WebSocket 和实时通信

王林

发布： 2024-05-09 21:42:01

原创

731人浏览过

websocket 是一种双向通信协议，允许 web 客户端和服务器之间建立低延迟、持久连接，广泛用于构建实时通信应用程序，如聊天和在线游戏。在 java 中，可以使用 websocket api 或第三方库，如 spring websocket。使用 websocket api 建立连接涉及以下步骤：建立 http 连接、握手和升级到 websocket。常见的使用案例是构建多人聊天应用程序，其中服务器端点通过 servlet 处理消息，而客户端可以通过 javascript websocket 对象连接到服务器并发送和接收消息。

Java 网络编程中的 WebSocket 和实时通信

Java 网络编程中的 WebSocket 和实时通信

WebSocket 是一个双向全双工通信协议，允许在 Web 客户端和服务器之间建立低延迟、持久连接。它广泛用于构建实时通信应用程序，如聊天、实时协作和在线游戏。

WebSocket 协议简介

立即学习“Java免费学习笔记（深入）”；

WebSocket 是一种协议，它在基于 HTTP 的协议之上（通常是 WebSocket）运行。建立 WebSocket 连接涉及以下步骤：

Android数据格式解析对象JSON用法 WORD版

本文档主要讲述的是Android数据格式解析对象JSON用法；JSON可以将Java对象转成json格式的字符串，可以将json字符串转换成Java。比XML更轻量级，Json使用起来比较轻便和简单。JSON数据格式，在Android中被广泛运用于客户端和服务器通信，在网络数据传输与解析时非常方便。希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看

查看详情

建立 HTTP 连接：客户端发送带有 Upgrade: websocket 标头的 HTTP GET 请求。
握手：服务器返回 101 Switching Protocols 响应，其中包含 WebSocket 密钥。
升级到 WebSocket：客户端发送带有 WebSocket 密钥的 HTTP 响应，以升级到 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中文网其它相关文章！