spingboot集成webSocket
生活随笔
收集整理的這篇文章主要介紹了
spingboot集成webSocket
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
maven依賴
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId></dependency>WebSocketConfig.java
@Component public class WebSocketConfig {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();} }WebSocket.java
import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component;import javax.websocket.OnClose; import javax.websocket.OnMessage; import javax.websocket.OnOpen; import javax.websocket.Session; import javax.websocket.server.ServerEndpoint; import java.util.concurrent.CopyOnWriteArraySet;@Component @ServerEndpoint("/webSocket") @Slf4j public class WebSocket {private Session session;private static CopyOnWriteArraySet<WebSocket> webSocketSet = new CopyOnWriteArraySet<>();@OnOpenpublic void onOpen(Session session) {this.session = session;webSocketSet.add(this);log.info("【websocket消息】有新的連接, 總數(shù):{}", webSocketSet.size());}@OnClosepublic void onClose() {webSocketSet.remove(this);log.info("【websocket消息】連接斷開, 總數(shù):{}", webSocketSet.size());}@OnMessagepublic void onMessage(String message) {log.info("【websocket消息】收到客戶端發(fā)來的消息:{}", message);}public void sendMessage(String message) {for (WebSocket webSocket : webSocketSet) {log.info("【websocket消息】廣播消息, message={}", message);try {webSocket.session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}}}后端發(fā)送
webSocket.sendMessage(message);前端：
<!DOCTYPE html> <html> <head><meta charset="utf-8"><title>websocket</title> </head> <body><h1>websocket</h1> <div id="websocket"></div></body> <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.6.0/jquery.min.js"></script> <script>var websocket = null;if ('WebSocket' in window) {websocket = new WebSocket('ws://127.0.0.1:8053/webSocket');} else {alert('該瀏覽器不支持websocket!');}websocket.onopen = function (event) {console.log('建立連接');$("#websocket").html("websocket建立連接成功！");}websocket.onclose = function (event) {console.log('連接關(guān)閉');}websocket.onmessage = function (event) {console.log('收到消息:' + event.data)}websocket.onerror = function () {alert('websocket通信發(fā)生錯誤！');}window.onbeforeunload = function () {websocket.close();}</script> </html> 創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎總結(jié)
以上是生活随笔為你收集整理的spingboot集成webSocket的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 淘特如何开店铺
- 下一篇： java面试的题积累【持续更新中....