使用spring websocket實(shí)現(xiàn)后臺(tái)給前端推送消息
在支持websocket的瀏覽器版本上能夠正常實(shí)現(xiàn)消息的收發(fā),現(xiàn)在使用sockjs做為不支持websocket的瀏覽器的兼容方案。
瀏覽器支持websocket時(shí):
并且后端會(huì)輸出對(duì)應(yīng)的連接成功的日志信息
當(dāng)瀏覽器不支持websocket時(shí),使用sockjs:
發(fā)現(xiàn)握手請(qǐng)求發(fā)送成功了,但是并沒有握手成功,連接沒有建立起來,也沒有相關(guān)的日志信息輸出。
"/info"和"t="是sockjs自己加上去的,我原來的url是http://localhost:8081/FGMSP-ui/sockjs/websocket?uid=2131231
為什么sockjs會(huì)在我原有的url上自動(dòng)加上info
的后綴和t
這個(gè)參數(shù)?
另外sockjs之后還發(fā)起過很多次類似的請(qǐng)求,如下圖
都是在我原先的url上加了后綴和參數(shù),這是什么原理啊?
為什么我的第一次的握手請(qǐng)求發(fā)送顯示成功了(在調(diào)試DispatcherServlet類的doDispatch()時(shí)也看到了這個(gè)請(qǐng)求已經(jīng)進(jìn)來),但是沒有被interceptor和handler處理?是我的配置出錯(cuò)了嗎?
下面是我的一些代碼和配置
config
@Configuration
@EnableWebMvc
@EnableWebSocket
public class MySocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer {
@Autowired
private MySocketHandler mySocketHandler;
@Autowired
private MyInterceptor myInterceptor;
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(mySocketHandler, "/websocket")
.addInterceptors(myInterceptor);
// 瀏覽器不支持websocket,使用sockjs建立連接
registry.addHandler(new MySocketHandler(), "/sockjs/websocket/info")
.addInterceptors(myInterceptor)
.withSockJS();
}
}
interceptor
public class MyInterceptor implements HandshakeInterceptor {
@Override
public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response,
WebSocketHandler webSocketHandler, Map<String, Object> attributes) throws Exception {
// System.out.println("Websocket:用戶[ID:" + ((ServletServerHttpRequest) request).getServletRequest().getSession(false).getAttribute("uid") + "]已經(jīng)建立連接");
if (request instanceof ServletServerHttpRequest) {
// 獲取請(qǐng)求參數(shù),首先我們要獲取HttpServletRequest對(duì)象才能獲取請(qǐng)求參數(shù);當(dāng)ServerHttpRequset的層次結(jié)構(gòu)打開后其子類可以獲取到我們想要的http對(duì)象,那么就簡(jiǎn)單了。
// 我這里是把獲取的請(qǐng)求數(shù)據(jù)綁定到session的map對(duì)象中(attributes)
HttpServletRequest servletRequest = ((ServletServerHttpRequest) request).getServletRequest();
String id = servletRequest.getSession().getId();
// 標(biāo)記用戶
String uid = servletRequest.getParameter("uid");
attributes.put("uid", uid);
if(uid!=null){
attributes.put("uid", uid);
System.out.println(String.format("websocket建立握手前:sessionId[%s],userId[%s]", id, uid));
}else{
return false;
}
}
return true;
}
@Override
public void afterHandshake(ServerHttpRequest serverHttpRequest, ServerHttpResponse serverHttpResponse, WebSocketHandler webSocketHandler, Exception e) {
System.out.println("握手后");
}
}
handler
public class MySocketHandler implements WebSocketHandler {
private static final Logger logger = Logger.getLogger(MySocketHandler.class);
// websocket連接建立
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
logger.info("Websocket Connection established");
logger.info("getId:" + session.getId());
logger.info ("getLocalAddress:" + session.getLocalAddress().toString());
logger.info ("getUri:" + session.getUri().toString());
session.sendMessage(new TextMessage("Server:connected OK!"));
String uid = (String) session.getHandshakeAttributes().get("uid");
if (SocketSessionMap.socketSession.get(uid) == null) {
SocketSessionMap.socketSession.put(uid, session);
}
}
// 消息處理
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
}
// 消息傳輸錯(cuò)誤
@Override
public void handleTransportError(WebSocketSession session, Throwable throwable) throws Exception {
if (session.isOpen()) {
session.close();
}
// 移除Socket會(huì)話
Iterator<Map.Entry<String, WebSocketSession>> iter = SocketSessionMap.socketSession.entrySet().iterator();
while (iter.hasNext()) {
ConcurrentHashMap.Entry entry = iter.next();
if (entry.getValue() == session) {
SocketSessionMap.socketSession.remove(entry.getKey());
System.out.println("Socket會(huì)話已經(jīng)移除:用戶ID" + entry.getKey());
break;
}
}
}
// websocket 連接關(guān)閉
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
// TODO Auto-generated method stub
System.out.println("Websocket:" + session.getId() + "已經(jīng)關(guān)閉");
// 移除Socket會(huì)話
Iterator<Map.Entry<String, WebSocketSession>> iter = SocketSessionMap.socketSession.entrySet().iterator();
while (iter.hasNext()) {
ConcurrentHashMap.Entry entry = iter.next();
if (entry.getValue() == session) {
SocketSessionMap.socketSession.remove(entry.getKey());
System.out.println("Socket會(huì)話已經(jīng)移除:用戶ID" + entry.getKey());
break;
}
}
}
@Override
public boolean supportsPartialMessages() {
return false;
}
/**
* 給某個(gè)用戶發(fā)送消息
*
* @param uid
* @param message
* @throws IOException
*/
public void sendMessageToUser(String uid, TextMessage message)
throws IOException {
WebSocketSession session = SocketSessionMap.socketSession.get(uid);
if (session != null && session.isOpen()) {
session.sendMessage(message);
}
}
}
DispatcherServlet配置
<servlet>
<servlet-name>springmvc</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:applicationContext-mvc.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
...
<servlet-mapping>
<servlet-name>springmvc</servlet-name>
<url-pattern>/websocket</url-pattern>
</servlet-mapping>
<servlet-mapping>
<servlet-name>springmvc</servlet-name>
<url-pattern>/sockjs/websocket/info</url-pattern>
</servlet-mapping>
<servlet>
<bean id="mySocketHandler" class="com.fingard.rh.msp.socket.MySocketHandler"/>
<!-- 握手接口/攔截器 -->
<bean id="myInterceptor" class="com.fingard.rh.msp.socket.MyInterceptor"/>
<websocket:handlers >
<websocket:mapping path="/websocket" handler="mySocketHandler"/>
<websocket:handshake-interceptors>
<ref bean="myInterceptor"/>
</websocket:handshake-interceptors>
</websocket:handlers>
<!-- sockJS -->
<websocket:handlers>
<websocket:mapping path="/sockjs/websocket/info" handler="mySocketHandler"/>
<websocket:handshake-interceptors>
<ref bean="myInterceptor"/>
</websocket:handshake-interceptors>
<websocket:sockjs />
</websocket:handlers>
問題一、問題二。請(qǐng)不吝賜教,萬分感激??!
北大青鳥APTECH成立于1999年。依托北京大學(xué)優(yōu)質(zhì)雄厚的教育資源和背景,秉承“教育改變生活”的發(fā)展理念,致力于培養(yǎng)中國(guó)IT技能型緊缺人才,是大數(shù)據(jù)專業(yè)的國(guó)家
北大青鳥中博軟件學(xué)院創(chuàng)立于2003年,作為華東區(qū)著名互聯(lián)網(wǎng)學(xué)院和江蘇省首批服務(wù)外包人才培訓(xùn)基地,中博成功培育了近30000名軟件工程師走向高薪崗位,合作企業(yè)超4
中公教育集團(tuán)創(chuàng)建于1999年,經(jīng)過二十年潛心發(fā)展,已由一家北大畢業(yè)生自主創(chuàng)業(yè)的信息技術(shù)與教育服務(wù)機(jī)構(gòu),發(fā)展為教育服務(wù)業(yè)的綜合性企業(yè)集團(tuán),成為集合面授教學(xué)培訓(xùn)、網(wǎng)
達(dá)內(nèi)教育集團(tuán)成立于2002年,是一家由留學(xué)海歸創(chuàng)辦的高端職業(yè)教育培訓(xùn)機(jī)構(gòu),是中國(guó)一站式人才培養(yǎng)平臺(tái)、一站式人才輸送平臺(tái)。2014年4月3日在美國(guó)成功上市,融資1
曾工作于聯(lián)想擔(dān)任系統(tǒng)開發(fā)工程師,曾在博彥科技股份有限公司擔(dān)任項(xiàng)目經(jīng)理從事移動(dòng)互聯(lián)網(wǎng)管理及研發(fā)工作,曾創(chuàng)辦藍(lán)懿科技有限責(zé)任公司從事總經(jīng)理職務(wù)負(fù)責(zé)iOS教學(xué)及管理工作。
浪潮集團(tuán)項(xiàng)目經(jīng)理。精通Java與.NET 技術(shù), 熟練的跨平臺(tái)面向?qū)ο箝_發(fā)經(jīng)驗(yàn),技術(shù)功底深厚。 授課風(fēng)格 授課風(fēng)格清新自然、條理清晰、主次分明、重點(diǎn)難點(diǎn)突出、引人入勝。
精通HTML5和CSS3;Javascript及主流js庫,具有快速界面開發(fā)的能力,對(duì)瀏覽器兼容性、前端性能優(yōu)化等有深入理解。精通網(wǎng)頁制作和網(wǎng)頁游戲開發(fā)。
具有10 年的Java 企業(yè)應(yīng)用開發(fā)經(jīng)驗(yàn)。曾經(jīng)歷任德國(guó)Software AG 技術(shù)顧問,美國(guó)Dachieve 系統(tǒng)架構(gòu)師,美國(guó)AngelEngineers Inc. 系統(tǒng)架構(gòu)師。