国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術文章
文章詳情頁

springboot+vue實現websocket配置過程解析

瀏覽:32日期:2023-01-27 14:23:02

1.引入依賴

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> <version>1.3.5.RELEASE</version></dependency>

2.配置ServerEndpointExporter

@Configurationpublic class WebSocketConfig { @Bean public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); }}

這個bean會自動注冊使用了@ServerEndpoint注解聲明的Websocket endpoint。

3.創建websocket的ServerEndpoint端點

@Component@ServerEndpoint('/socket')public class WebSocketServer { /** * 全部在線會話 */ private static Map<String, Session> onlineSessions = new ConcurrentHashMap<>(); /** * 當客戶端打開連接:1.添加會話對象 2.更新在線人數 */ @OnOpen public void onOpen(Session session) { onlineSessions.put(session.getId(), session); } /** * 當客戶端發送消息:1.獲取它的用戶名和消息 2.發送消息給所有人 * <p> * PS: 這里約定傳遞的消息為JSON字符串 方便傳遞更多參數! */ @OnMessage public void onMessage(Session session, String jsonStr) { } /** * 當關閉連接:1.移除會話對象 2.更新在線人數 */ @OnClose public void onClose(Session session) { onlineSessions.remove(session.getId()); } /** * 當通信發生異常:打印錯誤日志 */ @OnError public void onError(Session session, Throwable error) { error.printStackTrace(); } /** * 公共方法:發送信息給所有人 */ public void sendMessageToAll(String jsonMsg) { onlineSessions.forEach((id, session) -> { try {session.getBasicRemote().sendText(jsonMsg); } catch (IOException e) {e.printStackTrace(); } }); }}

4.前端配置連接與接收消息

<script>import Vue from ’vue’import ElementUI from ’element-ui’;import ’element-ui/lib/theme-chalk/index.css’; // 默認主題Vue.use(ElementUI, {size: ’small’});import ’@/directives/directives.js’import Locale from ’@/mixins/locale’;import { t } from ’@/locale’; /** * WebSocket客戶端 * * 使用說明: * 1、WebSocket客戶端通過回調函數來接收服務端消息。例如:webSocket.onmessage * 2、WebSocket客戶端通過send方法來發送消息給服務端。例如:webSocket.send(); */ function getWebSocket() { /** * WebSocket客戶端 PS:URL開頭表示WebSocket協議 中間是域名端口 結尾是服務端映射地址 */ var webSocket = new WebSocket(’ws://10.10.10.3:9117/socket’);//建立與服務端的連接 /** * 當服務端打開連接 */ webSocket.onopen = function (event) { console.log(’WebSocket打開連接’); }; /** * 當服務端發來消息:1.廣播消息 2.更新在線人數 */ webSocket.onmessage = function (event) { console.log(event) console.log(’WebSocket收到消息:%c’ + event.data, ’color:green’); //獲取服務端消息 var message = JSON.parse(event.data) || {}; console.log(message)// }; /** * 關閉連接 */ webSocket.onclose = function (event) { console.log(’WebSocket關閉連接’); }; /** * 通信失敗 */ webSocket.onerror = function (event) { console.log(’WebSocket發生異常’); }; return webSocket; } var webSocket = getWebSocket(); /** * 通過WebSocket對象發送消息給服務端 * 此處沒有主動發消息給服務端,如果調用此方法,則會發送消息至socket服務端onMessage()方法上 */ function sendMsgToServer() { var $message = $(’#msg’); if ($message.val()) { webSocket.send(JSON.stringify({username: $(’#username’).text(), msg: $message.val()})); $message.val(null); } }export default { }

5.實現后端推送消息至瀏覽器端

@Autowired private WebSocketServer webSocketServer;//注入socket服務 @Override public PuStatesResult queryPuStateUseInfo(QueryCondition condition) { String sql = condition.generatorSql(); if(sql == null){ return null; } List<PuState> puStateList = null; puStateList = puStateMapper.getPusBySql(sql); if(puStateList == null || puStateList.size() == 0){ return null; } PuStatesResult result = new PuStatesResult(); result.setPuStateList(puStateList); result.computePuStates(); if(false == condition.isWithDetail()){ result.setPuStateList(null); } //todo Gson gson = new Gson(); String json = gson.toJson(result); webSocketServer.sendMessageToAll(json);//調用第3節中的方法 return result; }

此處是前端查詢時,服務器將一些數據發送至前端,假如我們在實現有些前端數據顯示的時候,當查詢一次后,如果沒有斷開連接,希望后端數據更新后,前端能接收最近數據。那么可以在數據更新接口中,調用自己實現的socket服務端邏輯,推送消息至服務端,然后由服務端監聽,并更新數據

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 欧美精品国产制服第一页 | 天堂8在线天堂资源bt | 亚洲美女视频一区二区三区 | 国产一区欧美 | 日本免费一二区视频 | 日韩欧美国产高清在线观看 | a一级特黄日本大片 s色 | 91成人影院 | 亚洲在线观看网站 | 成人国产精品999视频 | 香焦视频在线观看黄 | 欧美一级视频免费观看 | 亚洲欧美成人在线 | 国产视频二区在线观看 | 国产精品短视频免费观看 | 全国男人的天堂网 | 成人在线视频免费看 | 波多野结衣手机视频一区 | 在线看免费观看韩国特黄一级 | 欧美日韩国产一区二区三区播放 | 毛片久久久 | 黄色美女视频免费 | 美女黄色在线看 | 成人在线免费观看网站 | 欧美在线一级毛片观看 | 国产免费人视频在线观看免费 | 国产一区二区精品 | 久久91在线| 91国语对白 | 日本一区深夜影院深a | 欧美午夜激情影院 | 久久久久久综合对白国产 | 日本不卡一区二区三区在线观看 | 欧美一区二区三区在线观看 | 亚洲国产精品久久卡一 | 亚洲视频在线视频 | 一级成人a免费视频 | 丝袜足液精子免费视频 | 成人免费在线播放 | 天天爱天天做天天爽天天躁 | 一区二区三区免费在线观看 |