溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
小編給大家分享一下SpringBoot如何使用WebSocket實現群發消息，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！
WebSocket 是一種在單個 TCP 連接上進行全雙工通信的協議，已被 W3C 定為標準。使用 WebSocket 可以使得客戶端和服務器之間的數據交換變得更加簡單。在 WebSocket 協議中，瀏覽器和服務器只需要完成一次握手，兩者之間就可以直接創建持久性的連接，并進行雙向數據傳輸。
特點
WebSocket 使用時需要先創建連接，這使得 Websocket 成為一種有狀態的協議，在之后的通信過程中可以省略部分狀態信息（例如身份認證等）。
WebSocket 連接在端口 80（ws）或者 443（wss）上創建，與 HTTP 使用的端口相同，這樣，基本上所有的防火墻都不會阻止 WebSocket 連接。
WebSocket 使用 HTTP 協議進行握手，因此它可以自然而然地集成到網絡瀏覽器和 HTTP 服務器中，而不需要額外的成本。
心跳消息（ping 和 pong）將被反復的發送，進而保持 WebSocket 連接一直處于活躍狀態。
使用該協議，當消息啟動或者到達的時候，服務端和客戶端都可以知道。
WebSocket 連接關閉時將發送一個特殊的關閉消息。
WebSocket 支持跨域，可以避免 Ajax 的限制。
HTTP 規范要求瀏覽器將并發連接數限制為每個主機名兩個連接，但是當我們使用 Websocket 的時候，當握手完成之后，該限制就不存在了，因為此時的連接已經不再是 HTTP 連接了。
WebSocket 協議支持擴展，用戶可以擴展協議，實現部分自定義的子協議。
WebSocket 擁有更好的二進制支持以及更好的壓縮效果。
一、添加依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> </dependency>
二、配置 WebSocket
Spring 框架提供了基于 WebSocket 的 STOMP 支持，STOMP 是一個簡單的可互操作的協議，通常被用于通過中間服務器在客戶端之間進行異步消息傳遞。
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
// 設置消息代理的前綴，如果消息的前綴為"/topic"，就會將消息轉發給消息代理（broker）
// 再由消息代理廣播給當前連接的客戶端
config.enableSimpleBroker("/topic");
// 下面方法可以配置一個或多個前綴，通過這些前綴過濾出需要被注解方法處理的消息。
// 例如這里表示前綴為"/app"的destination可以通過@MessageMapping注解的方法處理
// 而其他 destination（例如"/topic""/queue"）將被直接交給 broker 處理
config.setApplicationDestinationPrefixes("/app");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
// 定義一個前綴為"/chart"的endpoint，并開啟 sockjs 支持。
// sockjs 可以解決瀏覽器對WebSocket的兼容性問題，客戶端將通過這里配置的URL建立WebSocket連接
registry.addEndpoint("/chat").withSockJS();
}
}三、服務端代碼
根據上面 WebSocketConfig 的配置，@MessageMapping("/hello") 注解的方法將用來接收“/app/hello”路徑發送來的消息，在注解方法中對消息進行處理后，再將消息轉發到 @SendTo 定義的路徑上。而 @SendTo 路徑是一個前綴為“/topic”的路徑，因此該消息被交給消息代理 broker，再由 broker 進行廣播。
@Controller
public class DemoController {
@MessageMapping("/hello")
@SendTo("/topic/greetings")
public Message greeting(Message message) throws Exception {
return message;
}
}@Data
public class Message {
private String name;
private String content;
}四、前端代碼
在 resources/static 目錄下創建 chat.html 頁面作為聊天頁面。
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>群聊</title> <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.3.1/jquery.min.js"></script> <script src="https://cdn.bootcdn.net/ajax/libs/sockjs-client/1.1.2/sockjs.min.js"></script> <script src="https://cdn.bootcdn.net/ajax/libs/stomp.js/2.3.3/stomp.min.js"></script> <script> var stompClient = null; // 根據是否已連接設置頁面元素狀態 function setConnected(connected) { $("#connect").prop("disabled", connected); $("#disconnect").prop("disabled", !connected); if (connected) { $("#conversation").show(); $("#chat").show(); } else { $("#conversation").hide(); $("#chat").hide(); } $("#greetings").html(""); } // 建立一個WebSocket連接 function connect() { // 用戶名不能為空 if (!$("#name").val()) { return; } // 首先使用 SockJS 建立連接 var socket = new SockJS('/chat'); // 然后創建一個STOMP實例發起連接請求 stompClient = Stomp.over(socket); // 連接成功回調 stompClient.connect({}, function (frame) { // 進行頁面設置 setConnected(true); // 訂閱服務端發送回來的消息 stompClient.subscribe('/topic/greetings', function (greeting) { // 將服務端發送回來的消息展示出來 showGreeting(JSON.parse(greeting.body)); }); }); } // 斷開WebSocket連接 function disconnect() { if (stompClient !== null) { stompClient.disconnect(); } setConnected(false); } // 發送消息 function sendName() { stompClient.send("/app/hello", {}, JSON.stringify({'name': $("#name").val(),'content':$("#content").val()})); } // 將服務端發送回來的消息展示出來 function showGreeting(message) { $("#greetings") .append("<div>" + message.name+":"+message.content + "</div>"); } // 頁面加載后進行初始化動作 $(function () { $( "#connect" ).click(function() { connect(); }); $( "#disconnect" ).click(function() { disconnect(); }); $( "#send" ).click(function() { sendName(); }); }); </script> </head> <body> <div> <label for="name">請輸入用戶名：</label> <input type="text" id="name" placeholder="用戶名"> </div> <div> <button id="connect" type="button">連接</button> <button id="disconnect" type="button" disabled="disabled">斷開連接</button> </div> <div id="chat" > <div> <label for="name">請輸入聊天內容：</label> <input type="text" id="content" placeholder="聊天內容"> </div> <button id="send" type="button">發送</button> <div id="greetings"> <div id="conversation" >群聊進行中...</div> </div> </div> </body> </html>
SockJS 是一個瀏覽器JavaScript庫，提供類似于WebSocket的對象。SockJS為您提供了一個一致的，跨瀏覽器的Javascript API，該API在瀏覽器和Web服務器之間創建了低延遲，全雙工，跨域的通信通道。
STOMP 即Simple (or Streaming) Text Orientated Messaging Protocol，簡單(流)文本定向消息協議，它提供了一個可互操作的連接格式，允許STOMP客戶端與任意STOMP消息代理（Broker）進行交互。
@SendTo 注解，該注解將方法處理過的消息轉發到 broker，再由 broker 進行消息廣播。
五、驗證結果
我們請求地址：http://127.0.0.1:8086/chat.html
登錄用戶：piao
登錄用戶：admin
看完了這篇文章，相信你對“SpringBoot如何使用WebSocket實現群發消息”有了一定的了解，如果想了解更多相關知識，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
