有哪些网站免费做推广,做网站哪间好,网站免费空间哪里申请,设计工作网站好WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议#xff0c;广泛应用于需要实时数据交换的应用程序中。它能够实现服务器与客户端之间的双向通信#xff0c;避免了传统 HTTP 请求/响应的延迟。结合 Spring Boot#xff0c;开发实时通信应用变得更加高效与简便。 1. …WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议广泛应用于需要实时数据交换的应用程序中。它能够实现服务器与客户端之间的双向通信避免了传统 HTTP 请求/响应的延迟。结合 Spring Boot开发实时通信应用变得更加高效与简便。 1. WebSocket的基本概念与应用
1.1 什么是WebSocket
WebSocket 是一种协议它允许客户端和服务器之间通过持久的连接进行实时双向通信。在传统的 HTTP 协议中客户端发起请求服务器响应请求这种通信方式是单向的且每次请求都需要重新建立连接。而 WebSocket 通过在客户端和服务器之间建立一个长连接实现了数据的双向实时传输极大地提高了应用的实时性和响应能力。
全双工通信WebSocket 允许客户端和服务器同时发送数据这与传统的请求-响应模型不同。低延迟由于建立了持久连接数据传输的延迟非常低适合实时应用。节省带宽WebSocket 可以避免每次请求都建立连接减少了请求头和握手的开销。
1.2 WebSocket的应用场景
WebSocket 的实时通信特性使得它非常适合以下应用场景
实时聊天应用如在线客服、即时通讯。在线游戏多人在线互动游戏。股票和金融应用实时股票价格和市场数据更新。协作应用如多人协作编辑器、在线文档协作。实时通知系统推送通知和事件广播。 2. 使用Spring Boot实现WebSocket
2.1 引入Spring Boot WebSocket依赖
Spring Boot 提供了对 WebSocket 协议的原生支持使用 spring-boot-starter-websocket 依赖即可实现 WebSocket 功能。在 pom.xml 中加入如下依赖
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId
/dependency
2.2 配置WebSocket
Spring Boot 支持使用 Configuration 注解的配置类来配置 WebSocket。通过实现 WebSocketConfigurer 接口并重写 registerWebSocketHandlers 方法可以自定义 WebSocket 的配置。
例如
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;Configuration
EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(new ChatWebSocketHandler(), /chat).setAllowedOrigins(*); // 允许所有来源的跨域请求}
}
在此配置类中addHandler 方法指定了 WebSocket 请求路径 /chat并且配置了处理 WebSocket 消息的 ChatWebSocketHandler 类。
2.3 编写WebSocket处理器
WebSocketHandler 是处理 WebSocket 消息的核心类。在 Spring Boot 中我们可以自定义一个 WebSocketHandler 来处理连接、消息、关闭等事件。
例如ChatWebSocketHandler 可以实现以下功能
处理连接建立客户端连接成功时调用。处理消息传递接收到客户端消息时调用。处理连接关闭客户端断开连接时调用。
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketMessage;public class ChatWebSocketHandler extends TextWebSocketHandler {Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {System.out.println(New WebSocket connection established: session.getId());session.sendMessage(new TextMessage(Welcome to the chat room!));}Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {String payload message.getPayload();System.out.println(Received message: payload);// Echo the message back to the clientsession.sendMessage(new TextMessage(Echo: payload));}Overridepublic void afterConnectionClosed(WebSocketSession session, org.springframework.web.socket.CloseStatus status) throws Exception {System.out.println(Connection closed: session.getId());}
}
在这个 ChatWebSocketHandler 类中afterConnectionEstablished 用来在客户端连接后发送一条欢迎消息handleTextMessage 用来处理客户端发送的消息并回传相同的消息。
2.4 前端WebSocket客户端
在前端页面中我们可以通过 JavaScript 的 WebSocket API 来连接 WebSocket 服务并发送接收消息。例如
!DOCTYPE html
html langen
headmeta charsetUTF-8titleWebSocket Chat/title
/head
bodyh1WebSocket Chat/h1textarea idchat cols30 rows10 readonly/textareabr/input typetext idmessage placeholderEnter message/button onclicksendMessage()Send/buttonscriptvar socket new WebSocket(ws://localhost:8080/chat);socket.onopen function () {console.log(Connected to WebSocket server.);};socket.onmessage function (event) {document.getElementById(chat).value Server: event.data \n;};function sendMessage() {var message document.getElementById(message).value;socket.send(message);document.getElementById(chat).value You: message \n;document.getElementById(message).value ;}/script
/body
/html
在此 HTML 页面中使用 WebSocket API 建立连接点击发送按钮时将文本框内容发送到服务器服务器会回传相同的消息并在页面上显示。 3. 开发实时聊天应用示例
3.1 项目需求
我们的目标是构建一个实时聊天应用用户可以通过 WebSocket 与其他用户进行即时对话。该应用包括以下功能
用户连接到聊天服务器。用户输入消息并发送。服务器实时回传消息。聊天记录在页面上展示。
3.2 后端实现
我们已经在前面的部分中实现了 ChatWebSocketHandler 和 WebSocket 配置。接下来我们可以为聊天应用提供更多的功能如支持多个用户之间的消息转发。
修改 ChatWebSocketHandler 以支持广播消息
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketMessage;import java.util.HashSet;
import java.util.Set;public class ChatWebSocketHandler extends TextWebSocketHandler {private static final SetWebSocketSession sessions new HashSet();Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {sessions.add(session);session.sendMessage(new TextMessage(Welcome to the chat room!));}Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {String payload message.getPayload();for (WebSocketSession s : sessions) {s.sendMessage(new TextMessage(payload));}}Overridepublic void afterConnectionClosed(WebSocketSession session, org.springframework.web.socket.CloseStatus status) throws Exception {sessions.remove(session);}
}
这里我们使用一个 Set 来存储所有连接的 WebSocket 客户端每次收到消息时都将消息广播给所有连接的客户端。
3.3 前端实现
前端界面与之前类似但我们改进了显示聊天记录和输入框的样式。每当一个用户发送消息时其他所有连接的用户都会看到相同的消息。
textarea idchat cols30 rows10 readonly/textareabr/
input typetext idmessage placeholderEnter message/
button onclicksendMessage()Send/button 总结
WebSocket 是一种非常适合实时通信的协议特别是在构建即时通讯、在线协作、实时数据更新等应用时。在 Spring Boot 中实现 WebSocket 非常简单我们只需要添加相关依赖配置 WebSocket 处理器然后在前端使用 WebSocket API 进行连接和消息传递。通过这个简单的示例我们可以构建一个实时聊天应用展示 WebSocket 在实时通信中的强大能力。 关于作者
15年互联网开发、带过10-20人的团队多次帮助公司从0到1完成项目开发在TX等大厂都工作过。当下为退役状态写此篇文章属个人爱好。本人开发期间收集了很多开发课程等资料需要可联系我
