springmvc+websocket 框架搭建

阿新 • • 發佈：2019-01-23

package com.cuit.secims.mw.ws; import java.util.ArrayList; import java.util.Map; import org.apache.log4j.Logger; import org.springframework.web.socket.CloseStatus; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.WebSocketMessage; import

org.springframework.web.socket.WebSocketSession; import com.google.common.reflect.TypeToken; import com.google.gson.Gson; public class MyWebSocketHandler implements WebSocketHandler{ private static final Logger log = Logger.getLogger(MyWebSocketHandler.class); // 儲存所有的使用者session private

static final ArrayList<WebSocketSession> users = new ArrayList<WebSocketSession>(); // 連線就緒時 @Override public void afterConnectionEstablished(WebSocketSession session) throws Exception { log.info("connect websocket success......."); users.add(session); } // 處理資訊

@Override public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception { Gson gson = new Gson(); // 將訊息JSON格式通過Gson轉換成Map // message.getPayload().toString() 獲取訊息具體內容 Map<String, Object> msg = gson.fromJson(message.getPayload().toString(), new TypeToken<Map<String, Object>>() {}.getType()); log.info("handleMessage......."+message.getPayload()+"..........."+msg); // session.sendMessage(message); // 處理訊息 msgContent訊息內容 TextMessage textMessage = new TextMessage(msg.get("msgContent").toString(), true); // 呼叫方法（傳送訊息給所有人） sendMsgToAllUsers(textMessage); } // 處理傳輸時異常 @Override public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception { // TODO Auto-generated method stub } // 關閉連線時 @Override public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception { log.info("connect websocket closed......."); users.remove(session); } @Override public boolean supportsPartialMessages() { // TODO Auto-generated method stub return false; } // 給所有使用者傳送資訊 public void sendMsgToAllUsers(WebSocketMessage<?> message) throws Exception{ for (WebSocketSession user : users) { user.sendMessage(message); } } }

springmvc+websocket 框架搭建

springmvc+websocket 框架搭建

SpringMVC基礎框架搭建

springboot+mybatis+springMVC基礎框架搭建

Dubbo+SpringBoot+Spring+SpringMVC+MyBatis框架搭建的Demo中遇到的錯誤

Spring+Springmvc+Hibernate框架搭建，簡單例項

SpringMVC+Ibatis框架搭建

maven+springmvc+hibernate4框架搭建-純手工親手測試通過

一、springMVC+freemarker框架搭建

SSM（Spring+SpringMVC+Mybatis）框架搭建詳細教程【附源代碼Demo】

使用idea搭建Maven+SSM(Spring+SpringMVC+Mybatis)框架（一、使用Maven創建新工程）

新手搭建springmvc+mybits框架的經驗分享

springMVC框架搭建

SpringMVC框架搭建環境

Spring+Mybatis+SpringMVC+Maven+MySql(SSM框架)搭建例項

1025_Idea SSM框架搭建--------------Maven+Spring5+mybatis3.4.5+SpringMVC+Oracle

SpringMVC框架搭建步驟

SpringMVC——SSM框架對資料庫進行操作的流程以及搭建SSM框架的步驟

搭建eclipse+tomcat+maven+shiro+springmvc+jpa專案（二）：基本框架搭建

SpringMVC框架搭建（使用Jar包搭建）

SpringMVC 專案框架的搭建（javaweb專案）

springmvc+websocket 框架搭建

相關推薦