Vue.js 如何使用 Socket.IO ?
阿新 • • 發佈:2019-07-29
在很多需求業務中,都需要瀏覽器和伺服器實時通訊來實現功能,比如:掃碼登入(掃碼後,手機確認登入,PC網頁完成登入並跳轉)、訂單語言提醒等,這些都是建立在兩端實時通訊的基礎上的。對前端而言,來實現瀏覽器和伺服器實時通訊,最好的選擇就是Socket.IO庫,能夠快速的實現兩端實時通訊功能。
1、什麼是 Socket.IO?
Socket.IO
是一個WebSocket庫,可以在瀏覽器和伺服器之間實現實時,雙向和基於事件的通訊。它包括:Node.js伺服器庫、瀏覽器的Javascript客戶端庫。它會自動根據瀏覽器從WebSocket、AJAX長輪詢、Iframe流等等各種方式中選擇最佳的方式來實現網路實時應用,非常方便和人性化,而且支援的瀏覽器最低達IE5.5
2、Socket.IO 主要特點
(1)、支援瀏覽器/Nodejs環境 (2)、支援雙向通訊 (3)、API簡單易用 (4)、支援二進位制傳輸 (5)、減少傳輸資料量
3、Vue.js 中 Socket.IO的使用
(1)客戶端
npm install vue-socket.io --save
main.js新增下列程式碼
import VueSocketIO from 'vue-socket.io' Vue.use(new VueSocketIO({ debug: true, // 伺服器端地址 connection: 'http://localhost:3000', vuex: { } }))
傳送訊息和監聽訊息
//傳送資訊給服務端
this.$socket.emit('login',{
username: 'username',
password: 'password'
});
//接收服務端的資訊
this.sockets.subscribe('relogin', (data) => {
console.log(data)
})
(2)服務端
服務端,我們基於express搭建node伺服器。
npm install --save express
npm install --save socket.io
index.js檔案
var app = require('express')(); var http = require('http').Server(app); var io = require('socket.io')(http); app.get('/', function(req, res){ res.send('<h1>你好web秀</h1>'); }); io.on('connection',function(socket) { //接收資料 socket.on('login', function (obj) { console.log(obj.username); // 傳送資料 socket.emit('relogin', { msg: `你好${obj.username}`, code: 200 }); }); }); http.listen(3000, function(){ console.log('listening on *:3000'); });
然後啟動服務端服務
node index.js
客戶端即可檢視效果。
4、Socket.IO有哪些事件
io.on('connect', onConnect);
function onConnect(socket){
// 傳送給當前客戶端
socket.emit(
'hello',
'can you hear me?',
1,
2,
'abc'
);
// 傳送給所有客戶端,除了傳送者
socket.broadcast.emit(
'broadcast',
'hello friends!'
);
// 傳送給同在 'game' 房間的所有客戶端,除了傳送者
socket.to('game').emit(
'nice game',
"let's play a game"
);
// 傳送給同在 'game1' 或 'game2' 房間的所有客戶端,除了傳送者
socket.to('game1').to('game2').emit(
'nice game',
"let's play a game (too)"
);
// 傳送給同在 'game' 房間的所有客戶端,包括髮送者
io.in('game').emit(
'big-announcement',
'the game will start soon'
);
// 傳送給同在 'myNamespace' 名稱空間下的所有客戶端,包括髮送者
io.of('myNamespace').emit(
'bigger-announcement',
'the tournament will start soon'
);
// 傳送給指定 socketid 的客戶端(私密訊息)
socket.to(<socketid>).emit(
'hey',
'I just met you'
);
// 包含回執的訊息
socket.emit(
'question',
'do you think so?',
function (answer) {}
);
// 不壓縮,直接傳送
socket.compress(false).emit(
'uncompressed',
"that's rough"
);
// 如果客戶端還不能接收訊息,那麼訊息可能丟失
socket.volatile.emit(
'maybe',
'do you really need it?'
);
// 傳送給當前 node 例項下的所有客戶端(在使用多個 node 例項的情況下)
io.local.emit(
'hi',
'my lovely babies'
);
};