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

2023-12-25    前端達(dá)人

 

前言

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


WebSocket原理

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

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

  • WebSocket協(xié)議

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

升級完成后,客戶端和服務(wù)器之間的通信不再遵循HTTP請求-響應(yīng)模式,而是通過WebSocket協(xié)議進(jìn)行雙向的實(shí)時通信??蛻舳撕头?wù)器可以直接發(fā)送消息給對方,不需要等待對方的請求。


如何使用WebSocket

建立WebSocket連接:

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

在戶端(JavaScript):

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

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


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


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


// 監(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

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

const WebSocket = require("ws");

// 創(chuàng)建WebSocket服務(wù)器
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)聽連接關(guān)閉事件
socket.on("close", function() {
console.log("WebSocket連接已關(guān)閉");
});
});

 

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

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

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

在客戶端(JavaScript):

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

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

 

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

在服務(wù)器端(示例使用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

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

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


WebSocket的真實(shí)使用場景

即時通訊:

WebSocket非常適合用于即時通訊應(yīng)用,因為它能夠?qū)崿F(xiàn)實(shí)時雙向通信。以下是一個簡單的即時聊天應(yīng)用的代碼教程。

在客戶端(JavaScript):

// 創(chuàng)建WebSocket對象并指定服務(wù)器地址
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)聽接收到服務(wù)器發(fā)送的消息
socket.onmessage = function(event) {
var message = event.data;
console.log("接收到服務(wù)器發(fā)送的消息:" + message);


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


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


// 監(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

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

const WebSocket = require("ws");

// 創(chuàng)建WebSocket服務(wù)器
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)聽連接關(guān)閉事件
socket.on("close", function() {
console.log("WebSocket連接已關(guān)閉");
});
});

 

  • 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對象連接到服務(wù)器。輸入框中的文本框用于錄入要發(fā)送的消息,按下Enter鍵時會將消息發(fā)送給服務(wù)器。服務(wù)器接收到消息后,通過遍歷所有連接的客戶端,向每個客戶端發(fā)送消息。

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

多人協(xié)作:

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

在客戶端(JavaScript):

// 創(chuàng)建WebSocket對象并指定服務(wù)器地址
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)聽接收到服務(wù)器發(fā)送的消息
socket.onmessage = function(event) {
var message = JSON.parse(event.data);
console.log("接收到服務(wù)器發(fā)送的消息:" + message);


// 根據(jù)消息執(zhí)行相應(yīng)的操作,示例中處理了繪畫指令
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)聽連接關(guān)閉事件
socket.onclose = function(event) {
console.log("WebSocket連接已關(guān)閉");
};


// 監(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

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

const WebSocket = require("ws");

// 創(chuàng)建WebSocket服務(wù)器
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)聽連接關(guān)閉事件
socket.on("close", function() {
console.log("WebSocket連接已關(guān)閉");
});
});

 

  • 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對象連接到服務(wù)器。當(dāng)鼠標(biāo)在畫布上按下時,將繪畫指令發(fā)送給服務(wù)器。服務(wù)器接收到繪畫指令后,將指令廣播給所有連接的客戶端,并在各個客戶端上進(jìn)行繪畫操作。

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

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

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

在客戶端(JavaScript):

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

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


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


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


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


// 監(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

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

const WebSocket = require("ws");

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


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


// 向所有連接的客戶端發(fā)送實(shí)時數(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í)時數(shù)據(jù)
var stockPrice = Math.random() * 100;
var data = {
price: stockPrice
};
socket.send(JSON.stringify(data));


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

 

  • 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對象連接服務(wù)器。服務(wù)器使用setInterval函數(shù)模擬實(shí)時股票價格的更新,并將更新的數(shù)據(jù)發(fā)送給所有連接的客戶端??蛻舳吮O(jiān)聽接收到服務(wù)器發(fā)送的消息,并處理接收到的實(shí)時數(shù)據(jù)。

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


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

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

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

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

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

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

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

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

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

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

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


結(jié)論

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

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

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

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

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

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

日歷

鏈接

個人資料

存檔