這篇文章主要介紹了SpringBoot怎么使用WebSocket實(shí)現(xiàn)群發(fā)消息的相關(guān)知識(shí)，內(nèi)容詳細(xì)易懂，操作簡(jiǎn)單快捷，具有一定借鑒價(jià)值，相信大家閱讀完這篇SpringBoot怎么使用WebSocket實(shí)現(xiàn)群發(fā)消息文章都會(huì)有所收獲，下面我們一起來(lái)看看吧。

梅江網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)建站！從網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、成都響應(yīng)式網(wǎng)站建設(shè)公司等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)建站2013年至今到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來(lái)保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)建站。

WebSocket 是一種在單個(gè) TCP 連接上進(jìn)行全雙工通信的協(xié)議，已被 W3C 定為標(biāo)準(zhǔn)。使用 WebSocket 可以使得客戶端和服務(wù)器之間的數(shù)據(jù)交換變得更加簡(jiǎn)單。在 WebSocket 協(xié)議中，瀏覽器和服務(wù)器只需要完成一次握手，兩者之間就可以直接創(chuàng)建持久性的連接，并進(jìn)行雙向數(shù)據(jù)傳輸。

特點(diǎn)

• WebSocket 使用時(shí)需要先創(chuàng)建連接，這使得 Websocket 成為一種有狀態(tài)的協(xié)議，在之后的通信過(guò)程中可以省略部分狀態(tài)信息（例如身份認(rèn)證等）。

• WebSocket 連接在端口 80（ws）或者 443（wss）上創(chuàng)建，與 HTTP 使用的端口相同，這樣，基本上所有的防火墻都不會(huì)阻止 WebSocket 連接。

• WebSocket 使用 HTTP 協(xié)議進(jìn)行握手，因此它可以自然而然地集成到網(wǎng)絡(luò)瀏覽器和 HTTP 服務(wù)器中，而不需要額外的成本。

• 心跳消息（ping 和 pong）將被反復(fù)的發(fā)送，進(jìn)而保持 WebSocket 連接一直處于活躍狀態(tài)。

• 使用該協(xié)議，當(dāng)消息啟動(dòng)或者到達(dá)的時(shí)候，服務(wù)端和客戶端都可以知道。

• WebSocket 連接關(guān)閉時(shí)將發(fā)送一個(gè)特殊的關(guān)閉消息。

• WebSocket 支持跨域，可以避免 Ajax 的限制。

• HTTP 規(guī)范要求瀏覽器將并發(fā)連接數(shù)限制為每個(gè)主機(jī)名兩個(gè)連接，但是當(dāng)我們使用 Websocket 的時(shí)候，當(dāng)握手完成之后，該限制就不存在了，因?yàn)榇藭r(shí)的連接已經(jīng)不再是 HTTP 連接了。

• WebSocket 協(xié)議支持?jǐn)U展，用戶可以擴(kuò)展協(xié)議，實(shí)現(xiàn)部分自定義的子協(xié)議。

• WebSocket 擁有更好的二進(jìn)制支持以及更好的壓縮效果。

一、添加依賴

    org.springframework.boot
    spring-boot-starter-websocket

二、配置 WebSocket

Spring 框架提供了基于 WebSocket 的 STOMP 支持，STOMP 是一個(gè)簡(jiǎn)單的可互操作的協(xié)議，通常被用于通過(guò)中間服務(wù)器在客戶端之間進(jìn)行異步消息傳遞。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
 
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 設(shè)置消息代理的前綴，如果消息的前綴為"/topic"，就會(huì)將消息轉(zhuǎn)發(fā)給消息代理（broker）
        // 再由消息代理廣播給當(dāng)前連接的客戶端
        config.enableSimpleBroker("/topic");
        // 下面方法可以配置一個(gè)或多個(gè)前綴，通過(guò)這些前綴過(guò)濾出需要被注解方法處理的消息。
        // 例如這里表示前綴為"/app"的destination可以通過(guò)@MessageMapping注解的方法處理
        // 而其他 destination（例如"/topic""/queue"）將被直接交給 broker 處理
        config.setApplicationDestinationPrefixes("/app");
    }
 
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        // 定義一個(gè)前綴為"/chart"的endpoint，并開啟 sockjs 支持。
        // sockjs 可以解決瀏覽器對(duì)WebSocket的兼容性問(wèn)題，客戶端將通過(guò)這里配置的URL建立WebSocket連接
        registry.addEndpoint("/chat").withSockJS();
    }
}

三、服務(wù)端代碼

根據(jù)上面 WebSocketConfig 的配置，@MessageMapping("/hello") 注解的方法將用來(lái)接收“/app/hello”路徑發(fā)送來(lái)的消息，在注解方法中對(duì)消息進(jìn)行處理后，再將消息轉(zhuǎn)發(fā)到 @SendTo 定義的路徑上。而 @SendTo 路徑是一個(gè)前綴為“/topic”的路徑，因此該消息被交給消息代理 broker，再由 broker 進(jìn)行廣播。

@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 目錄下創(chuàng)建 chat.html 頁(yè)面作為聊天頁(yè)面。

    
    
    
    
    
    



    請(qǐng)輸入用戶名：
    


    連接
    斷開連接


    

        請(qǐng)輸入聊天內(nèi)容：
        
    
    發(fā)送
    
        群聊進(jìn)行中...