SpringBoot中的WebSocketSession原理詳解
介紹
在現(xiàn)代 Web 應用程序中，實時通信是一個非常常見的需求。傳統(tǒng)的 HTTP 協(xié)議是無法支持實時通信的，因為它是一種無狀態(tài)協(xié)議，每次請求都是獨立的，無法保持連接。為了解決這個問題，WebSocket 協(xié)議被引入。WebSocket 協(xié)議是一種雙向通信協(xié)議，它允許服務器和客戶端之間建立持久連接，實現(xiàn)實時通信。
Spring Boot 是一個非常流行的 Java Web 框架，它提供了對 WebSocket 的支持。Spring Boot 的 WebSocket 模塊提供了一組用于構(gòu)建 WebSocket 應用程序的 API 和工具，其中 WebSocketSession 是其中一個核心概念。
本文將介紹 WebSocketSession 的概念、原理和使用方法。
WebSocketSession 概念
WebSocketSession 是一個 WebSocket 連接的會話對象。每當客戶端與服務器建立一個 WebSocket 連接時，服務器都會創(chuàng)建一個新的 WebSocketSession 對象。WebSocketSession 對象代表了服務器和客戶端之間的一個持久連接，可以用來發(fā)送和接收消息。
WebSocketSession 接口定義了一組用于與客戶端進行通信的方法。這些方法包括：
- void sendMessage(TextMessage message)：發(fā)送文本消息。
- void sendMessage(BinaryMessage message)：發(fā)送二進制消息。
- void sendMessage(PongMessage message)：發(fā)送 Pong 消息。
- void close()：關(guān)閉 WebSocket 連接。
- boolean isOpen()：檢查 WebSocket 連接是否打開。
WebSocketSession 還提供了一些其他的方法，例如獲取會話 ID、獲取遠程地址等。
WebSocketSession 原理
在使用 WebSocketSession 之前，我們需要了解一些 WebSocket 的原理。
WebSocket 協(xié)議是一個基于 HTTP 的協(xié)議。在客戶端和服務器建立 WebSocket 連接之前，客戶端和服務器之間首先要建立一個普通的 HTTP 連接。當客戶端發(fā)送一個包含 WebSocket 握手信息的 HTTP 請求時，服務器會將其升級為 WebSocket 連接。在升級完成后，客戶端和服務器之間的通信就變成了基于 WebSocket 協(xié)議的雙向通信。
在 Spring Boot 中，使用 WebSocketSession 進行通信的過程與上述原理類似。當客戶端和服務器建立 WebSocket 連接時，服務器會創(chuàng)建一個新的 WebSocketSession 對象?？蛻舳撕头掌髦g的通信就是通過這個 WebSocketSession 對象進行的。
WebSocketSession 使用
在 Spring Boot 中使用 WebSocketSession 需要進行以下步驟：
添加依賴
首先，我們需要在項目中添加 Spring Boot 的 WebSocket 依賴。在 Maven 中，可以通過以下方式添加依賴：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>配置 WebSocket
接下來，我們需要配置 WebSocket。在 Spring Boot 中，可以通過實現(xiàn) WebSocketConfigurer 接口來配置 WebSocket。WebSocketConfigurer 接口定義了一個 configureWebSocket 方法，我們可以在這個方法中注冊 WebSocket 處理器和攔截器。
下面是一個示例 WebSocketConfigurer 的實現(xiàn)：
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(webSocketHandler(), "/websocket")
.setAllowedOrigins("*");
}
@Bean
public WebSocketHandler webSocketHandler() {
return new CustomWebSocketHandler();
}
}在上面的示例中，我們實現(xiàn)了 WebSocketConfigurer 接口，并注冊了一個 WebSocket 處理器。在 registerWebSocketHandlers 方法中，我們調(diào)用了 addHandler 方法來注冊 WebSocket 處理器，并指定了 WebSocket 的路徑。在這個示例中，WebSocket 的路徑是 “/websocket”。setAllowedOrigins 方法用于設置允許的來源，這里設置為 “*” 表示允許所有來源。
實現(xiàn) WebSocket 處理器
接下來，我們需要實現(xiàn) WebSocket 處理器。WebSocket 處理器負責處理客戶端發(fā)送的消息，并向客戶端發(fā)送響應消息。在 Spring Boot 中，可以通過實現(xiàn) WebSocketHandler 接口來實現(xiàn) WebSocket 處理器。
下面是一個示例 WebSocketHandler 的實現(xiàn)：
public class CustomWebSocketHandler implements WebSocketHandler {
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
System.out.println("WebSocket connection established: " + session.getId());
}
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
System.out.println("Received message: " + message.getPayload());
session.sendMessage(new TextMessage("Hello, " + message.getPayload() + "!"));
}
@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
System.out.println("WebSocket transport error: " + exception.getMessage());
}
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
System.out.println("WebSocket connection closed: " + closeStatus.getCode() + " - " + closeStatus.getReason());
}
@Override
public boolean supportsPartialMessages() {
return false;
}
}在上面的示例中，我們實現(xiàn)了 WebSocketHandler 接口，并重寫了其中的幾個方法。afterConnectionEstablished 方法在建立 WebSocket 連接后被調(diào)用，可以在這個方法中進行一些初始化操作。handleMessage 方法用于處理客戶端發(fā)送的消息，并向客戶端發(fā)送響應消息。handleTransportError 方法在 WebSocket 傳輸發(fā)生錯誤時被調(diào)用。
afterConnectionClosed 方法在 WebSocket 連接關(guān)閉后被調(diào)用，可以在這個方法中進行一些清理操作。supportsPartialMessages 方法用于設置是否支持部分消息傳輸。
使用 WebSocketSession
使用 WebSocketSession 進行通信非常簡單。在 WebSocket 處理器中，可以將 WebSocketSession 對象保存下來，并在需要發(fā)送消息時使用它。下面是一個示例：
public class CustomWebSocketHandler implements WebSocketHandler {
private List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
System.out.println("WebSocket connection established: " + session.getId());
sessions.add(session);
}
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
System.out.println("Received message: " + message.getPayload());
for (WebSocketSession s : sessions) {
if (s.isOpen()) {
s.sendMessage(new TextMessage("Hello, " + message.getPayload() + "!"));
}
}
}
@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
System.out.println("WebSocket transport error: " + exception.getMessage());
}
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
System.out.println("WebSocket connection closed: " + closeStatus.getCode() + " - " + closeStatus.getReason());
sessions.remove(session);
}
@Override
public boolean supportsPartialMessages() {
return false;
}
}在上面的示例中，我們將所有連接到服務器的 WebSocketSession 對象保存到一個列表中。在 handleMessage 方法中，我們遍歷這個列表，并向所有客戶端發(fā)送響應消息。
客戶端使用 WebSocketSession
在客戶端使用 WebSocketSession 也非常簡單。下面是一個示例：
var socket = new WebSocket("ws://localhost:8080/websocket");
socket.onopen = function(event) {
console.log("WebSocket connection established");
socket.send("World");
};
socket.onmessage = function(event) {
console.log("Received message: " + event.data);
};
socket.onclose = function(event) {
console.log("WebSocket connection closed: " + event.code + " - " + event.reason);
};在上面的示例中，我們創(chuàng)建了一個 WebSocket 對象，并指定了 WebSocket 的路徑。在 onopen 方法中，我們發(fā)送了一個消息。在 onmessage 方法中，我們處理服務器發(fā)送的響應消息。在 onclose 方法中，我們處理 WebSocket 連接關(guān)閉事件。
總結(jié)
WebSocketSession 是 Spring Boot 中用于與客戶端進行 WebSocket 通信的核心概念。在使用 WebSocketSession 時，我們需要先添加 Spring Boot 的 WebSocket 依賴，然后配置 WebSocket，并實現(xiàn)一個 WebSocket 處理器，最后在處理器中使用 WebSocketSession 進行通信?？蛻舳艘部梢允褂?WebSocketSession 進行通信，非常簡單。
總的來說，WebSocketSession 是實現(xiàn) WebSocket 通信的關(guān)鍵。它提供了一組用于與客戶端進行通信的方法，可以用來發(fā)送和接收消息。在 Spring Boot 中，使用 WebSocketSession 進行通信非常方便，只需要實現(xiàn)一個 WebSocket 處理器，并使用 WebSocketSession 進行通信即可。
代碼示例：
WebSocket 處理器
public class CustomWebSocketHandler implements WebSocketHandler {
private List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
System.out.println("WebSocket connection established: " + session.getId());
sessions.add(session);
}
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
System.out.println("Received message: " + message.getPayload());
for (WebSocketSession s : sessions) {
if (s.isOpen()) {
s.sendMessage(new TextMessage("Hello, " + message.getPayload() + "!"));
}
}
}
@Override
public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
System.out.println("WebSocket transport error: " + exception.getMessage());
}
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
System.out.println("WebSocket connection closed: " + closeStatus.getCode() + " - " + closeStatus.getReason());
sessions.remove(session);
}
@Override
public boolean supportsPartialMessages() {
return false;
}
}WebSocket 配置器
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(webSocketHandler(), "/websocket")
.setAllowedOrigins("*");
}
@Bean
public WebSocketHandler webSocketHandler() {
return new CustomWebSocketHandler();
}
}客戶端代碼
var socket = new WebSocket("ws://localhost:8080/websocket");
socket.onopen = function(event) {
console.log("WebSocket connection established");
socket.send("World");
};
socket.onmessage = function(event) {
console.log("Received message: " + event.data);
};
socket.onclose = function(event) {
console.log("WebSocket connection closed: " + event.code + " - " + event.reason);
};到此這篇關(guān)于SpringBoot中的WebSocketSession原理詳解的文章就介紹到這了,更多相關(guān)SpringBoot中的WebSocketSession內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了Java設計模式之命令模式詳細解析,命令模式將請求封裝成對象,以便使用不同的請求、隊列或者日志來參數(shù)化其他對象,同時也支持可撤銷的操作,需要的朋友可以參考下2024-01-01
idea使用easyCode生成代碼(根據(jù)mybatis-plus模板創(chuàng)建自己的模板)
本文主要介紹了idea使用easyCode生成代碼,easyCode代碼生成器可以減少低價值搬磚,具有一定的參考價值,感興趣的可以了解一下2023-10-10
這篇文章主要介紹了Java中的不可變對象的相關(guān)知識，文中代碼非常詳細，幫助大家更好的理解和學習，感興趣的朋友可以參考下2020-06-06
這篇文章主要介紹了JavaWeb實現(xiàn)用戶登錄與注冊功能，服務器部分的關(guān)鍵代碼實現(xiàn)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-08-08
大家好，本篇文章主要講的是java判斷各類型字符個數(shù)實例代碼，感興趣的同學趕快來看一看吧，對你有幫助的話記得收藏一下，方便下次瀏覽2021-12-12
使用PageHelper插件實現(xiàn)Service層分頁
這篇文章主要為大家詳細介紹了使用PageHelper插件實現(xiàn)Service層分頁，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-04-04
這篇文章主要介紹了java8中forkjoin和optional框架使用心得以及用法講解，需要的朋友參考下吧。2017-12-12
Java中&&與?表達式結(jié)合時出現(xiàn)的坑
這篇文章主要給大家介紹了關(guān)于Java中&&與?表達式結(jié)合時出現(xiàn)的坑的相關(guān)資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-02-02
本文主要介紹了vue2向springboot傳值接收不到的解決方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-07-07
Java Socket實現(xiàn)聊天室附1500行源代碼
Socket是應用層與TCP/IP協(xié)議族通信的中間軟件抽象層，它是一組接口。本篇文章手把手帶你通過Java Socket來實現(xiàn)自己的聊天室,大家可以在過程中查缺補漏，溫故而知新2021-10-10