在不少需求業務中,都須要瀏覽器和服務器實時通訊來實現功能,好比:掃碼登陸(掃碼後,手機確認登陸,PC網頁完成登陸並跳轉)、訂單語言提醒等,這些都是創建在兩端實時通訊的基礎上的。對前端而言,來實現瀏覽器和服務器實時通訊,最好的選擇就是Socket.IO庫,可以快速的實現兩端實時通訊功能。javascript
Socket.IO
是一個WebSocket庫,能夠在瀏覽器和服務器之間實現實時,雙向和基於事件的通訊。它包括:Node.js服務器庫、瀏覽器的Javascript客戶端庫。它會自動根據瀏覽器從WebSocket、AJAX長輪詢、Iframe流等等各類方式中選擇最佳的方式來實現網絡實時應用,很是方便和人性化,並且支持的瀏覽器最低達IE5.5前端
(1)、支持瀏覽器/Nodejs環境 (2)、支持雙向通訊 (3)、API簡單易用 (4)、支持二進制傳輸 (5)、減小傳輸數據量vue
npm install vue-socket.io --save
複製代碼
main.js添加下列代碼java
import VueSocketIO from 'vue-socket.io'
Vue.use(new VueSocketIO({
debug: true,
// 服務器端地址
connection: 'http://localhost:3000',
vuex: {
}
}))
複製代碼
發送消息和監聽消息node
//發送信息給服務端
this.$socket.emit('login',{
username: 'username',
password: 'password'
});
//接收服務端的信息
this.sockets.subscribe('relogin', (data) => {
console.log(data)
})
複製代碼
服務端,咱們基於express搭建node服務器。web
npm install --save express
npm install --save socket.io
複製代碼
index.js文件vuex
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');
});
複製代碼
而後啓動服務端服務express
node index.js
複製代碼
客戶端便可查看效果。npm
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' ); }; 複製代碼
原文地址:www.javanx.cn瀏覽器