您好,登錄后才能下訂單哦!
近來學習 Spring WebSocket 時按照 Spring IN ACTION 中示例編寫代碼,運行時瀏覽器報404 錯誤
WebSocket connection to 'ws://localhost/websocket/marco' failed: Error during WebSocket handshake: Unexpected response code: 404
按照 Spring IN ACTION 中步驟:
首先,繼承 AbstractWebSocketHandler,重載以下 3 個方法:
- handleTextMessage – 處理文本類型消息
- afterConnectionEstablished – 新連接建立后調用
- afterConnectionClosed – 連接關閉后調用
import org.springframework.web.socket.CloseStatus; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketSession; import org.springframework.web.socket.handler.AbstractWebSocketHandler; public class MarcoHandler extends AbstractWebSocketHandler { protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { System.out.println("Received message: " + message.getPayload()); Thread.sleep(2000); session.sendMessage(new TextMessage("Polo!")); } @Override public void afterConnectionEstablished(WebSocketSession session) { System.out.println("Connection established!"); } @Override public void afterConnectionClosed(WebSocketSession session, CloseStatus status) { System.out.println("Connection closed. Status: " + status); } }
其次,使用 JavaConfig 啟用 WebSocket 并映射消息處理器
import org.springframework.context.annotation.Bean; import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.WebSocketConfigurer; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; @EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer { @Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(marcoHandler(), "/marco"); } @Bean public MarcoHandler marcoHandler() { return new MarcoHandler(); } }
最后,編寫前端 JS 代碼發(fā)起連接請求及后續(xù)消息交互
var url = 'ws://' + window.location.host + '/websocket/marco'; var sock = new WebSocket(url); sock.onopen = function() { console.log('Opening'); sock.send('Marco!'); }; sock.onmessage = function(e) { console.log('Received Message: ', e.data); setTimeout(function() { sayMarco() }, 2000); }; sock.onclose = function() { console.log('Closing'); }; function sayMarco() { console.log('Sending Marco!'); sock.send('Marco!'); }
部署后打開瀏覽器運行,直接報 404 錯誤
上網(wǎng)搜索了一晚上解決方案,包括參考 stackoverflow.com 上的經(jīng)驗都未解決該問題,直到查看到以下文章:
Spring集成webSocket頁面訪問404問題的解決方法
在此自己也做個記錄避免以后遺忘。
WebSocket 實質上借用 HTTP 請求進行握手,啟用 Spring WebSocket 需要在 org.springframework.web.servlet.DispatcherServlet 里配置攔截此請求。
以下是解決步驟:
首先,修改 WebSocketConfig 類定義,在類上添加 @Configuration 注解,表明該類以 JavaConfig 形式用作 bean 定義的源(相當于 XML 配置中的 <beans> 元素)。
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.WebSocketConfigurer; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; @Configuration @EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer { @Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(marcoHandler(), "/marco"); } @Bean public MarcoHandler marcoHandler() { return new MarcoHandler(); } }
其次,使用 JavaConfig 配置 DispatcherServlet,繼承org.springframework.web.servlet.support.AbstractAnnotationConfigDispatcherServletInitializer ,重載以下 3 個方法:
- getRootConfigClasses – 返回帶有 @Configuration 注解的類將會用來配置 ContextLoaderListener 創(chuàng)建的應用上下文中的 bean
- getServletConfigClasses – 返回帶有 @Configuration 注解的類將會用來定義 DispatcherServlet 應用上下文中的 bean
- getServletMappings – 將一個或多個路徑映射到 DispatcherServlet 上
實際上,如果只需要 Spring WebSocket 生效,則只需要在 getServletConfigClasses 方法中返回用來定義 DispatcherServlet 應用上下文中的 bean
import org.springframework.web.servlet.support.AbstractAnnotationConfigDispatcherServletInitializer; public class WebSocketInitializer extends AbstractAnnotationConfigDispatcherServletInitializer { @Override protected Class<?>[] getRootConfigClasses() { return null; } @Override protected Class<?>[] getServletConfigClasses() { return new Class<?>[] {WebSocketConfig.class}; } @Override protected String[] getServletMappings() { return new String[] {"/"}; } }
重新部署后代開瀏覽器運行成功
客戶端消息
服務器消息
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內(nèi)容。