国产高清在线免费观看-国产高清在线免费无码-国产高清在线男人的天堂-国产高清在线视频-国产高清在线视频精品视频-国产高清在线视频伊甸园

LOGO OA教程 ERP教程 模切知識交流 PMS教程 CRM教程 開發(fā)文檔 其他文檔  
 
網(wǎng)站管理員

你還在使用websocket實(shí)現(xiàn)實(shí)時消息推送嗎?

admin
2025年4月26日 11:55 本文熱度 197

作者:工邊頁字

https://juejin.cn/post/7325730345840066612


前言

在日常的開發(fā)中,我們經(jīng)常能碰見服務(wù)端需要主動推送給客戶端數(shù)據(jù)的業(yè)務(wù)場景,比如數(shù)據(jù)大屏的實(shí)時數(shù)據(jù),比如消息中心的未讀消息,比如聊天功能等等。

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

服務(wù)端向客戶端推送數(shù)據(jù)的實(shí)現(xiàn)方案有哪幾種?

我們常規(guī)實(shí)現(xiàn)這些需求的方案有以下三種:

  1. 輪詢
  2. websocket
  3. SSE


輪詢簡介

在很久很久以前,前端一般使用輪詢來進(jìn)行服務(wù)端向客戶端進(jìn)行消息的偽推送,為什么說輪詢是偽推送?因?yàn)檩喸儽举|(zhì)上還是通過客戶端向服務(wù)端發(fā)起一個單項(xiàng)傳輸?shù)恼埱螅?wù)端對這個請求做出響應(yīng)而已。

通過不斷的請求來實(shí)現(xiàn)服務(wù)端向客戶端推送數(shù)據(jù)的錯覺。并不是服務(wù)端主動向客戶端推送數(shù)據(jù)。顯然,輪詢一定是上述三個方法里最下策的決定。


輪詢的缺點(diǎn):

  1. 首先輪詢需要不斷的發(fā)起請求,每一個請求都需要經(jīng)過http建立連接的流程(比如三次握手,四次揮手),是沒有必要的消耗。
  2. 客戶端需要從頁面被打開的那一刻開始就一直處理請求。雖然每次輪詢的消耗不大,但是一直處理請求對于客戶端來說一定是不友好的。
  3. 瀏覽器請求并發(fā)是有限制的。比如Chrome 最大并發(fā)請求數(shù)目為 6,這個限制還有一個前提是針對同一域名的,超過這一限制的后續(xù)請求將會被阻塞。而輪詢意味著會有一個請求長時間的占用并發(fā)名額。
  4. 而如果輪詢時間較長,可能又沒有辦法非常及時的獲取數(shù)據(jù)


websocket簡介

websocket是一個雙向通訊的協(xié)議,他的優(yōu)點(diǎn)是,可以同時支持客戶端和服務(wù)端彼此相互進(jìn)行通訊。功能上很強(qiáng)大。

缺點(diǎn)也很明顯,websocket是一個新的協(xié)議,ws/wss。也就是說,支持http協(xié)議的瀏覽器不一定支持ws協(xié)議。

相較于SSE來說,websocket因?yàn)楣δ芨鼜?qiáng)大。結(jié)構(gòu)更復(fù)雜。所以相對比較重。

websocket對于各大瀏覽器的兼容性↓


?

SSE簡介

sse是一個單向通訊的協(xié)議也是一個長鏈接,它只能支持服務(wù)端主動向客戶端推送數(shù)據(jù),但是無法讓客戶端向服務(wù)端推送消息。

長鏈接是一種HTTP/1.1的持久連接技術(shù),它允許客戶端和服務(wù)器在一次TCP連接上進(jìn)行多個HTTP請求和響應(yīng),而不必為每個請求/響應(yīng)建立和斷開一個新的連接,長連接有助于減少服務(wù)器的負(fù)載和提高性能。

SSE的優(yōu)點(diǎn)是,它是一個輕量級的協(xié)議,相對于websockte來說,他的復(fù)雜度就沒有那么高,相對于客戶端的消耗也比較少。而且SSE使用的是http協(xié)議(websocket使用的是ws協(xié)議),也就是現(xiàn)有的服務(wù)端都支持SSE,無需像websocket一樣需要服務(wù)端提供額外的支持。

注意:IE大魔王不支持SSE

SSE對于各大瀏覽器的兼容性↓


注意哦,上圖是SSE對于瀏覽器的兼容不是對于服務(wù)端的兼容。

websocket和SSE有什么區(qū)別?

輪詢

對于當(dāng)前計(jì)算機(jī)的發(fā)展來說,幾乎很少出現(xiàn)同時不支持websocket和sse的情況,所以輪詢是在極端情況下瀏覽器實(shí)在是不支持websocket和see的下策。

Websocket和SSE

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

SSE的官方對于SSE和Websocket的評價是:

  1. WebSocket是全雙工通道,可以雙向通信,功能更強(qiáng);SSE是單向通道,只能服務(wù)器向?yàn)g覽器端發(fā)送。

  2. WebSocket是一個新的協(xié)議,需要服務(wù)器端支持;SSE則是部署在HTTP協(xié)議之上的,現(xiàn)有的服務(wù)器軟件都支持。

  3. SSE是一個輕量級協(xié)議,相對簡單;WebSocket是一種較重的協(xié)議,相對復(fù)雜。

  4. SSE默認(rèn)支持?jǐn)嗑€重連,WebSocket則需要額外部署。

  5. SSE支持自定義發(fā)送的數(shù)據(jù)類型。

Websocket和SSE分別適用于什么業(yè)務(wù)場景?

對于SSE來說,它的優(yōu)點(diǎn)就是輕,而且對于服務(wù)端的支持度要更好。換言之,可以使用SSE完成的功能需求,沒有必要使用更重更復(fù)雜的websocket。

比如:數(shù)據(jù)大屏的實(shí)時數(shù)據(jù),消息中心的消息推送等一系列只需要服務(wù)端單方面推送而不需要客戶端同時進(jìn)行反饋的需求,SSE就是不二之選。

對于Websocket來說,他的優(yōu)點(diǎn)就是可以同時支持客戶端和服務(wù)端的雙向通訊。所適用的業(yè)務(wù)場景:最典型的就是聊天功能。這種服務(wù)端需要主動向客戶端推送信息,并且客戶端也有向服務(wù)端推送消息的需求時,Websocket就是更好的選擇。


SSE有哪些主要的API?


建立一個SSE鏈接 :var source = new EventSource(url);

SSE連接狀態(tài)

source.readyState

  • 0,相當(dāng)于常量EventSource.CONNECTING,表示連接還未建立,或者連接斷線。

  • 1,相當(dāng)于常量EventSource.OPEN,表示連接已經(jīng)建立,可以接受數(shù)據(jù)。

  • 2,相當(dāng)于常量EventSource.CLOSED,表示連接已斷,且不會重連。


SSE相關(guān)事件

  • open事件(連接一旦建立,就會觸發(fā)open事件,可以定義相應(yīng)的回調(diào)函數(shù))

  • message事件(收到數(shù)據(jù)就會觸發(fā)message事件)

  • error事件(如果發(fā)生通信錯誤(比如連接中斷),就會觸發(fā)error事件)

數(shù)據(jù)格式

Content-Type: text/event-stream //文本返回格式Cache-Control: no-cache  //不要緩存Connection: keep-alive //長鏈接標(biāo)識

SSE相關(guān)文檔:.w3cschool.cn/nwfchn/wpi3cozt.html

顯然,如果直接看api介紹不論是看這里還是看官網(wǎng),大部分同學(xué)都是比較懵圈的狀態(tài),那么我們寫個demo來看一下?

如何實(shí)操一個SSE鏈接?Demo↓

這里Demo前端使用的就是最基本的html靜態(tài)頁面連接,沒有使用任何框架。后端選用語言是node,框架是Express。

理論上,把這兩段端代碼復(fù)制過去跑起來就直接可以用了。

  1. 第一步,建立一個index.html文件,然后復(fù)制前端代碼Demo到index.html文件中,打開文件

  2. 第二步,進(jìn)入一個新的文件夾,建立一個index.js文件,然后將后端Demo代碼復(fù)制進(jìn)去,然后在該文件夾下執(zhí)行

npm init          //初始化npm       npm i express     //下載node express框架node index        //啟動服務(wù)


在這一層文件夾下執(zhí)行命令。

完成以上操作就可以把項(xiàng)目跑起來了。

前端代碼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;}    //判斷當(dāng)前瀏覽器是否支持SSE  let source = '' if (!!window.EventSource) {    source = new EventSource('http://localhost:8088/sse/'); }else{    throw new Error("當(dāng)前瀏覽器不支持SSE") }
 //對于建立鏈接的監(jiān)聽 source.onopen = function(event) {   console.log(source.readyState);   console.log("長連接打開"); };
 //對服務(wù)端消息的監(jiān)聽 source.onmessage = function(event) {   console.log(JSON.parse(event.data));   console.log("收到長連接信息");   let li = createLi(JSON.parse(event.data));   document.getElementById("ul").appendChild(li) };
 //對斷開鏈接的監(jiān)聽 source.onerror = function(event) {   console.log(source.readyState);   console.log("長連接中斷"); };</script></html>

后端代碼Demo(node的express)

const express = require('express'); //引用框架const app = express(); //創(chuàng)建服務(wù)const port = 8088//項(xiàng)目啟動端口
//設(shè)置跨域訪問app.all("*"function(req, res, next) {  //設(shè)置允許跨域的域名,*代表允許任意域名跨域  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'//設(shè)定數(shù)據(jù)類型        'Cache-Control''no-cache',// 長鏈接拒絕緩存        'Connection''keep-alive' //設(shè)置長鏈接      });
      console.log("進(jìn)入到長連接了")      //持續(xù)返回?cái)?shù)據(jù)      setInterval(() => {        console.log("正在持續(xù)返回?cái)?shù)據(jù)中ing")        const data = {          message`Current time is ${new Date().toLocaleTimeString()}`        };        res.write(`data: ${JSON.stringify(data)}\n\n`);      }, 1000);  })
//創(chuàng)建項(xiàng)目app.listen(port, () => {  console.log(`項(xiàng)目啟動成功-http://localhost:${port}`)})

效果


總結(jié)

  1. SSE比websocket更輕

  2. SSE是基于http/https協(xié)議的

  3. websocket是一個新的協(xié)議,ws/wss協(xié)議

  4. 如果只需要服務(wù)端向客戶端推送消息,推薦使用SSE

  5. 如果需要服務(wù)端和客戶端雙向推送,請選擇websocket

  6. 不論是SSE還是websocket,對于瀏覽器的兼容性都不錯

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

  8. IE不支持SSE


對了,小程序不支持SSE哦


閱讀原文:原文鏈接


該文章在 2025/4/27 9:26:49 編輯過
關(guān)鍵字查詢
相關(guān)文章
正在查詢...
點(diǎn)晴ERP是一款針對中小制造業(yè)的專業(yè)生產(chǎn)管理軟件系統(tǒng),系統(tǒng)成熟度和易用性得到了國內(nèi)大量中小企業(yè)的青睞。
點(diǎn)晴PMS碼頭管理系統(tǒng)主要針對港口碼頭集裝箱與散貨日常運(yùn)作、調(diào)度、堆場、車隊(duì)、財(cái)務(wù)費(fèi)用、相關(guān)報(bào)表等業(yè)務(wù)管理,結(jié)合碼頭的業(yè)務(wù)特點(diǎn),圍繞調(diào)度、堆場作業(yè)而開發(fā)的。集技術(shù)的先進(jìn)性、管理的有效性于一體,是物流碼頭及其他港口類企業(yè)的高效ERP管理信息系統(tǒng)。
點(diǎn)晴WMS倉儲管理系統(tǒng)提供了貨物產(chǎn)品管理,銷售管理,采購管理,倉儲管理,倉庫管理,保質(zhì)期管理,貨位管理,庫位管理,生產(chǎn)管理,WMS管理系統(tǒng),標(biāo)簽打印,條形碼,二維碼管理,批號管理軟件。
點(diǎn)晴免費(fèi)OA是一款軟件和通用服務(wù)都免費(fèi),不限功能、不限時間、不限用戶的免費(fèi)OA協(xié)同辦公管理系統(tǒng)。
Copyright 2010-2025 ClickSun All Rights Reserved

主站蜘蛛池模板: 一本色道久久综合亚 | 无码人妻丰满熟妇奶水区码 | 亚洲av鲁丝一区二区三区黄 | 精品欧美一区二区在线观看 | 亚洲av丰满熟妇在线播放 | 久久亚洲精精品中文字幕 | 亚洲午夜无码毛片AV久久久久久 | 国产视频一区在线免费看 | 国产精品亚洲二区在线观看 | 中国亚州女人69内射少妇 | 午夜精品一区二区 | 亚洲综合久久一区二区不卡 | 四虎影视免费在线观看 | 国产色情一区二区不卡毛片 | 亚洲av无码久久 | 少妇高潮惨叫久久久久久 | 丝袜自慰一区二 | 亚洲午夜久久久影院伊人 | 精品人妻无码区在线视频 | 国产精品扒开腿做爽爽爽A片软件 | 亚洲中文乱码免费一区二区三区 | 欧美色图一区二区三区 | 亚洲区区图片区qvod | 亚洲av日韩综合一区二区三区 | 亚洲av无码精品无码麻豆 | 欧美日韩亚洲另类一区二区 | 少妇被躁爽到高潮无码人狍大战 | 国产综合精品久久久久成人影 | 99久久精品费精品国产 | 国产午夜片无码区在线观看 | 麻豆精品免费在线观看 | 囯产精品一区二区三区乱码 | 亚洲无人区码一码二码三码四码 | 午夜私人影院免费体验区 | 中文字幕无码精品亚洲资源网 | 亚洲国产在线二区三区 | 亚洲国产精品无码一区二区三区 | 国产精品v欧美精品观看 | 综合色天天鬼久久鬼色 | 国产日产精品久久久久 | 亚洲日韩精品一区二区三区无码 |