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