這個(gè)看出客戶端要通過(guò)很多次詢(xún)問(wèn)后,才能知道服務(wù)端什么時(shí)候準(zhǔn)備就緒,這樣如果發(fā)送請(qǐng)求的客戶特別多,請(qǐng)求頻率特別高這無(wú)疑會(huì)給服務(wù)端造成了不小的壓力。
如果有那么一種方式可以讓服務(wù)端想客戶端推送消息,就可以完美解決這一情況,于是WebSocket出現(xiàn)了。
WebSocket是HTML5的新協(xié)議,所以支持HTML5的瀏覽器都能直接使用WebSocket不需要額外安裝,什么開(kāi)發(fā)包,或者插件。
為了測(cè)試WebSocket我們需要簡(jiǎn)單的搞一個(gè)服務(wù)端程序。Node.js本身支持的協(xié)議包括TCP協(xié)議和HTTP協(xié)議,但不支持WebSocket,為了讓讓node也支持WebSocket,這里我選用ws
模塊。
創(chuàng)建一個(gè)名為testWebSocket的文件夾,使用npm init 初始化項(xiàng)目
配置package.json文件添加,這里選用ws
的最新的版本
"dependencies": {
"ws": "^6.2.1"
}
在根目錄使用npm指令npm install --save,把ws
相關(guān)依賴(lài)都拉下來(lái)。
然后創(chuàng)建一個(gè)名為myWebSocketServer.js的文件,一個(gè)簡(jiǎn)單的WebSocket服務(wù)端程序完成,
node myWebSocketServer.js先讓服務(wù)端跑起來(lái)。相關(guān)教程:webSocket 視頻教程
// 導(dǎo)入WebSocket模塊:
const WebSocket = require('ws');
let i = 1;// 引用Server類(lèi):
const WebSocketServer = WebSocket.Server;// 實(shí)例化:
const myWs = new WebSocketServer({
port: 8080
});myWs.on('connection', ws => {
ws.on('message', message => {
console.log('received: %s', message);
});setInterval(() => {
ws.send('Hello siegaii this is serverMessage!' + i);
i++;
}, 1000);});
客戶端
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>test</title>
</head>
<body>
<button id="test">hello siegaii</button><script>
let ws = new WebSocket('ws://localhost:8080/testWebSocket');
document.getElementById('test').addEventListener('click', () => {
ws.send('Hello Siegaii this is clientMessage!');
});// 響應(yīng)onmessage事件:
ws.onmessage = (msg) => {
console.log(msg);
};</script>
</body>
</html>
運(yùn)行結(jié)果如下
簡(jiǎn)單介紹下WebSocket的api
// WebSocket Api
let socket = new WebSocket(url, [protocol] ); // 實(shí)例化一個(gè)WebSocket對(duì)象建立連接
/**
* socket的readyState屬性
* 0 - 表示連接尚未建立。
* 1 - 表示連接已建立,可以進(jìn)行通信。
* 2 - 表示連接正在進(jìn)行關(guān)閉。
* 3 - 表示連接已經(jīng)關(guān)閉或者連接不能打開(kāi)。
*/
socket.readyState/**
* 只讀屬性 bufferedAmount 已被 send() 放入正在隊(duì)列中等待傳輸,但是還沒(méi)有發(fā)出的 UTF-8 文本字節(jié)數(shù)。
*/
socket.bufferedAmount/**
* WebSocket 事件
*/
socket.onopen(); //連接建立時(shí)觸發(fā)
socket.onmessage(); //客戶端接收服務(wù)端數(shù)據(jù)時(shí)觸發(fā)
socket.onerror(); //通信發(fā)生錯(cuò)誤時(shí)觸發(fā)
socket.onclose(); //連接關(guān)閉時(shí)觸發(fā)/**
* WebSocket 方法
*/
Socket.send() //使用連接發(fā)送數(shù)據(jù)
Socket.close() //關(guān)閉連接
聲明:本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí),若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系,我們將在第一時(shí)間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com