SpringBoot+WebSocket實現(xiàn)即時通訊的方法詳解
環(huán)境信息
| 名稱 | 版本號 |
|---|---|
| Spring Boot | 2.4.5 |
| Idea | 2021.3.2 |
服務端實現(xiàn)
導入依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
注意：Spring Boot在父工程中已經(jīng)管理了websocket的版本信息，所以不用指定版本號也是可以的
創(chuàng)建配置類
package com.fenzhichuanmei.configuration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
/**
* @author Yi Dai 484201132@qq.com
* @since 2022/5/13 11:34
*/
@Configuration
public class WebsocketConfiguration {
@Bean
public ServerEndpointExporter serverEndpointExporter() {
return new ServerEndpointExporter();
}
}
創(chuàng)建此配置類的目的只是為了把ServerEndpointExporter 這個類的實例交給spring 容器進行管理，您可以用任意一種方式交給容器，如使用@Import(ServerEndpointExporter.class)這種方式等進行操作；此處只是我的編碼風格如此；并非必須這樣操作
創(chuàng)建一個注解式的端點并在其中通過配套注解聲明回調方法
package com.fenzhichuanmei.websocket;
import com.fenzhichuanmei.websocket.utils.SessionManager;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
/**
* @author Yi Dai 484201132@qq.com
* @since 2022/3/7 15:47
*/
@Slf4j
@Component
@ServerEndpoint("/arcticFoxServerEndpoint/{websocketClientType}")
public class ArcticFoxServerEndpoint {
private static SessionManager sessionManager;
@Resource
public void setProcessor(SessionManager sessionManager) {
ArcticFoxServerEndpoint.sessionManager = sessionManager;
}
/**
* 建立連接成功的回調方法
*
* @param session 會話對象
* @param websocketClientType 此參數(shù)就是路徑中{websocketClientType}位置傳入的參數(shù)
*/
@OnOpen
public void onOpen(Session session, @PathParam("websocketClientType") int websocketClientType) {
sessionManager.onOpen(session, websocketClientType);
}
/**
* 當會話關閉時執(zhí)行的回調方法
*
* @param session 會話對象
* @param websocketClientType 此參數(shù)就是路徑中{websocketClientType}位置傳入的參數(shù)
*/
@OnClose
public void onClose(Session session, @PathParam("websocketClientType") int websocketClientType) {
sessionManager.onClose(session, websocketClientType);
}
/**
* 當收到客戶端信息時執(zhí)行的回調方法
*
* @param session 會話對象
* @param message 客戶端傳遞過來的信息
* @param websocketClientType 此參數(shù)就是路徑中{websocketClientType}位置傳入的參數(shù)
*/
@OnMessage
public void onMessage(Session session, String message, @PathParam("websocketClientType") int websocketClientType) {
sessionManager.onMessage(session, message, websocketClientType);
}
/**
* 當發(fā)生錯誤時的回調方法
*
* @param session 會話對象
* @param e 異常對象
* @param websocketClientType 此參數(shù)就是路徑中{websocketClientType}位置傳入的參數(shù)
*/
@OnError
public void onError(Session session, Throwable e, @PathParam("websocketClientType") int websocketClientType) {
sessionManager.onError(session, e, websocketClientType);
}
}
@ServerEndpoint注解標注此類為一個服務端的端點類，此注解有一個必須的參數(shù)，用于指定客戶端訪問的地址，本案例中為：/arcticFoxServerEndpoint，而路徑后面的/{websocketClientType}這個是路徑中參數(shù)的占位符，有點類似與Spring Mvc中Rest接口和@PathVariable注解的作用
注意事項： 一定要將此類交給spring 容器進行管理??！還有一個坑就是，此類的實例時非單例的，所以如果要在此類中注入其他的bean，不能使直接在屬性上使用@Resource注解或者@Autowired等注解進行注入，否則會報錯。正確操作應該是把要注入的字段設置為靜態(tài)的，然后通過非靜態(tài)的set方法進行注入，具體代碼請看上方實例
服務端主動發(fā)送消息給客戶端
通過上面的代碼我們可以知道每個回調方法中都會收到一個Session對象，正如您所想，要向客戶端發(fā)送消息正是要借助此對象；Session對象有一個getAsyncRemote方法，調用此方法可以得到一個RemoteEndpoint.Async對象，查看此對象，發(fā)現(xiàn)有很多send打頭的方法；
是的，這些方法就是發(fā)送消息的方法，博主這個項目中主要是通過JSON來進行交互的，所以我使用了sendText方法，示例代碼：
RemoteEndpoint.Async asyncRemote = session.getAsyncRemote(); asyncRemote.sendText(jsonString);
很顯然中轉變量asyncRemote 沒什么太大的用處，不如直接寫成：
session.getAsyncRemote().sendText(jsonString);
通過方法名看到，似乎還可以發(fā)送對象，二進制序列等，博主沒有深入研究，有興趣的小伙伴可以嘗試嘗試
客戶端實現(xiàn)
一般來講客戶端應該是用Java Script實現(xiàn)，但是博主這個項目比較特殊，需要用Java來實現(xiàn)客戶端，下面博主先以Java客戶端說明其實現(xiàn)細節(jié)，然后再說再前端如何實現(xiàn)
Java客戶端實現(xiàn)
導入依賴
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.5.3</version>
</dependency>
其實Java中實現(xiàn)WebSocket的第三方包還有很多，博主這個地方使用的是Java-WebSocket，有興趣的小伙伴可以試試其他的包
建立連接和處理回調
package com.fenzhichuanmei.websocket;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fenzhichuanmei.components.PaymentComponent;
import com.fenzhichuanmei.pojo.Instructions;
import com.fenzhichuanmei.utils.WebsocketClientType;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.enums.ReadyState;
import org.java_websocket.handshake.ServerHandshake;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.net.URI;
import java.net.URISyntaxException;
/**
* @author Yi Dai 484201132@qq.com
* @since 2022/5/13 10:16
*/
@Slf4j
@Component
public class ArcticFoxWebSocketClient {
@Resource
private ObjectMapper objectMapper;
@Resource
private PaymentComponent paymentComponent;
@Resource
private ArcticFoxWebSocketClientProperties properties;
public void establishConnection() throws URISyntaxException {
WebSocketClient webSocketClient = new WebSocketClient(new URI(String.format("%s/%d", properties.getWebSocketServerUrl(), WebsocketClientType.PAYMENT_DEVICE))) {
@Override
public void onOpen(ServerHandshake serverHandshake) {
log.info("WebSocketClient: onOpen : {}", serverHandshake);
}
@Override
public void onMessage(String jsonString) {
try {
Instructions instructions = objectMapper.readValue(jsonString, Instructions.class);
if (instructions.getType() == Instructions.NOTICE_PAYMENT) {
paymentComponent.queryAnUnpaidOrdersAndPay();
} else {
throw new RuntimeException("錯誤的指令類型");
}
} catch (JsonProcessingException e) {
e.printStackTrace();
}
}
@Override
public void onClose(int i, String s, boolean b) {
log.info("WebSocketClient: onClose : i:{},s:{},b:{}", i, s, b);
try {
Thread.sleep(1000 * 20);
establishConnection();
} catch (InterruptedException | URISyntaxException e) {
e.printStackTrace();
}
}
@Override
public void onError(Exception e) {
log.error("WebSocketClient: onError {}", e.getMessage());
}
};
webSocketClient.connect();
while (!(webSocketClient.getReadyState() == ReadyState.OPEN)) {
try {
Thread.sleep(1000 * 2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
log.info("WebSocketClient: connection established successfully");
}
@Data
@Component
@ConfigurationProperties("arctic-fox-web-socket-client.properties")
public static class ArcticFoxWebSocketClientProperties {
private String webSocketServerUrl;
}
}代碼解釋： 其實我的establishConnection方法中上來就實例化了一個WebSocketClient 類的實例，請注意，此類是個抽象類，我在這里用匿名實現(xiàn)類的方式實現(xiàn)的，此類有幾個抽象方法需要實現(xiàn)，也就是onOpen,onMessage,onClose,onError四個方法，其作用其實已經(jīng)是很見名知意了，和服務端的回調方法一樣，就不過多解釋；實例化此類需要傳入一個URI對象，這個URI對象其實就是封裝了對服務端連接的地址，由于博主不希望把服務端的地址給寫死了，所以我配置到了配置文件中，然后通過String.format靜態(tài)方法配合占位符拼接url地址和參數(shù)；路徑的規(guī)則是：協(xié)議名://IP地址(或域名):端口號/服務端聲明的地址/參數(shù)；舉個例子：
ws://192.168.88.88:8080/arcticFoxServerEndpoint/1
ws://localhost:8080/arcticFoxServerEndpoint/2
ws://為協(xié)議;實例化WebSocketClient 類的實例之后，調用其connect()方法即開始建立連接，調用getReadyState()方法可以獲得其狀態(tài)；由于我的服務端可能隨時都連不上，所以我在客戶端的onClose回調函數(shù)中進行了一個遞歸（20秒后），用于重新連接。
客戶端向服務端發(fā)送消息
通過WebSocketClient 類的實例，我們可以看到有以下方法，很明顯send方法就是用來發(fā)送消息使用的
示例代碼：
//判斷一下是否為空
if (Objects.nonNull(webSocketClient)) {
try {
//通過jackson將對象轉換為json字符串（非必須）
String jsonString = objectMapper.writeValueAsString(feedback);
//發(fā)送信息
webSocketClient.send(jsonString);
} catch (JsonProcessingException e) {
e.printStackTrace();
}
} else {
log.warn("no connection established");
}
在前端環(huán)境（vue）中使用websocket
安裝reconnecting-websocket包(非必須)
npm i --save reconnecting-websocket
安裝這個包是為了websocket能在斷線之后重新連接，其實不使用這個包也是可以用原生Java Script實現(xiàn)的；但是他和原生的api幾乎一樣；
示例代碼：
import ReconnectingWebSocket from "reconnecting-websocket";
export default function initializationWebsocket() {
let reconnectingWebSocket = new ReconnectingWebSocket(`ws://localhost:8080/arcticFoxServerEndpoint/${2}`);
reconnectingWebSocket.onopen = event => {
console.log("on open :", event);
};
reconnectingWebSocket.onmessage = event => {
//event對象中data存儲的就是服務端發(fā)送過來的消息
let parse = JSON.parse(event.data);
console.log("webSocket on message :", parse);
};
reconnectingWebSocket.onclose = event => {
console.log(event);
};
reconnectingWebSocket.onerror = event => {
console.log(event);
};
//窗口關閉時斷開連接
window.onbeforeunload = function () {
reconnectingWebSocket.close();
}
}
在前端中實現(xiàn)websocket就比較簡單了，就上面的幾行代碼即可，不用調用其他函數(shù)進行連接，實例化之后就開始連接了
想服務端發(fā)送信息
在前端中發(fā)送信息就更簡單了，直接調用reconnectingWebSocket的send方法，傳入要發(fā)送的數(shù)據(jù)即可
到此這篇關于SpringBoot+WebSocket實現(xiàn)即時通訊的方法詳解的文章就介紹到這了,更多相關SpringBoot WebSocket即時通訊內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
基于java SSM springboot實現(xiàn)抗疫物質信息管理系統(tǒng)
這篇文章主要介紹了基于JAVA SSM springboot實現(xiàn)的抗疫物質信息管理系統(tǒng)，本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-08-08
這篇文章主要介紹了SpringBoot應用快速部署到K8S的詳細教程,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-12-12
Springboot+MybatisPlus實現(xiàn)帶驗證碼的登錄
本文主要介紹了Springboot+MybatisPlus實現(xiàn)帶驗證碼的登錄,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2024-05-05
SpringBoot用多線程批量導入數(shù)據(jù)庫實現(xiàn)方法
這篇文章主要介紹了SpringBoot用多線程批量導入數(shù)據(jù)庫實現(xiàn)方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習吧2023-02-02
這篇文章主要介紹了Minio與SpringBoot使用okhttp3問題解決,有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-10-10
SpringBoot+Spring?Data?JPA整合H2數(shù)據(jù)庫的示例代碼
H2數(shù)據(jù)庫是一個開源的關系型數(shù)據(jù)庫，本文重點給大家介紹SpringBoot+Spring?Data?JPA整合H2數(shù)據(jù)庫的示例代碼，感興趣的朋友跟隨小編一起看看吧2022-02-02
這篇文章主要介紹了JAVA算法起步之插入排序實例,需要的朋友可以參考下2014-02-02
Java Kafka分區(qū)發(fā)送及消費實戰(zhàn)
本文主要介紹了Kafka分區(qū)發(fā)送及消費實戰(zhàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-07-07
DFS指在進行算法運算時，優(yōu)先將該路徑的當前路徑執(zhí)行完畢，執(zhí)行完畢或失敗后向上回溯嘗試其他途徑。BFS指在進行算法運算時，優(yōu)先將當前路徑點的所有情況羅列出來，然后根據(jù)羅列出來的情況羅列下一層。本文介紹了二者的實現(xiàn)與應用，需要的可以參考一下2022-11-11
SpringBoot+Dubbo+Zookeeper知識整合過程詳解
本文首先介紹了分布式系統(tǒng)的基本概念和分類,包括單一應用架構、垂直應用架構、分布式服務架構和流動計算架構,通過一個完整的Spring Boot + Dubbo + Zookeeper框架搭建示例,展示了如何將這些技術整合到一個實際的項目中,感興趣的朋友一起看看吧2025-02-02