在不少需求业务中,都须要浏览器和服务器实时通讯来实现功能,好比:扫码登陆(扫码后,手机确认登陆,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浏览器