當前位置: 妍妍網 > 碼農

你還在使用 WebSocket 實作即時訊息推播嗎?

2024-05-24碼農

來源:juejin.cn/post/7325730345840066612

👉 歡迎 ,你將獲得: 專屬的計畫實戰 / Java 學習路線 / 一對一提問 / 學習打卡 / 每月贈書

新計畫: 仿小紅書 (微服務架構)正在更新中... , 全棧前後端分離部落格計畫 2.0 版本完結啦, 演示連結 http://116.62.199.48/ 。全程手摸手,後端 + 前端全棧開發,從 0 到 1 講解每個功能點開發步驟,1v1 答疑,直到計畫上線。 目前已更新了261小節,累計41w+字,講解圖:1806張,還在持續爆肝中.. 後續還會上新更多計畫,目標是將Java領域典型的計畫都整一波,如秒殺系統, 線上商城, IM即時通訊,Spring Cloud Alibaba 等等,

  • 伺服端向客戶端推播數據的實作方案有哪幾種?

  • 輪詢簡介

  • websocket簡介

  • SSE簡介

  • websocket和SSE有什麽區別?

  • 輪詢

  • Websocket和SSE

  • Websocket和SSE分別適用於什麽業務場景?

  • SSE有哪些主要的API?

  • SSE連線狀態

  • SSE相關事件

  • 數據格式

  • 如何實操一個SSE連結?Demo↓

  • 前端程式碼Demo

  • 後端程式碼Demo(node的express)

  • 總結

  • 在日常的開發中,我們經常能碰見伺服端需要主動推播給客戶端數據的業務場景,比如數據大屏的即時數據,比如訊息中心的未讀訊息,比如聊天功能等等。

    本文主要介紹SSE的使用場景和如何使用SSE。

    圖片

    伺服端向客戶端推播數據的實作方案有哪幾種?

    我們常規實作這些需求的方案有以下三種

  • 輪詢

  • websocket

  • SSE

  • 輪詢簡介

    在很久很久以前,前端一般使用輪詢來進行伺服端向客戶端進行訊息的偽推播,為什麽說輪詢是偽推播?因為輪詢本質上還是透過客戶端向伺服端發起一個單項傳輸的請求,伺服端對這個請求做出響應而已。透過不斷的請求來實作伺服端向客戶端推播數據的錯覺。並不是伺服端主動向客戶端推播數據。

    顯然,輪詢一定是上述三個方法裏最下策的決定。

    輪詢的缺點:

  • 首先輪詢需要不斷的發起請求,每一個請求都需要經過http建立連線的流程(比如三次握手,四次揮手),是沒有必要的消耗。

  • 客戶端需要從頁面被開啟的那一刻開始就一直處理請求。雖然每次輪詢的消耗不大,但是一直處理請求對於客戶端來說一定是不友好的。

  • 瀏覽器請求並行是有限制的。比如Chrome 最大並行請求數目為 6,這個限制還有一個前提是針對同一網域名稱的,超過這一限制的後續請求將會被阻塞。而輪詢意味著會有一個請求長時間的占用並行名額。

  • 而如果輪詢時間較長,可能又沒有辦法非常及時的獲取數據

  • websocket簡介

    websocket是一個雙向通訊的協定,他的優點是,可以同時支持客戶端和伺服端彼此相互進行通訊。功能上很強大。

    缺點也很明顯,websocket是一個新的協定,ws/wss。也就是說,支持http協定的瀏覽器不一定支持ws協定。

    相較於SSE來說,websocket因為功能更強大。結構更復雜。所以相對比較重。

    websocket對於各大瀏覽器的相容性↓

    圖片

    SSE簡介

    sse是一個單向通訊的協定也是一個長連結,它只能支持伺服端主動向客戶端推播數據,但是無法讓客戶端向伺服端推播訊息。

    長連結是一種HTTP/1.1的持久連線技術,它允許客戶端和伺服器在一次TCP連線上進行多個HTTP請求和響應,而不必為每個請求/響應建立和斷開一個新的連線。長連線有助於減少伺服器的負載和提高效能。

    SSE的優點是,它是一個輕量級的協定,相對於websockte來說,他的復雜度就沒有那麽高,相對於客戶端的消耗也比較少。而且SSE使用的是http協定(websocket使用的是ws協定),也就是現有的伺服端都支持SSE,無需像websocket一樣需要伺服端提供額外的支持。

    註意:IE大魔王不支持SSE

    SSE對於各大瀏覽器的相容性↓

    圖片

    註意哦,上圖是SSE對於瀏覽器的相容不是對於伺服端的相容。

    websocket和SSE有什麽區別?

    輪詢

    對於當前電腦的發展來說,幾乎很少出現同時不支持websocket和sse的情況,所以輪詢是在極端情況下瀏覽器實在是不支持websocket和see的下策。

    Websocket和SSE

    我們一般的伺服端和客戶端的通訊基本上使用這兩個方案。首先聲明:這兩個方案沒有絕對的好壞,只有在不同的業務場景下更好的選擇。

    SSE的官方對於SSE和Websocket的評價是

  • WebSocket是全雙工通道,可以雙向通訊,功能更強;SSE是單向通道,只能伺服器向瀏覽器端發送。

  • WebSocket是一個新的協定,需要伺服器端支持;SSE則是部署在HTTP協定之上的,現有的伺服器軟體都支持。

  • SSE是一個輕量級協定,相對簡單;WebSocket是一種較重的協定,相對復雜。

  • SSE預設支持斷線重連,WebSocket則需要額外部署。

  • SSE支持自訂發送的數據型別。

  • Websocket和SSE分別適用於什麽業務場景?

    對於SSE來說,它的優點就是輕,而且對於伺服端的支持度要更好。換言之,可以使用SSE完成的功能需求,沒有必要使用更重更復雜的websocket。

    比如:數據大屏的即時數據,訊息中心的訊息推播等一系列只需要伺服端單方面推播而不需要客戶端同時進行反饋的需求,SSE就是不二之選。

    對於Websocket來說,他的優點就是可以同時支持客戶端和伺服端的雙向通訊。所適用的業務場景:最典型的就是聊天功能。這種伺服端需要主動向客戶端推播資訊,並且客戶端也有向伺服端推播訊息的需求時,Websocket就是更好的選擇。

    SSE有哪些主要的API?

    建立一個SSE連結 : var source = new EventSource(url);

    SSE連線狀態

    source.readyState

  • 0,相當於常量EventSource.CONNECTING,表示連線還未建立,或者連線斷線。

  • 1,相當於常量EventSource.OPEN,表示連線已經建立,可以接受數據。

  • 2,相當於常量EventSource.CLOSED,表示連線已斷,且不會重連。

  • SSE相關事件

  • open事件(連線一旦建立,就會觸發open事件,可以定義相應的回呼函式)

  • message事件(收到數據就會觸發message事件)

  • error事件(如果發生通訊錯誤(比如連線中斷),就會觸發error事件)

  • 數據格式

    Content-Type: text/event-stream //文本返回格式
    Cache-Control: no-cache //不要緩存
    Connection: keep-alive //長連結標識

    SSE相關文件:

    https://www.w3cschool.cn/nwfchn/wpi3cozt.html

    顯然,如果直接看api介紹不論是看這裏還是看官網,大部份同學都是比較懵圈的狀態,那麽我們寫個demo來看一下?

    我更建議您先把Demo跑起來,然後在看看上面這個w3cschool的SSE文件。兩個配合一起看,會更方便理解些。

    如何實操一個SSE連結?Demo↓

    這裏Demo前端使用的就是最基本的html靜態頁面連線,沒有使用任何框架。

    後端選用語言是node,框架是Express。

    理論上,把這兩段端程式碼復制過去跑起來就直接可以用了。

  • 第一步,建立一個index.html檔,然後復制前端程式碼Demo到index.html檔中,開啟檔

  • 第二步,進入一個新的資料夾,建立一個index.js檔,然後將後端Demo程式碼復制進去,然後在該資料夾下執行

  • npm init //初始化npm
    npm i express //下載node express框架
    node index //啟動服務

    圖片

    在這一層資料夾下執行命令。

    完成以上操作就可以把計畫跑起來了

    前端程式碼Demo

    <!DOCTYPE html>
    <html lang="en">
    <head>
    <meta charset="UTF-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Document</title>
    </head>
    <body>
    <ul id="ul">
    </ul>
    </body>
    <script>
    //生成li元素
    function createLi(data){
    let li = document.createElement("li");
    li.innerHTML = String(data.message);
    return li;
    }
    //判斷當前瀏覽器是否支持SSE
    letsource = ''
    if (!!window.EventSource) {
    source = new EventSource('http://localhost:8088/sse/');
     }else{
    throw new Error("當前瀏覽器不支持SSE")
     }
     //對於建立連結的監聽
     source.onopen = function(event) {
    console.log(source.readyState);
    console.log("長連線開啟");
     };
     //對伺服端訊息的監聽
     source.onmessage = function(event) {
    console.log(JSON.parse(event.data));
    console.log("收到長連線資訊");
    let li = createLi(JSON.parse(event.data));
    document.getElementById("ul").appendChild(li)
     };
     //對斷開連結的監聽
     source.onerror = function(event) {
    console.log(source.readyState);
    console.log("長連線中斷");
     };
    </script>
    </html>





    後端程式碼Demo(node的express)

    const express = require('express'); //參照框架
    const app = express(); //建立服務
    const port = 8088; //計畫啟動埠
    //設定跨域存取
    app.all("*"function(req, res, next) {
     //設定允許跨域的網域名稱,*代表允許任意網域名稱跨域
     res.header("Access-Control-Allow-Origin"'*');
     //允許的header型別
     res.header("Access-Control-Allow-Headers""Content-Type, Authorization, X-Requested-With");
     //跨域允許的請求方式 
     res.header("Access-Control-Allow-Methods""PUT,POST,GET,DELETE,OPTIONS");
     // 可以帶cookies
     res.header("Access-Control-Allow-Credentials"true);
    if (req.method == 'OPTIONS') {
    res.sendStatus(200);
     } else {
    next();
     }
    })
    app.get("/sse",(req,res) => {
    res.set({
    'Content-Type''text/event-stream', //設定數據型別
    'Cache-Control''no-cache',// 長連結拒絕緩存
    'Connection''keep-alive' //設定長連結
    });
    console.log("進入到長連線了")
    //持續返回數據
    setInterval(() => {
    console.log("正在持續返回數據中ing")
    const data = {
    message: `Current time is ${new Date().toLocaleTimeString()}`
    };
    res.write(`data: ${JSON.stringify(data)}\n\n`);
    }, 1000);
    })
    //建立計畫
    app.listen(port, () => {
     console.log(`計畫啟動成功-http://localhost:${port}`)
    })


    總結

  • SSE比websocket更輕

  • SSE是基於http/https協定的

  • websocket是一個新的協定,ws/wss協定

  • 如果只需要伺服端向客戶端推播訊息,推薦使用SSE

  • 如果需要伺服端和客戶端雙向推播,請選擇websocket

  • 不論是SSE還是websocket,對於瀏覽器的相容性都不錯

  • 輪詢是下策,很占用客戶端資源,不建議使用。(不過偷懶的時候他確實方便)

  • IE不支持SSE

  • 對了,小程式不支持SSE哦

    👉 歡迎 ,你將獲得: 專屬的計畫實戰 / Java 學習路線 / 一對一提問 / 學習打卡 / 每月贈書

    新計畫: 仿小紅書 (微服務架構)正在更新中... , 全棧前後端分離部落格計畫 2.0 版本完結啦, 演示連結 http://116.62.199.48/ 。全程手摸手,後端 + 前端全棧開發,從 0 到 1 講解每個功能點開發步驟,1v1 答疑,直到計畫上線。 目前已更新了261小節,累計41w+字,講解圖:1806張,還在持續爆肝中.. 後續還會上新更多計畫,目標是將Java領域典型的計畫都整一波,如秒殺系統, 線上商城, IM即時通訊,Spring Cloud Alibaba 等等,


    1. 

    2. 

    3. 

    4. 

    最近面試BAT,整理一份面試資料Java面試BATJ通關手冊,覆蓋了Java核心技術、JVM、Java並行、SSM、微服務、資料庫、數據結構等等。

    獲取方式:點「在看」,關註公眾號並回復 Java 領取,更多內容陸續奉上。

    PS:因公眾號平台更改了推播規則,如果不想錯過內容,記得讀完點一下在看,加個星標,這樣每次新文章推播才會第一時間出現在你的訂閱列表裏。

    「在看」支持小哈呀,謝謝啦