SpringBoot實(shí)現(xiàn)WebSocket通信過程解讀
更新時(shí)間：2025年08月17日 17:01:57 作者：沒事學(xué)AI
文章講解了WebSocket在SpringBoot中的集成,涵蓋技術(shù)原理、實(shí)戰(zhàn)步驟、性能優(yōu)化及安全措施,提供環(huán)境搭建、消息處理、STOMP支持等關(guān)鍵實(shí)現(xiàn),結(jié)合業(yè)務(wù)場(chǎng)景構(gòu)建高效實(shí)時(shí)通信系統(tǒng)
在現(xiàn)代Web應(yīng)用中，實(shí)時(shí)通信已成為不可或缺的功能模塊，從在線聊天到實(shí)時(shí)數(shù)據(jù)監(jiān)控，都離不開高效的雙向通信機(jī)制。
傳統(tǒng)的HTTP協(xié)議基于請(qǐng)求-響應(yīng)模式，無法滿足實(shí)時(shí)性要求，而WebSocket技術(shù)的出現(xiàn)徹底解決了這一痛點(diǎn)。
本文將從技術(shù)原理到實(shí)戰(zhàn)落地，全面解析如何在Spring Boot環(huán)境中構(gòu)建穩(wěn)定、高效的WebSocket通信系統(tǒng)。
一、WebSocket核心技術(shù)原理
1.1 從HTTP到WebSocket的演進(jìn)邏輯
HTTP協(xié)議作為Web通信的基礎(chǔ)，其"無狀態(tài)"和"單向請(qǐng)求"特性在實(shí)時(shí)場(chǎng)景下存在明顯短板。為了實(shí)現(xiàn)服務(wù)器主動(dòng)推送數(shù)據(jù)，早期開發(fā)者采用了輪詢、長輪詢等折衷方案，但這些方式不僅增加了 服務(wù)器負(fù)載，還存在顯著的延遲問題。
WebSocket協(xié)議（RFC 6455）通過一次HTTP握手建立持久連接，實(shí)現(xiàn)了客戶端與服務(wù)器之間的全雙工通信。其核心優(yōu)勢(shì)體現(xiàn)在：
- 持久連接：一次握手后保持連接狀態(tài)，避免頻繁建立連接的開銷
- 雙向平等：客戶端和服務(wù)器可隨時(shí)主動(dòng)發(fā)送數(shù)據(jù)
- 輕量協(xié)議：數(shù)據(jù)幀頭部開銷小，比HTTP更高效
- 跨域支持：原生支持跨域通信，無需復(fù)雜配置
1.2 WebSocket通信的底層機(jī)制
WebSocket的通信過程可分為三個(gè)階段：
1.握手階段：客戶端通過HTTP請(qǐng)求發(fā)起握手，請(qǐng)求頭包含Upgrade: websocket和Connection: Upgrade等關(guān)鍵信息，服務(wù)器返回101狀態(tài)碼表示協(xié)議切換成功。
2.數(shù)據(jù)傳輸階段：采用幀（Frame）結(jié)構(gòu)傳輸數(shù)據(jù)，每個(gè)幀包含 opcode（操作碼）、 payload length（數(shù)據(jù)長度）和payload data（實(shí)際數(shù)據(jù)）。常見 opcode包括：
- 0x00：繼續(xù)幀
- 0x01：文本幀
- 0x02：二進(jìn)制幀
- 0x08：關(guān)閉幀
3.連接關(guān)閉階段：任何一方發(fā)送關(guān)閉幀，另一方確認(rèn)后關(guān)閉連接，確保資源正確釋放。
Spring Boot通過封裝WebSocket API，屏蔽了底層幀處理的復(fù)雜性，讓開發(fā)者能夠?qū)Ｗ⒂跇I(yè)務(wù)邏輯實(shí)現(xiàn)。
二、Spring Boot集成WebSocket實(shí)戰(zhàn)
2.1 環(huán)境搭建與依賴配置
首先在pom.xml中添加WebSocket核心依賴：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<!-- 可選：添加STOMP支持 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
創(chuàng)建WebSocket配置類，注冊(cè)核心組件：
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
// 注冊(cè)處理器，允許跨域訪問
registry.addHandler(new ChatWebSocketHandler(), "/ws/chat")
.setAllowedOrigins("*");
// 可選：添加SockJS支持，兼容不支持WebSocket的瀏覽器
registry.addHandler(new ChatWebSocketHandler(), "/sockjs/chat")
.setAllowedOrigins("*")
.withSockJS();
}
}
2.2 實(shí)現(xiàn)基礎(chǔ)消息處理器
創(chuàng)建自定義WebSocketHandler處理消息交互：
public class ChatWebSocketHandler extends TextWebSocketHandler {
// 存儲(chǔ)連接的會(huì)話
private final Set<WebSocketSession> sessions = ConcurrentHashMap.newKeySet();
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
// 新連接建立時(shí)加入會(huì)話集合
sessions.add(session);
session.sendMessage(new TextMessage("連接成功，歡迎加入聊天室！"));
}
@Override
protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
String payload = message.getPayload();
// 解析消息內(nèi)容
ChatMessage chatMessage = new ObjectMapper().readValue(payload, ChatMessage.class);
// 廣播消息給所有在線用戶
for (WebSocketSession s : sessions) {
if (s.isOpen()) {
s.sendMessage(new TextMessage(
new ObjectMapper().writeValueAsString(
new ChatMessage(chatMessage.getSender(), chatMessage.getContent(), LocalDateTime.now())
)
));
}
}
}
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
// 連接關(guān)閉時(shí)移除會(huì)話
sessions.remove(session);
}
}
定義消息實(shí)體類：
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ChatMessage {
private String sender;
private String content;
private LocalDateTime timestamp;
}
2.3 客戶端實(shí)現(xiàn)與測(cè)試
創(chuàng)建簡(jiǎn)單的HTML客戶端進(jìn)行測(cè)試：
<!DOCTYPE html>
<html>
<head>
<title>WebSocket聊天室</title>
<script src="https://cdn.jsdelivr.net/npm/sockjs-client@1/dist/sockjs.min.js"></script>
</head>
<body>
<input type="text" id="sender" placeholder="請(qǐng)輸入用戶名">
<input type="text" id="content" placeholder="請(qǐng)輸入消息">
<button onclick="sendMessage()">發(fā)送</button>
<div id="messageContainer"></div>
<script>
// 連接WebSocket服務(wù)器
const socket = new WebSocket('ws://localhost:8080/ws/chat');
// 或使用SockJS兼容模式
// const socket = new SockJS('/sockjs/chat');
// 接收消息處理
socket.onmessage = function(event) {
const message = JSON.parse(event.data);
const container = document.getElementById('messageContainer');
container.innerHTML += `<div>${message.timestamp} ${message.sender}: ${message.content}</div>`;
};
// 發(fā)送消息
function sendMessage() {
const sender = document.getElementById('sender').value;
const content = document.getElementById('content').value;
socket.send(JSON.stringify({ sender, content }));
}
</script>
</body>
</html>
2.4 高級(jí)特性：STOMP協(xié)議支持
對(duì)于復(fù)雜場(chǎng)景，推薦使用STOMP（Simple Text Oriented Messaging Protocol）協(xié)議，它在WebSocket之上提供了更豐富的消息語義：
- 添加STOMP配置：
@Configuration
@EnableWebSocketMessageBroker
public class StompWebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
// 配置消息代理，用于廣播消息
config.enableSimpleBroker("/topic");
// 配置應(yīng)用前綴，客戶端發(fā)送消息的目標(biāo)前綴
config.setApplicationDestinationPrefixes("/app");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/stomp/chat")
.setAllowedOrigins("*")
.withSockJS();
}
}
- 創(chuàng)建STOMP消息控制器：
@Controller
public class StompChatController {
// 處理點(diǎn)對(duì)點(diǎn)消息
@MessageMapping("/chat/private")
@SendToUser("/queue/messages")
public ChatMessage handlePrivateMessage(ChatMessage message,
@Header("simpUser") Principal user) {
return new ChatMessage(user.getName(), message.getContent(), LocalDateTime.now());
}
// 處理廣播消息
@MessageMapping("/chat/public")
@SendTo("/topic/public")
public ChatMessage handlePublicMessage(ChatMessage message) {
return new ChatMessage(message.getSender(), message.getContent(), LocalDateTime.now());
}
}
- STOMP客戶端實(shí)現(xiàn)：
// 連接STOMP服務(wù)器
const socket = new SockJS('/stomp/chat');
const stompClient = Stomp.over(socket);
stompClient.connect({}, function(frame) {
console.log('連接成功: ' + frame);
// 訂閱廣播消息
stompClient.subscribe('/topic/public', function(message) {
showMessage(JSON.parse(message.body));
});
// 訂閱個(gè)人消息
stompClient.subscribe('/user/queue/messages', function(message) {
showMessage(JSON.parse(message.body));
});
});
// 發(fā)送廣播消息
function sendPublicMessage() {
const sender = document.getElementById('sender').value;
const content = document.getElementById('content').value;
stompClient.send("/app/chat/public", {}, JSON.stringify({ sender, content }));
}
三、性能優(yōu)化與生產(chǎn)環(huán)境配置
3.1 連接管理與資源控制
在高并發(fā)場(chǎng)景下，需要對(duì)WebSocket連接進(jìn)行精細(xì)化管理：
- 設(shè)置連接超時(shí)時(shí)間：通過
SockJSProperties配置連接超時(shí) - 限制并發(fā)連接數(shù)：自定義
HandshakeInterceptor控制連接數(shù)量 - 實(shí)現(xiàn)連接心跳檢測(cè)：配置STOMP心跳機(jī)制保持連接活躍
@Bean
public WebMvcConfigurer webMvcConfigurer() {
return new WebMvcConfigurer() {
@Override
public void addInterceptors(InterceptorRegistry registry) {
registry.addInterceptor(new HandshakeInterceptor() {
@Override
public boolean beforeHandshake(ServerHttpRequest request,
ServerHttpResponse response,
WebSocketHandler wsHandler,
Map<String, Object> attributes) throws Exception {
// 限制最大連接數(shù)
if (connectionCounter.get() > 1000) {
response.setStatusCode(HttpStatus.TOO_MANY_REQUESTS);
return false;
}
return true;
}
// 其他方法實(shí)現(xiàn)...
});
}
};
}
3.2 集群環(huán)境下的WebSocket部署
單節(jié)點(diǎn)部署無法滿足高可用需求，集群環(huán)境需解決以下問題：
- 會(huì)話共享：使用Redis等存儲(chǔ)會(huì)話信息
- 消息廣播：通過消息隊(duì)列（如RabbitMQ、Kafka）實(shí)現(xiàn)跨節(jié)點(diǎn)消息同步
- 負(fù)載均衡：配置Nginx支持WebSocket代理
Nginx配置示例：
location /ws/ {
proxy_pass http://backend_servers;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
proxy_set_header Host $host;
}
四、常見問題與最佳實(shí)踐
4.1 調(diào)試與排錯(cuò)技巧
- 使用瀏覽器開發(fā)者工具的Network面板監(jiān)控WebSocket幀
- 開啟Spring WebSocket日志：
logging.level.org.springframework.web.socket=DEBUG - 實(shí)現(xiàn)
WebSocketHandlerDecorator記錄消息交互日志
4.2 安全加固措施
- 對(duì)WebSocket握手進(jìn)行認(rèn)證授權(quán)（通過
HandshakeInterceptor） - 使用wss://協(xié)議加密傳輸
- 限制消息大小防止DoS攻擊：
registry.setMaxTextMessageBufferSize(8192)
4.3 性能優(yōu)化建議
- 對(duì)于高頻消息采用二進(jìn)制幀傳輸
- 實(shí)現(xiàn)消息批處理減少IO操作
- 根據(jù)業(yè)務(wù)場(chǎng)景合理選擇通信模式（廣播/點(diǎn)對(duì)點(diǎn)）
通過本文的講解，相信讀者已經(jīng)掌握了Spring Boot集成WebSocket的核心技術(shù)和實(shí)戰(zhàn)技巧。WebSocket作為實(shí)時(shí)通信的基礎(chǔ)設(shè)施，在實(shí)際項(xiàng)目中還需要結(jié)合具體業(yè)務(wù)場(chǎng)景進(jìn)行靈活設(shè)計(jì)，建議在開發(fā)過程中充分利用Spring生態(tài)的優(yōu)勢(shì)，構(gòu)建可靠、高效的實(shí)時(shí)通信系統(tǒng)。
總結(jié)
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
您可能感興趣的文章:
- SpringBoot分布式WebSocket的實(shí)現(xiàn)指南
- 深入淺出SpringBoot WebSocket構(gòu)建實(shí)時(shí)應(yīng)用全面指南
- 利用SpringBoot與WebSocket實(shí)現(xiàn)實(shí)時(shí)雙向通信功能
- Springboot整合WebSocket 實(shí)現(xiàn)聊天室功能
- vue+springboot+webtrc+websocket實(shí)現(xiàn)雙人音視頻通話會(huì)議(最新推薦)
- Springboot使用Websocket的時(shí)候調(diào)取IOC管理的Bean報(bào)空指針異常問題
- Java?springBoot初步使用websocket的代碼示例
- SpringBoot3整合WebSocket詳細(xì)指南
- SpringBoot實(shí)現(xiàn)WebSocket的示例代碼
- Spring Boot集成WebSocket項(xiàng)目實(shí)戰(zhàn)的示例代碼
相關(guān)文章
利用SpringBoot和LiteFlow解鎖復(fù)雜流程
隨著業(yè)務(wù)的復(fù)雜化，企業(yè)需要更加高效、便捷地管理自己的業(yè)務(wù)流程，這就需要借助一些流程引擎實(shí)現(xiàn)，今天，我們就來介紹一種基于Java語言開發(fā)的輕量級(jí)工作流引擎——LiteFlow，以及如何在Spring Boot框架中集成它，從而提高企業(yè)的工作效率和開發(fā)效率2023-06-06
Mybatis統(tǒng)計(jì)sql運(yùn)行時(shí)間的兩種方式
這篇文章主要介紹了Mybatis統(tǒng)計(jì)sql運(yùn)行時(shí)間的方案,Spring?Boot?+?Mybatis?web項(xiàng)目,統(tǒng)計(jì)sql運(yùn)行時(shí)間,用于分析慢sql,優(yōu)化系統(tǒng)速度,方案有兩種：自定義實(shí)現(xiàn)?Interceptor和使用現(xiàn)有依賴庫（Druid）,文中通過代碼示例講解的非常詳細(xì),需要的朋友可以參考下2024-11-11
springboot整合logback實(shí)現(xiàn)日志管理操作
本章節(jié)是記錄logback在springboot項(xiàng)目中的簡(jiǎn)單使用,本文將會(huì)演示如何通過logback將日志記錄到日志文件或輸出到控制臺(tái)等管理操作,感興趣的朋友跟隨小編一起看看吧2024-02-02
Spring boot2基于Mybatis實(shí)現(xiàn)多表關(guān)聯(lián)查詢
這篇文章主要介紹了Spring boot2基于Mybatis實(shí)現(xiàn)多表關(guān)聯(lián)查詢,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-04-04
Spring?WebClient實(shí)戰(zhàn)示例
本文主要介紹了Spring?WebClient實(shí)戰(zhàn)示例，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-01-01
本文主要介紹了Springboot中的@Order如何使用，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-02-02
單例模式（Singleton Pattern）是 Java 中最簡(jiǎn)單的設(shè)計(jì)模式之一。這種類型的設(shè)計(jì)模式屬于創(chuàng)建型模式，它提供了一種創(chuàng)建對(duì)象的最佳方式，這種模式涉及到一個(gè)單一的類，該類負(fù)責(zé)創(chuàng)建自己的對(duì)象，同時(shí)確保只有單個(gè)對(duì)象被創(chuàng)建2021-11-11
Springboot處理配置CORS跨域請(qǐng)求時(shí)碰到的坑
本篇文章介紹了我在開發(fā)過程中遇到的一個(gè)問題，以及解決該問題的過程及思路，通讀本篇對(duì)大家的學(xué)習(xí)或工作具有一定的價(jià)值，需要的朋友可以參考下2021-09-09
SpringAOP實(shí)現(xiàn)自定義接口權(quán)限控制
本文主要介紹了SpringAOP實(shí)現(xiàn)自定義接口權(quán)限控制，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-11-11
springBoot集成mybatis 轉(zhuǎn)換為 mybatis-plus方式
這篇文章主要介紹了springBoot集成mybatis 轉(zhuǎn)換為 mybatis-plus方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-12-12