建站
咨詢(xún)
售后
建站咨詢(xún)
新聞中心
這篇文章主要講解了springboot+vue如何實(shí)現(xiàn)websocket配置，內(nèi)容清晰明了，對(duì)此有興趣的小伙伴可以學(xué)習(xí)一下，相信大家閱讀完之后會(huì)有幫助。
按需定制網(wǎng)站可以根據(jù)自己的需求進(jìn)行定制，成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作構(gòu)思過(guò)程中功能建設(shè)理應(yīng)排到主要部位公司成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作的運(yùn)用實(shí)際效果公司網(wǎng)站制作網(wǎng)站建立與制做的實(shí)際意義
1.引入依賴(lài)
org.springframework.boot spring-boot-starter-websocket 1.3.5.RELEASE
2.配置ServerEndpointExporter
@Configuration
public class WebSocketConfig {
@Bean
public ServerEndpointExporter serverEndpointExporter() {
return new ServerEndpointExporter();
}
}這個(gè)bean會(huì)自動(dòng)注冊(cè)使用了@ServerEndpoint注解聲明的Websocket endpoint。
3.創(chuàng)建websocket的ServerEndpoint端點(diǎn)
@Component
@ServerEndpoint("/socket")
public class WebSocketServer {
/**
* 全部在線(xiàn)會(huì)話(huà)
*/
private static Map onlineSessions = new ConcurrentHashMap<>();
/**
* 當(dāng)客戶(hù)端打開(kāi)連接：1.添加會(huì)話(huà)對(duì)象 2.更新在線(xiàn)人數(shù)
*/
@OnOpen
public void onOpen(Session session) {
onlineSessions.put(session.getId(), session);
}
/**
* 當(dāng)客戶(hù)端發(fā)送消息：1.獲取它的用戶(hù)名和消息 2.發(fā)送消息給所有人
*
* PS: 這里約定傳遞的消息為JSON字符串 方便傳遞更多參數(shù)！
*/
@OnMessage
public void onMessage(Session session, String jsonStr) {
}
/**
* 當(dāng)關(guān)閉連接：1.移除會(huì)話(huà)對(duì)象 2.更新在線(xiàn)人數(shù)
*/
@OnClose
public void onClose(Session session) {
onlineSessions.remove(session.getId());
}
/**
* 當(dāng)通信發(fā)生異常：打印錯(cuò)誤日志
*/
@OnError
public void onError(Session session, Throwable error) {
error.printStackTrace();
}
/**
* 公共方法：發(fā)送信息給所有人
*/
public void sendMessageToAll(String jsonMsg) {
onlineSessions.forEach((id, session) -> {
try {
session.getBasicRemote().sendText(jsonMsg);
} catch (IOException e) {
e.printStackTrace();
}
});
}
}
4.前端配置連接與接收消息