當(dāng)前位置：首頁(yè) > 科技 > 軟件

SpringBoot整合WebSocket詳解

來(lái)源：責(zé)編：時(shí)間：2023-08-09 23:02:31 376觀看

導(dǎo)讀環(huán)境：Springboot3.0.5WebSocket介紹WebSocket協(xié)議RFC 6455提供了一種標(biāo)準(zhǔn)化的方式，通過(guò)一個(gè)TCP連接在客戶端和服務(wù)器之間建立全雙工、雙向的通信通道。它是一個(gè)不同于HTTP的TCP協(xié)議，但設(shè)計(jì)為在HTTP之上工作，使用80和443端

環(huán)境：Springboot3.0.5

WebSocket介紹

WebSocket協(xié)議RFC 6455提供了一種標(biāo)準(zhǔn)化的方式，通過(guò)一個(gè)TCP連接在客戶端和服務(wù)器之間建立全雙工、雙向的通信通道。它是一個(gè)不同于HTTP的TCP協(xié)議，但設(shè)計(jì)為在HTTP之上工作，使用80和443端口，并允許重用現(xiàn)有的防火墻規(guī)則。

WebSocket交互開(kāi)始于一個(gè)HTTP請(qǐng)求，使用HTTP Upgrade header進(jìn)行升級(jí)，在本例中是切換到WebSocket協(xié)議。下面的例子展示了這種交互:

GET /spring-websocket-portfolio/portfolio HTTP/1.1Host: localhost:8080Upgrade: websocket             // ①Connection: Upgrade           // ②Sec-WebSocket-Key: Uc9l9TMkWGbHFD2qnFHltg==Sec-WebSocket-Protocol: v10.stomp, v11.stompSec-WebSocket-Version: 13Origin: http://localhost:8080

①：Upgrade header頭部信息

②：使用 Upgrade 連接

支持WebSocket的服務(wù)器會(huì)返回類似下面的輸出，而不是通常的200狀態(tài)碼:

HTTP/1.1 101 Switching Protocols Upgrade: websocketConnection: UpgradeSec-WebSocket-Accept: 1qVdfYHU9hPOl4JYYNXF623Gzn0=Sec-WebSocket-Protocol: v10.stomp

握手成功后，HTTP upgrade請(qǐng)求的TCP套接字保持打開(kāi)，客戶端和服務(wù)器可以繼續(xù)發(fā)送和接收消息。

如果WebSocket服務(wù)器運(yùn)行在web服務(wù)器(例如nginx)后面，你可能需要配置它來(lái)將WebSocket升級(jí)請(qǐng)求傳遞給WebSocket服務(wù)器。同樣，如果應(yīng)用程序運(yùn)行在云環(huán)境中，請(qǐng)查看云提供商提供的有關(guān)WebSocket支持的說(shuō)明。

HTTP與WebSocket

盡管WebSocket在設(shè)計(jì)上是與HTTP兼容的，而且從HTTP請(qǐng)求開(kāi)始，但重要的是要明白，這兩種協(xié)議導(dǎo)致了非常不同的架構(gòu)和應(yīng)用程序編程模型。

在HTTP和REST中，應(yīng)用程序被建模為多個(gè)url。為了與應(yīng)用程序交互，客戶端以請(qǐng)求-響應(yīng)的方式訪問(wèn)這些url。服務(wù)器根據(jù)HTTP URL、方法和首部將請(qǐng)求路由到適當(dāng)?shù)奶幚沓绦颉?span style="display:none">SS828資訊網(wǎng)——每日最新資訊28at.com

相比之下，在websocket中，初始連接通常只有一個(gè)URL。隨后，所有應(yīng)用程序消息都在同一個(gè)TCP連接上流動(dòng)。這是一種完全不同的異步、事件驅(qū)動(dòng)的消息傳遞架構(gòu)。

WebSocket也是一種底層傳輸協(xié)議，與HTTP不同，它對(duì)消息內(nèi)容沒(méi)有任何語(yǔ)義規(guī)定。這意味著除非客戶端和服務(wù)器在消息語(yǔ)義上達(dá)成一致，否則無(wú)法路由或處理消息。

WebSocket客戶端和服務(wù)器可以通過(guò)HTTP握手請(qǐng)求的Sec-WebSocket-Protocol頭部來(lái)協(xié)商使用更高級(jí)別的消息傳遞協(xié)議(例如STOMP)。在這種情況下，他們需要制定自己的慣例。

什么時(shí)候該使用WebSocket

WebSockets可以使網(wǎng)頁(yè)具有動(dòng)態(tài)性和交互性。然而，在許多情況下，Ajax和HTTP流或長(zhǎng)輪詢的組合可以提供簡(jiǎn)單而有效的解決方案。

例如，新聞、郵件和社交源需要?jiǎng)討B(tài)更新，但每隔幾分鐘更新一次完全沒(méi)問(wèn)題。另一方面，協(xié)作、游戲和金融應(yīng)用需要更接近實(shí)時(shí)。

延遲本身并不是決定性因素。如果消息量相對(duì)較少(例如監(jiān)視網(wǎng)絡(luò)故障)，HTTP流或輪詢可以提供有效的解決方案。低延遲、高頻率和高容量的組合才是WebSocket的最佳選擇。

還要記住，在互聯(lián)網(wǎng)上，你無(wú)法控制的限制性代理可能會(huì)阻止WebSocket交互，要么是因?yàn)樗鼈儧](méi)有配置為傳遞Upgrade header，要么是因?yàn)樗鼈冴P(guān)閉了看起來(lái)空閑的長(zhǎng)連接。這意味著對(duì)防火墻內(nèi)的內(nèi)部應(yīng)用程序使用WebSocket比面向公眾的應(yīng)用程序更直接。

WebSocket核心API

Spring框架提供了一個(gè)WebSocket API，可以用它來(lái)編寫(xiě)處理WebSocket消息的客戶端和服務(wù)器端應(yīng)用程序。

WebSocketHandler

創(chuàng)建WebSocket服務(wù)器很簡(jiǎn)單，只需實(shí)現(xiàn)WebSocketHandler，或者擴(kuò)展TextWebSocketHandler或BinaryWebSocketHandler。下面的例子使用了TextWebSocketHandler:

public class MessageHandler extends TextWebSocketHandler {  @Override  public void handleTextMessage(WebSocketSession session, TextMessage message) {    System.out.printf("SessionId: %s, 接收到消息: %s%n", session.getId(), message.getPayload()) ;    try {      session.sendMessage(new TextMessage("服務(wù)端接收到消息 - " + message.getPayload())) ;    } catch (IOException e) {      e.printStackTrace();    }  }  @Override  public void afterConnectionEstablished(WebSocketSession session) throws Exception {    System.out.printf("連接成功, 會(huì)話Id: %s, Attribute: %s%n", session.getId(), session.getAttributes()) ;  }  @Override  public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {    System.out.printf("連接關(guān)閉, 會(huì)話Id: %s, 關(guān)閉狀態(tài): %s%n", session.getId(), status.getCode() + " - " + status.getReason()) ;  }}

WebSocket配置

@Configuration@EnableWebSocketpublic class WebSocketConfig implements WebSocketConfigurer {  @Override  public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {    registry.addHandler(messageHandler(), "/message")  }  @Bean  public WebSocketHandler messageHandler() {    return new MessageHandler();  }}

WebSocket Handshake

要定制初始的HTTP WebSocket握手請(qǐng)求，最簡(jiǎn)單的方法是使用HandshakeInterceptor，它提供了握手前和握手后的方法。你可以使用這樣的攔截器來(lái)阻止握手，或者讓 WebSocketSession可以訪問(wèn)任何屬性。下面的例子使用內(nèi)置的攔截器將HTTP會(huì)話屬性傳遞給WebSocket會(huì)話:

@Configuration@EnableWebSocketpublic class WebSocketConfig implements WebSocketConfigurer {  @Override  public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {    registry      .addHandler(messageHandler(), "/message")      .setHandshakeHandler(handshakeHandler())      // 添加捂手?jǐn)r截器      .addInterceptors(new HandshakeInterceptor() {        // 如果該方法返回false，則不允許建立連接        @Override        public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response,            WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {          // todo          attributes.put("uid", uid) ;          return true ;        }        @Override        public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,            Exception exception) {          // todo        }      }) ;  }}

部署

Spring WebSocket API很容易集成到Spring MVC應(yīng)用程序中，DispatcherServlet可以同時(shí)處理HTTP WebSocket握手和其他HTTP請(qǐng)求。調(diào)用
WebSocketHttpRequestHandler也很容易集成到其他HTTP處理場(chǎng)景中。這樣既方便又容易理解。但是，對(duì)于JSR-356運(yùn)行時(shí)，需要特別注意。

Java WebSocket API (JSR-356)提供兩種部署機(jī)制。第一種方法涉及啟動(dòng)時(shí)的Servlet容器類路徑掃描(Servlet 3特性)@ServerEndpoint。另一個(gè)是Servlet容器初始化時(shí)使用的注冊(cè) API(ServletContainerInitializer)。這兩種機(jī)制都不可能對(duì)所有HTTP處理使用單個(gè)“前端控制器”?—?包括WebSocket握手和所有其他HTTP請(qǐng)求?—?如Spring MVC的DispatcherServlet。

這是JSR-356的一個(gè)重要限制，Spring的WebSocket支持通過(guò)特定于服務(wù)器的RequestUpgradeStrategy實(shí)現(xiàn)來(lái)解決這個(gè)問(wèn)題，即使運(yùn)行在JSR-356運(yùn)行時(shí)也是如此。Tomcat、Jetty、GlassFish、WebLogic、WebSphere和Undertow(以及WildFly)目前都存在這樣的策略。

服務(wù)配置

每個(gè)底層WebSocket引擎都公開(kāi)了控制運(yùn)行時(shí)特征的配置屬性，例如消息緩沖區(qū)大小、空閑超時(shí)等。

對(duì)于Tomcat、WildFly和GlassFish，可以在WebSocket Java配置中添加
ServletServerContainerFactoryBean，如下面的例子所示:

@Beanpublic ServletServerContainerFactoryBean servletServerContainerFactoryBean() {  ServletServerContainerFactoryBean container = new ServletServerContainerFactoryBean() ;  container.setMaxTextMessageBufferSize(8192) ;  container.setMaxBinaryMessageBufferSize(8192) ;  return container ;}

允許的來(lái)源

從Spring Framework 4.1.5開(kāi)始，WebSocket和SockJS的默認(rèn)行為是只接受同源請(qǐng)求。也可以允許所有或指定的來(lái)源列表。這個(gè)檢查主要是為瀏覽器客戶端設(shè)計(jì)的。沒(méi)有什么能阻止其他類型的客戶端修改Origin首部值。

三種可能的行為是：

僅允許同源請(qǐng)求(默認(rèn)):在這種模式下，當(dāng)啟用SockJS時(shí)，Iframe HTTP響應(yīng)頭X-Frame-Options設(shè)置為SAMEORIGIN，并且禁用JSONP傳輸，因?yàn)樗辉试S檢查請(qǐng)求的來(lái)源。因此，啟用此模式時(shí)，不支持IE6和IE7。
允許指定的來(lái)源列表:每個(gè)允許的來(lái)源必須以http://或https://.開(kāi)頭在此模式下，當(dāng)啟用SockJS時(shí)，禁用IFrame傳輸。因此，啟用此模式時(shí)，將不支持IE6到IE9。
允許所有來(lái)源:要啟用此模式，你應(yīng)該提供*作為允許的來(lái)源值。在該模式下，所有傳輸通道都可用。

@Configuration@EnableWebSocketpublic class WebSocketConfig implements WebSocketConfigurer {  @Override  public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {    registry      .addHandler(messageHandler(), "/message")      .setAllowedOriginPatterns("*") ;  }}

測(cè)試

通過(guò)上面的介紹和配置，WebSocket環(huán)境就算是簡(jiǎn)單的配置完成了，接下來(lái)通過(guò)Postman進(jìn)行測(cè)試。

圖片

連接成功

發(fā)送消息及接收消息

服務(wù)端接收到消息

本文鏈接：http://www.www897cc.com/showinfo-26-5136-0.htmlSpringBoot整合WebSocket詳解

聲明：本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com

上一篇：這款輕量級(jí)規(guī)則引擎，真香！

下一篇：大模型速度狂飆2.39倍！清華聯(lián)手微軟首提SoT，讓LLM思考更像人類

標(biāo)簽：

熱門(mén)焦點(diǎn)

鴻蒙OS 4.0公測(cè)機(jī)型公布：甚至連nova6都支持

華為全新的HarmonyOS 4.0操作系統(tǒng)將于今天下午正式登場(chǎng)，官方在發(fā)布會(huì)之前也已經(jīng)正式給出了可升級(jí)的機(jī)型產(chǎn)品，這意味著這些機(jī)型會(huì)率先支持升級(jí)享用。這次的HarmonyOS 4.0支持
一文掌握 Golang 模糊測(cè)試（Fuzz Testing）

模糊測(cè)試（Fuzz Testing）模糊測(cè)試（Fuzz Testing）是通過(guò)向目標(biāo)系統(tǒng)提供非預(yù)期的輸入并監(jiān)視異常結(jié)果來(lái)發(fā)現(xiàn)軟件漏洞的方法?？梢杂脕?lái)發(fā)現(xiàn)應(yīng)用程序、操作系統(tǒng)和網(wǎng)絡(luò)協(xié)議等中的漏洞或
WebRTC.Net庫(kù)開(kāi)發(fā)進(jìn)階，教你實(shí)現(xiàn)屏幕共享和多路復(fù)用！

WebRTC.Net庫(kù)：讓你的應(yīng)用更親民友好，實(shí)現(xiàn)視頻通話無(wú)痛接入！除了基本用法外，還有一些進(jìn)階用法可以更好地利用該庫(kù)。自定義 STUN/TURN 服務(wù)器配置WebRTC.Net 默認(rèn)使用 Google 的
網(wǎng)紅炒股不為了賺錢(qián)，那就是耍流氓！

來(lái)源：首席商業(yè)評(píng)論6月26日高調(diào)宣布入市，網(wǎng)絡(luò)名嘴大v胡錫進(jìn)居然進(jìn)軍了股市。在一次財(cái)經(jīng)媒體峰會(huì)上，幾個(gè)財(cái)經(jīng)圈媒體大佬就“胡錫進(jìn)炒股是否知道認(rèn)真報(bào)道”展開(kāi)討論。有
3699元！iQOO Neo8 Pro頂配版今日首銷：1TB UFS 4.0同價(jià)位唯一

5月23日，iQOO推出了全新的iQOO Neo8系列，包含iQOO Neo8和iQOO Neo8 Pro兩個(gè)版本，其中標(biāo)準(zhǔn)版搭載高通驍龍8+，而Pro版更是首發(fā)搭載了聯(lián)發(fā)科天璣9200+旗艦
OPPO K11搭載高性能石墨散熱系統(tǒng)：旗艦同款性能涼爽釋放

日前OPPO官方宣布，將于7月25日14:30舉辦新品發(fā)布會(huì)，屆時(shí)全新的OPPO K11將正式與大家見(jiàn)面，將主打旗艦影像，和同檔位競(jìng)品相比，其最大的賣點(diǎn)就是將配備索尼
Windows 11發(fā)布，微軟一改往常對(duì)老機(jī)型開(kāi)放的態(tài)度

距離 Windows 11 發(fā)布已經(jīng)過(guò)去一周，在過(guò)去一周里，很多數(shù)碼愛(ài)好者圍繞其對(duì) Android 應(yīng)用的支持、對(duì)老機(jī)型的升級(jí)問(wèn)題展開(kāi)了激烈討論。與以往不同的是，在這次大
蘋(píng)果140W USB-C充電器：采用氮化鎵技術(shù)

據(jù)10 月 30 日 9to5 Mac 消息報(bào)道，當(dāng)蘋(píng)果推出新的 MacBook Pro 2021 時(shí)，該公司還推出了新的 140W USB-C 充電器，附贈(zèng)在 MacBook Pro 16 英寸機(jī)型的盒子里，也支
最薄的14英寸游戲筆記本電腦 Alienware X14已可以購(gòu)買(mǎi)

2022年1月份在國(guó)際消費(fèi)電子展(CES2022)上首次亮相的Alienware新品——Alienware X14現(xiàn)在已經(jīng)可以購(gòu)買(mǎi)了，這款筆記本電腦被譽(yù)為世界上最薄的 14 英寸游戲筆

日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

SpringBoot整合WebSocket詳解

WebSocket介紹

HTTP與WebSocket

什么時(shí)候該使用WebSocket

WebSocket核心API

測(cè)試

鴻蒙OS 4.0公測(cè)機(jī)型公布：甚至連nova6都支持

一文掌握 Golang 模糊測(cè)試（Fuzz Testing）

WebRTC.Net庫(kù)開(kāi)發(fā)進(jìn)階，教你實(shí)現(xiàn)屏幕共享和多路復(fù)用！

網(wǎng)紅炒股不為了賺錢(qián)，那就是耍流氓！

3699元！iQOO Neo8 Pro頂配版今日首銷：1TB UFS 4.0同價(jià)位唯一

OPPO K11搭載高性能石墨散熱系統(tǒng)：旗艦同款性能涼爽釋放

Windows 11發(fā)布，微軟一改往常對(duì)老機(jī)型開(kāi)放的態(tài)度

蘋(píng)果140W USB-C充電器：采用氮化鎵技術(shù)

最薄的14英寸游戲筆記本電腦 Alienware X14已可以購(gòu)買(mǎi)

最新推薦

猜你喜歡

熱門(mén)推薦

相關(guān)資訊