使用 Spring Boot 實現(xiàn) WebSocket實時通信
在開發(fā) Web 應(yīng)用程序時,我們有時需要將服務(wù)端事件推送到連接的客戶端。但 HTTP 并不能做到。客戶端打開與服務(wù)端的連接并請求數(shù)據(jù),但服務(wù)端不能打開與客戶端的連接并推送數(shù)據(jù)。
為了解決這個限制,我們可以建立了一個輪詢模式,網(wǎng)頁會間隔地輪詢服務(wù)器以獲取新事件。但這種模式不太理想,因為它增加了 HTTP 開銷,速度也只能達到與輪詢的速率一樣快,并且給服務(wù)器增加了不必要的負載。
幸運的是,HTML5 WebSocket 出現(xiàn)了。WebSocket 協(xié)議允許瀏覽器與 Web 服務(wù)器之間進行低開銷的交互。在文中,我們將介紹 Websockets API,并展示如何使用 Spring Boot 實現(xiàn) Websockets。
HTML5 來救場!
WebSockets 通過瀏覽器和服務(wù)器之間的單連接提供全雙工通信。它不存在 HTTP 開銷,并且允許服務(wù)器將消息實時推送到客戶端。
WebSocket API 實際上很簡單。您只需要創(chuàng)建一個 WebSocket 對象,附加事件監(jiān)聽器和發(fā)送消息即可。
以下是一個例子:
var socket = new WebSocket('ws://' + window.location.host + '/my-websocket-endpoint');
// Add an event listener for when a connection is open
socket.onopen = function() {
console.log('WebSocket connection opened. Ready to send messages.');
// Send a message to the server
socket.send('Hello, from WebSocket client!');
};
// Add an event listener for when a message is received from the server
socket.onmessage = function(message) {
console.log('Message received from server: ' + message);
};
Spring Boot
Spring 對 WebSockets 接口提供了很好的支持。
首先,我們需要創(chuàng)建一個類,繼承 Spring 的 TextWebSocketHandler 類。
public class MyMessageHandler extends TextWebSocketHandler {
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
// The WebSocket has been closed
}
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
// The WebSocket has been opened
// I might save this session object so that I can send messages to it outside of this method
// Let's send the first message
session.sendMessage(new TextMessage("You are now connected to the server. This is the first message."));
}
@Override
protected void handleTextMessage(WebSocketSession session, TextMessage textMessage) throws Exception {
// A message has been received
System.out.println("Message received: " + textMessage.getPayload());
}
}
接下來,我們需要配置 WebSocket 端點。
@Configuration
@EnableWebSocket
public class WebsocketConfig implements WebSocketConfigurer {
@Bean
public WebSocketHandler myMessageHandler() {
return new MyMessageHandler();
}
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(myMessageHandler(), "/my-websocket-endpoint");
}
}
由于 WebSockets API 是純 JavaScript,您可以在大多數(shù)前端框架中它。包括 Angular,您可以在 TypeScript 中包含 JavaScript 代碼。
總結(jié)
是不是相當(dāng)簡單?它解決了服務(wù)端和客戶端之間傳輸數(shù)據(jù)的一大困擾。Spring Boot 使它變得更加簡單。
原文鏈接:https://keyholesoftware.com/2017/04/10/websockets-with-spring-boot/
作者:THOMAS KENDALL
譯者:oopsguy.com
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- 使用spring的websocket創(chuàng)建通信服務(wù)的示例代碼
- PHP實現(xiàn)websocket通信的方法示例
- WebSocket的通信過程與實現(xiàn)方法詳解
- android利用websocket協(xié)議與服務(wù)器通信
- C# websocket及時通信協(xié)議的實現(xiàn)方法示例
- Spring Boot 開發(fā)私有即時通信系統(tǒng)(WebSocket)
- .NET實現(xiàn)WebSocket服務(wù)端即時通信實例
- WebSocket+node.js創(chuàng)建即時通信的Web聊天服務(wù)器
- Python通過websocket與js客戶端通信示例分析
- 在Android中使用WebSocket實現(xiàn)消息通信的方法詳解
相關(guān)文章
Android開發(fā)中Socket通信的基本實現(xiàn)方法講解
這篇文章主要介紹了Android開發(fā)中Socket通信的基本實現(xiàn)方法講解,是安卓上移動互聯(lián)網(wǎng)程序開發(fā)的基礎(chǔ),需要的朋友可以參考下2015-12-12
elasticsearch的zenDiscovery和master選舉機制原理分析
這篇文章主要介紹了elasticsearch的zenDiscovery和master選舉機制原理分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-04-04
SpringBoot使用Feign進行服務(wù)間通信的實現(xiàn)示例代碼
Feign是一個開源的Java HTTP客戶端,可以幫助我們在SpringBoot應(yīng)用中快速構(gòu)建和使用HTTP客戶端,方便實現(xiàn)服務(wù)間的通信,本文就來介紹一下SpringBoot使用Feign進行服務(wù)間通信的實現(xiàn)示例代碼,感興趣的可以了解一下2024-01-01

