WebSocket:實現(xiàn)實時雙向數(shù)據(jù)傳輸?shù)腤eb通信協(xié)議

2023-12-25    前端達人

 

前言

在當今互聯(lián)網(wǎng)時代,實時通信已成為很多應用的需求。為了滿足這種需求,WebSocket協(xié)議被設計出來。WebSocket是一種基于TCP議的全雙工通信協(xié)議,通過WebSocket,Web應用程序可以與服務器建立持久的連接,實現(xiàn)實時雙向數(shù)據(jù)輸,提供極低的延遲和高效的數(shù)據(jù)傳輸。


WebSocket原理

  • HTTP請求-響應協(xié)議

在理解WebSocket原理之前,我們需要了解HTTP請求-響應協(xié)議。HTTP是一種無狀態(tài)的請求-響應協(xié)議,客戶端通過發(fā)送HTTP請求到服務器,服務器接收并處理請求,并返回HTTP響應給客戶端。但是,在傳統(tǒng)的HTTP協(xié)議中,客戶端只能發(fā)送請求,而服務器只能通過響應來處理客戶端的請求。

  • WebSocket協(xié)議

WebSocket協(xié)議是在HTTP協(xié)議的基礎上進行擴展的。在建立WebSocket連接時,客戶端首先發(fā)送一個HTTP請求到服務器,并將Upgrade頭部字段設置為"websocket",表示希望升級到WebSocket協(xié)議。服務器接收到這個請求后,如果支持WebSocket協(xié)議,會返回一個狀態(tài)碼101 Switching Protocols的HTTP響應,并通過Upgrade頭部字段將連接升級為WebSocket連接。

升級完成后,客戶端和服務器之間的通信不再遵循HTTP請求-響應模式,而是通過WebSocket協(xié)議進行雙向的實時通信??蛻舳撕头掌骺梢灾苯影l(fā)送消息給對方,不需要等待對方的請求。


如何使用WebSocket

建立WebSocket連接:

要建立WebSocket連接,需要在客戶端和服務器之間進行系列的握手操作。下面是詳細的代碼教程,示了如何在Web應用程序中建立WebSocket連接。

在戶端(JavaScript):

// 創(chuàng)建WebSocket對象并指定服務器地址
var socket = new WebSocket("ws://example.com/socket");

// 監(jiān)聽連接建立事件
socket.onopen = function() {
console.log("WebSocket連接已建立");
// 在連接建立后,可以發(fā)送消息到服務器
socket.send("Hello Server!");
};


// 監(jiān)聽接收到服務器發(fā)送的消息
socket.onmessage = function(event) {
var message = event.data;
console.log("接收到服務器發(fā)送的消息:" + message);
};


// 監(jiān)聽連接關閉事件
socket.onclose = function(event) {
console.log("WebSocket連接已關閉");
};


// 監(jiān)聽連接錯誤事件
socket.onerror = function(event) {
console.error("WebSocket連接錯誤:" + event};

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24

在服務器端(示例使用Node.js):

const WebSocket = require("ws");

// 創(chuàng)建WebSocket服務器
const wss = new WebSocket.Server({ port: 8080 });


// 監(jiān)聽連接建立事件
wss.on("connection", function(socket) {
console.log("WebSocket連接已建立");


// 監(jiān)聽接收到客戶端發(fā)送的消息
socket.on("message", function(message) {
console.log("接收到戶端發(fā)送的消息:" + message);


<span class="token comment">// 向客戶端發(fā)送消息</span>
socket<span class="token punctuation">.</span><span class="token function">send</span><span class="token punctuation">(</span><span class="token string">"Hello Client!"</span><span class="token punctuation">)</span><span class="token punctuation">;</span>

});


// 監(jiān)聽連接關閉事件
socket.on("close", function() {
console.log("WebSocket連接已關閉");
});
});

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22

在以上代碼中,客戶端通過創(chuàng)建WebSocket對象,并指定服務器地址"ws://example.com/socket"來建立WebSocket連接。同時,客戶端通過監(jiān)聽onopen事件,可以在連接建立后發(fā)送消息到服務器。服務器端使用WebSocket.Server類創(chuàng)建WebSocket服務器,并監(jiān)聽"connection事件來處理連接建立后的操作。服務器端通過socket.on(“message”)來監(jiān)聽接收到客戶端發(fā)送的消息,并通過socket.send()向客戶端發(fā)送消息。

數(shù)據(jù)傳輸:

建立WebSocket連接后,客戶端和服務器可以通過WebSocket對象進行雙向的實時數(shù)據(jù)傳輸。下面是一個示例代碼,演示了如何在客戶端和服務器之間進行數(shù)據(jù)傳輸。

在客戶端(JavaScript):

// 發(fā)送消息到服務器
socket.send("Hello Server!");

// 監(jiān)聽接收到服務器發(fā)送的消息
socket.onmessage = function(event) {
var message = event.data;
console.log("接收到服務器發(fā)送的消息:" + message);
};

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

在服務器端(示例使用Node.js):

// 向客戶端發(fā)送消息
socket.send("Hello Client!");

// 監(jiān)聽接收到客戶端發(fā)送的消息
socket.on("message", function(message) {
console.log("接收到客戶端發(fā)送的消息:" + message);
});

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7

在以上代碼中,客戶端通過調用socket.send()方法將消息發(fā)送到服務器,服務器通過socket.send()方法將消息發(fā)送到客戶端??蛻舳送ㄟ^監(jiān)聽socket.onmessage事件來接收服務器發(fā)送的消息,服務器通過監(jiān)聽socket.on("message")事件來接收客戶端發(fā)送的消息。

通過以上代碼示例,你可以詳細了解如何使用WebSocket建立連接并進行數(shù)據(jù)傳輸。請注意,示例代碼中使用的服務器地址和端口號需要根據(jù)實際情況進行修改。同時,你還可以在具體應用中根據(jù)需要使用WebSocket的其他方法和事件來實現(xiàn)更復雜的功能。


WebSocket的真實使用場景

即時通訊:

WebSocket非常適合用于即時通訊應用,因為它能夠實現(xiàn)實時雙向通信。以下是一個簡單的即時聊天應用的代碼教程。

在客戶端(JavaScript):

// 創(chuàng)建WebSocket對象并指定服務器地址
var socket = new WebSocket("ws://example.com/socket");

// 監(jiān)聽連接建立事件
socket.onopen = function() {
console.log("WebSocket連接已建立");


// 監(jiān)聽文本框輸入,按下Enter鍵時發(fā)送消息
var input = document.getElementById("input");
input.addEventListener("keyup", function(event) {
if (event.keyCode === 13) {
var message = input.value;
socket.send(message);
input.value = "";
}
});
};


// 監(jiān)聽接收到服務器發(fā)送的消息
socket.onmessage = function(event) {
var message = event.data;
console.log("接收到服務器發(fā)送的消息:" + message);


// 將接收到的消息顯示在聊天窗口中
var chatWindow = document.getElementById("chatWindow");
chatWindow.innerHTML += "<p>" + message + "</p>";
};


// 監(jiān)聽連接關閉事件
socket.onclose = function(event) {
console.log("WebSocket連接已關閉");
};


// 監(jiān)聽連接錯誤事件
socket.onerror = function(event) {
console.error("WebSocket連接錯誤:" + event};

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36

在服務器端(示例使用Node.js):

const WebSocket = require("ws");

// 創(chuàng)建WebSocket服務器
const wss = new WebSocket.Server({ port: 8080 });


// 監(jiān)聽連接建立事件
wss.on("connection", function(socket) {
console.log("WebSocket連接已建立");


// 監(jiān)聽接收到客戶端發(fā)送的消息
socket.on("message", function(message) {
console.log("接收到客戶端發(fā)送的消息:" + message);


<span class="token comment">// 向所有連接的客戶端發(fā)送消息</span>
wss<span class="token punctuation">.</span>clients<span class="token punctuation">.</span><span class="token function">forEach</span><span class="token punctuation">(</span><span class="token keyword">function</span><span class="token punctuation">(</span><span class="token parameter">client</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
  client<span class="token punctuation">.</span><span class="token function">send</span><span class="token punctuation">(</span>message<span class="token punctuation">)</span><span class="token punctuation">;</span>
<span class="token punctuation">}</span><span class="token punctuation">)</span><span class="token punctuation">;</span>

});


// 監(jiān)聽連接關閉事件
socket.on("close", function() {
console.log("WebSocket連接已關閉");
});
});

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24

在上述代碼中,客戶端通過創(chuàng)建WebSocket對象連接到服務器。輸入框中的文本框用于錄入要發(fā)送的消息,按下Enter鍵時會將消息發(fā)送給服務器。服務器接收到消息后,通過遍歷所有連接的客戶端,向每個客戶端發(fā)送消息。

這樣,多個客戶端就可以實時地進行聊天,并且所有的消息都會實時地在各個客戶端之間同步顯示。

多人協(xié)作:

WebSocket還可用于多人協(xié)作應用,讓多個用戶可以實時地協(xié)同編輯文檔或畫布。以下是一個簡單的代碼教程。

在客戶端(JavaScript):

// 創(chuàng)建WebSocket對象并指定服務器地址
var socket = new WebSocket("ws://example.com/socket");

// 監(jiān)聽連接建立事件
socket.onopen = function() {
console.log("WebSocket連接已建立");


// 監(jiān)聽文本框輸入,按下Enter鍵時發(fā)送繪畫指令
var canvas = document.getElementById("canvas");
canvas.addEventListener("mousedown", function(event) {
// 繪畫指令的數(shù)據(jù)格式可以自定義,這里使用了簡單的示例
var instruction = {
type: "draw",
position: {
x: event.clientX,
y: event.clientY
}
};
socket.send(JSON.stringify(instruction));
});
};


// 監(jiān)聽接收到服務器發(fā)送的消息
socket.onmessage = function(event) {
var message = JSON.parse(event.data);
console.log("接收到服務器發(fā)送的消息:" + message);


// 根據(jù)消息執(zhí)行相應的操作,示例中處理了繪畫指令
if (message.type === "draw") {
var canvas = document.getElementById("canvas");
var ctx = canvas.getContext("2d");
ctx.beginPath();
ctx.arc(message.position.x, message.position.y, 5, 0, 2 * Math.PI);
ctx.fill();
}
};


// 監(jiān)聽連接關閉事件
socket.onclose = function(event) {
console.log("WebSocket連接已關閉");
};


// 監(jiān)聽連接錯誤事件
socket.onerror = function(event) {
console.error("WebSocket連接錯誤:" + event};

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45

在服務器端(示例使用Node.js):

const WebSocket = require("ws");

// 創(chuàng)建WebSocket服務器
const wss = new WebSocket.Server({ port: 8080 });


// 監(jiān)聽連接建立事件
wss.on("connection", function(socket) {
console.log("WebSocket連接已建立");


// 監(jiān)聽接收到客戶端發(fā)送的消息
socket.on("message", function(message) {
console.log("接收到客戶端發(fā)送的消息:" + message);


<span class="token comment">// 向所有連接的客戶端發(fā)送消息</span>
wss<span class="token punctuation">.</span>clients<span class="token punctuation">.</span><span class="token function">forEach</span><span class="token punctuation">(</span><span class="token keyword">function</span><span class="token punctuation">(</span><span class="token parameter">client</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
  client<span class="token punctuation">.</span><span class="token function">send</span><span class="token punctuation">(</span>message<span class="token punctuation">)</span><span class="token punctuation">;</span>
<span class="token punctuation">}</span><span class="token punctuation">)</span><span class="token punctuation">;</span>

});


// 監(jiān)聽連接關閉事件
socket.on("close", function() {
console.log("WebSocket連接已關閉");
});
});

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24

在上述代碼中,客戶端通過創(chuàng)建WebSocket對象連接到服務器。當鼠標在畫布上按下時,將繪畫指令發(fā)送給服務器。服務器接收到繪畫指令后,將指令廣播給所有連接的客戶端,并在各個客戶端上進行繪畫操作。

這樣,多個用戶就可以實時地協(xié)同編輯同一個畫布或文檔,所有的繪畫指令都會即時同步在各個客戶端之間。

實時數(shù)據(jù)更新:

WebSocket還可以用于實時數(shù)據(jù)更新應用,例如股票交易應用中的實時股票價格更新。以下是一個簡單的代碼教程。

在客戶端(JavaScript):

// 創(chuàng)建WebSocket對象并指定服務器地址
var socket = new WebSocket("鏈接");

// 監(jiān)聽連接建立事件
socket.onopen = function() {
console.log("WebSocket連接已建立");
};


// 監(jiān)聽接收到服務器發(fā)送的消息
socket.onmessage = function(event) {
var message = JSON.parse(event.data);
console.log("接收到服務器發(fā)送的消息:" + message);


// 對接收到的實時數(shù)據(jù)進行處理
var stockPriceElement = document.getElementById("stockPrice");
stockPriceElement.innerText = message.price;
};


// 監(jiān)聽連接關閉事件
socket.onclose = function(event) {
console.log("WebSocket連接已關閉");
};


// 監(jiān)聽連接錯誤事件
socket.onerror = function(event) {
console.error("WebSocket連接錯誤:" + event};

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26

在服務器端(示例使用Node.js):

const WebSocket = require("ws");

// 創(chuàng)建WebSocket服務器
const wss = new WebSocket.Server({ port: 8080 });


// 模擬實時股票價格更新
setInterval(function() {
var stockPrice = Math.random() * 100;


// 向所有連接的客戶端發(fā)送實時數(shù)據(jù)
wss.clients.forEach(function(client) {
var data = {
price: stockPrice
};
client.send(JSON.stringify(data));
});
}, 2000);


// 監(jiān)聽連接建立事件
wss.on("connection", function(socket) {
console.log("WebSocket連接已建立");


// 初始化發(fā)送實時數(shù)據(jù)
var stockPrice = Math.random() * 100;
var data = {
price: stockPrice
};
socket.send(JSON.stringify(data));


// 監(jiān)聽連接關閉事件
socket.on("close", function() {
console.log("WebSocket連接已關閉");
});
});

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34

在上述代碼中,客戶端通過創(chuàng)建WebSocket對象連接服務器。服務器使用setInterval函數(shù)模擬實時股票價格的更新,并將更新的數(shù)據(jù)發(fā)送給所有連接的客戶端??蛻舳吮O(jiān)聽接收到服務器發(fā)送的消息,并處理接收到的實時數(shù)據(jù)。

這樣,在股票交易應用中,多個用戶可以實時地接收和顯示股票價格的更新信息。包括打游戲的時候,隊友之間互相溝通,打字交流,或者走位,放技能等等,都是即時的。


WebSocket的優(yōu)勢與局限性

  • WebSocket的優(yōu)勢:
  • 雙向實時通信:WebSocket提供了雙向的實時信能力,客戶端和服務器可以通過該協(xié)議進行雙向數(shù)據(jù)傳輸,實時反饋更新信息,實現(xiàn)即時通訊、實時數(shù)據(jù)推送等功能。

  • 較低的延遲:與傳統(tǒng)的HTTP請求相比,WebSocket降低了通信的開銷,減少了傳輸和處理數(shù)據(jù)的延遲,因此可以更快進行實時數(shù)據(jù)傳輸。

  • 更高的性能:由于WebSocket使用較少的頭部信息和更有效的消息傳輸格式,因此在相同帶寬下可以傳輸更多的數(shù)據(jù),提高了性能和效率。

  • 廣泛的瀏覽器支持:WebSocket是HTML5的一部分,并且得到了大多數(shù)現(xiàn)代瀏覽器的支持,因此它可以在各種平臺和設備上使用。

  • 連接保持:與傳統(tǒng)的HTTP請求不同,WebSocket連接保持在建立之后,雙方可以隨時進行數(shù)據(jù)傳輸,避免了不必要的連接和斷開操作。

  • WebSocket的局限性:
  • 兼容性問題:雖然現(xiàn)代瀏覽器廣泛支持WebSocket,但在某些舊版本或特定設備上可能存在兼容性問題。為了兼容性,可以使用輪訓技術(如長輪詢)作為備選方案。

  • 部署和維護復雜性:WebSocket服務器的設置和配置可能比傳統(tǒng)的Web服務器復雜一些,需要專門的服務器環(huán)境和配置。

  • 安全性問題:由于WebSocket是在HTTP協(xié)議的基礎上建立的,它們共享相同的安全風險,例如跨站點腳本(XSS)和跨站請求偽造(CSRF)。因此,在使用WebSocket時需要考慮到安全性,并采取適當?shù)陌踩胧?/p>

  • 擴展問題:WebSocket協(xié)議還不支持像HTTP/2那樣的一些高級特性,例如頭部壓縮和流量控制。在某些特殊情況下,可能需要通過其他方式實現(xiàn)這些功能。

盡管WebSocket具有上述局限性,但它仍然是實時通訊、實時數(shù)據(jù)傳輸和實時協(xié)作等場景下的首選協(xié)議,因為它具備了雙向實時通信和較低延遲等一系列的優(yōu)勢。在開發(fā)時,需要根據(jù)具體需求和限制,綜合考慮使用WebSocket的適用性。


結論

WebSocket是一種能夠提供雙向實時通信的協(xié)議,適用于需要實時數(shù)據(jù)傳輸和雙向通信的場景。它具有較低的延遲、更高的性和廣泛的瀏覽器持等優(yōu)勢,能夠實現(xiàn)即時通訊、多人協(xié)和實時數(shù)據(jù)更新等功能。

然而,WebSocket也存在兼容性、部署和維護復雜性、安全性問題以及缺乏一些高級特性等局限性。在開發(fā)時,需要仔細考慮具體需求和限制,并必要時采取適當?shù)慕鉀Q方案。

總的來說,WebSocket在實時通信和實時數(shù)據(jù)傳輸方面具有明顯的優(yōu)勢,是構建現(xiàn)代Web應用的重要工具之一。

藍藍設計(sillybuy.com )是一家專注而深入的界面設計公司,為期望卓越的國內外企業(yè)提供卓越的大數(shù)據(jù)可視化界面設計、B端界面設計、桌面端界面設計、APP界面設計、圖標定制、用戶體驗設計、交互設計UI咨詢、高端網(wǎng)站設計、平面設計,以及相關的軟件開發(fā)服務,咨詢電話:01063334945。

關鍵詞:UI咨詢、UI設計服務公司軟件界面設計公司、界面設計公司、UI設計公司、UI交互設計公司、數(shù)據(jù)可視化設計公司、用戶體驗公司高端網(wǎng)站設計公司

銀行金融軟件UI界面設計、能源及監(jiān)控軟件UI界面設計、氣象行業(yè)UI界面設計軌道交通界面設計、地理信息系統(tǒng)GIS UI界面設計航天軍工軟件UI界面設計、醫(yī)療行業(yè)軟件UI界面設計教育行業(yè)軟件UI界面設計、企業(yè)信息化UI界面設計、軟件qt開發(fā)、軟件wpf開發(fā)軟件vue開發(fā)

分享本文至:

日歷

鏈接

個人資料

藍藍設計的小編 http://sillybuy.com

存檔