您好,登錄后才能下訂單哦!
本篇內(nèi)容介紹了“Spring Boot如何實(shí)現(xiàn)WebSocket”的有關(guān)知識(shí),在實(shí)際案例的操作過(guò)程中,不少人都會(huì)遇到這樣的困境,接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
WebSocket協(xié)議提供了一種標(biāo)準(zhǔn)化的方法,通過(guò)單個(gè)TCP連接在客戶機(jī)和服務(wù)器之間建立全雙工、雙向的通信通道。它是一種不同于HTTP的TCP協(xié)議,但被設(shè)計(jì)為在HTTP上工作,使用端口80和443,并允許重用現(xiàn)有的防火墻規(guī)則。
WebSocket 協(xié)議是獨(dú)立的基于 TCP 協(xié)議。它與 HTTP 的唯一關(guān)系是,它的握手會(huì)被 HTTP 服務(wù)器解釋為 Upgrade 請(qǐng)求。
使用“Upgrade: websocket”切換到 websocket 協(xié)議:
GET /spring-websocket-portfolio/portfolio HTTP/1.1 Host: localhost:8080 Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: Uc9l9TMkWGbHFD2qnFHltg== Sec-WebSocket-Protocol: v10.stomp, v11.stomp Sec-WebSocket-Version: 13 Origin: http://localhost:8080
websocket 服務(wù)器返回 “101”:
HTTP/1.1 101 Switching Protocols Upgrade: websocket Connection: Upgrade Sec-WebSocket-Accept: 1qVdfYHU9hPOl4JYYNXF623Gzn0= Sec-WebSocket-Protocol: v10.stomp
HTTP 中,應(yīng)用會(huì)提供很多 URLs??蛻舳送ㄟ^(guò) 請(qǐng)求-響應(yīng)風(fēng)格訪問(wèn)這些 URLs。服務(wù)器根據(jù)請(qǐng)求的 URL、方法、請(qǐng)求頭路由這些請(qǐng)求到合適的處理。
WebSocket 初始化連接只使用1個(gè) URL。之后,所有的消息使用相同的 TCP 連接。WebSocket 是一個(gè)低等級(jí)的協(xié)議,它沒(méi)有規(guī)定消息內(nèi)容的任何語(yǔ)義。這意味著,除非客戶機(jī)和服務(wù)器在消息語(yǔ)義上達(dá)成一致,否則無(wú)法路由或處理消息。
WebSocket 客戶端與服務(wù)器可以通過(guò)HTTP 握手請(qǐng)求的 Sec-WebSocket-Protocol 請(qǐng)求頭商定更高級(jí)別的消息協(xié)議(像 STOMP)
WebSockets可以使網(wǎng)頁(yè)具有動(dòng)態(tài)和交互性。然而,在許多情況下,Ajax和HTTP流或長(zhǎng)輪詢的組合可以提供一個(gè)簡(jiǎn)單而有效的解決方案。
例如,新聞、郵件和社交源需要?jiǎng)討B(tài)更新,但每隔幾分鐘更新一次可能完全沒(méi)有問(wèn)題。另一方面,協(xié)作、游戲和金融應(yīng)用需要更接近實(shí)時(shí)。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> <version>2.6.7</version> </dependency>
通過(guò)以下方式實(shí)現(xiàn) WebSocket 服務(wù)端:
實(shí)現(xiàn) WebSocketHandler 接口繼承 BinaryWebSocketHandler、TextWebSocketHandler 類
package org.spring.boot.websocket; import java.nio.charset.StandardCharsets; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketSession; import org.springframework.web.socket.handler.TextWebSocketHandler; /** * websocket 處理類:在請(qǐng)求信息的基礎(chǔ)上加上“服務(wù)器返回:”,然后返回給客戶端 * @author black * */ public class EchoTextWebSocketHandler extends TextWebSocketHandler { @Override protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { // 收到的信息 String requestMsg = message.getPayload(); System.out.println("服務(wù)器收到:" + requestMsg ); // 組織響應(yīng)信息 String responseMsg = "服務(wù)器返回: " + requestMsg; System.out.println(responseMsg ); TextMessage respMsg = new TextMessage(responseMsg.getBytes(StandardCharsets.UTF_8)); // 返回給客戶端 session.sendMessage( respMsg); } }
package org.spring.boot.websocket; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.WebSocketConfigurer; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistration; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; /** * WebSocket 配置類 * @author black * */ @Configuration @EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer { public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { // 為指定的URL 配置具體的 WebSocketHandler WebSocketHandlerRegistration registration = registry.addHandler(echoHandler(), "/echo"); // registration 能夠?qū)?nbsp;WebSocketHandler 進(jìn)行配置 } @Bean public WebSocketHandler echoHandler() { return new EchoTextWebSocketHandler(); } }
package org.spring.boot.websocket; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; /** * Spring boot 使用 websocket 代碼示例 * */ @SpringBootApplication public class SpringBootWebSocketBootstrap { public static void main( String[] args ) { SpringApplication.run(SpringBootWebSocketBootstrap.class, args); } }
應(yīng)用默認(rèn)端口為 8080 ,嵌入式容器是 tomcat。
使用 Postman 進(jìn)行 WebSocket 測(cè)試.
新建WebSocket 請(qǐng)求:
輸入“l(fā)ocalhost:8080”
點(diǎn)擊【Connect】,下面顯示:
展開(kāi) “Connected to localhost:8080/echo”,具體內(nèi)容:
# Handshake Details Request URL: http://localhost:8080/echo Request Method: GET Status Code: 101 # Request Headers Sec-WebSocket-Version: 13 Sec-WebSocket-Key: 1bNYHBOf9wqNuy2WUOYIsQ== Connection: Upgrade Upgrade: websocket Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits Host: localhost:8080 # Response Headers Upgrade: websocket Connection: upgrade Sec-WebSocket-Accept: uh9IkfewEg11GuuAKnbXmpH+Yqo= Sec-WebSocket-Extensions: permessage-deflate;client_max_window_bits=15 Date: Sat, 30 Apr 2022 05:53:23 GMT
輸入“hello, 我是 black!”
點(diǎn)擊【Send】
上圖可以看出消息是按倒序展示的。
最后點(diǎn)擊url旁邊的【Disconnect】按鈕關(guān)閉連接:
驗(yàn)證結(jié)束。
“Spring Boot如何實(shí)現(xiàn)WebSocket”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。