为了防止无良网站的爬虫抓取文章,特此标识,转载请注明文章出处。LaplaceDemon/SJQ。
http://www.cnblogs.com/shijiaqi1066/p/3826251.html
Socket.IO用于浏览器与node.js之间实现实时通信。Socket.IO设计的目标是支持任何的浏览器,任何Mobile设备。支持主流的PC浏览器 (IE,Safari,Chrome,Firefox,Opera等),Mobile浏览器(iphone Safari/ipad Safari/android WebKit/WebOS WebKit等)。
Socket.IO支持如下方式的通信方式,根据浏览器的支持程度,自动选择使用哪种技术进行通信:
Socket.IO解决了实时的通信问题,并统一了服务端与客户端的编程方式。启动了socket以后,就像建立了一条客户端与服务端的管道,两边可以互通有无。
engine.io是一个Socket.IO的抽象实现,作为Socket.IO的服务器和浏览器之间交换的数据的传输层。它不会取代Socket.IO,它只是抽象出固有的复杂性,支持多种浏览器,设备和网络的实时数据交换。
例:创建io服务器的两种简单的方法。
var io = require(‘Socket.IO‘)(); // 或 var Server = require(‘Socket.IO‘); var io = new Server();
Socket.IO服务器的配置项与engine.io相同。
通过Node http server使用Socket.IO
// Server (app.js) var app = require(‘http‘).createServer(handler) var io = require(‘Socket.IO‘)(app); var fs = require(‘fs‘); app.listen(80);
function handler (req, res) { fs.readFile(__dirname + ‘/index.html‘, function (err, data) { if (err) { res.writeHead(500); return res.end(‘Error loading index.html‘); }
res.writeHead(200); res.end(data); }); } io.on(‘connection‘, function (socket) { socket.emit(‘news‘, { hello: ‘world‘ }); socket.on(‘my other event‘, function (data) { console.log(data); }); }); // Client (index.html) <script src="/Socket.IO/Socket.IO.js"></script> <script> var socket = io(‘http://localhost‘); socket.on(‘news‘, function (data) { console.log(data); socket.emit(‘my other event‘, { my: ‘data‘ }); }); </script>
通过Express 3/4 使用Socket.IO
// Server (app.js) var app = require(‘express‘)(); var server = require(‘http‘).Server(app); var io = require(‘Socket.IO‘)(server); server.listen(80); app.get(‘/‘, function (req, res) { res.sendfile(__dirname + ‘/index.html‘); }); io.on(‘connection‘, function (socket) { socket.emit(‘news‘, { hello: ‘world‘ }); socket.on(‘my other event‘, function (data) { console.log(data); }); }); // Client (index.html) <script src="/Socket.IO/Socket.IO.js"></script> <script> var socket = io.connect(‘http://localhost‘); socket.on(‘news‘, function (data) { console.log(data); socket.emit(‘my other event‘, { my: ‘data‘ }); }); </script>
Socket.IO 提供了默认事件(如:connect, message, disconnect)。另外,Socket.IO允许发送并接收自定义事件。
事件的发送:
//发送给对应的客户端 socket.emit(‘message‘,"this is a test"); //发送给所有客户端 io.sockets.emit(‘message‘,"this is a test"); //发送消息给指定socketId的客户端。 io.sockets.socket(socketid).emit(‘message‘,‘for your eyes only‘); //发送自定义的事件 socket.emit("my-event","this is a test");
事件的接收:
socket.on("event name",function(data){ //data为接收到的数据。 });
示例代码
例1:
// note, io.listen(<port>) will create a http server for you var io = require(‘Socket.IO‘).listen(80); io.sockets.on(‘connection‘, function (socket) { io.sockets.emit(‘this‘, { will: ‘be received by everyone‘}); socket.on(‘private message‘, function (from, msg) { console.log(‘I received a private message by ‘, from, ‘ saying ‘, msg); }); socket.on(‘disconnect‘, function () { io.sockets.emit(‘user disconnected‘); }); });
例2:
// Server (app.js) var io = require(‘Socket.IO‘).listen(80); io.sockets.on(‘connection‘, function (socket) { socket.on(‘ferret‘, function (name, fn) { fn(‘woot‘); }); }); // Client (index.html) <script> var socket = io(); // TIP: io() with no args does auto-discovery socket.on(‘connect‘, function () { // TIP: you can avoid listening on `connect` and listen on events directly too! socket.emit(‘ferret‘, ‘tobi‘, function (data) { console.log(data); // data will be ‘woot‘ }); }); </script>
广播消息由服务器发送,会发送给除了当前连接的其他所有客户端。
//发送给除了发送者之外的所有客户端。 socket.broadcast.emit(‘message‘,"this is a test");
例:广播用户连接的自定义事件。
var io = require(‘Socket.IO‘).listen(80);
io.sockets.on(‘connection‘, function (socket) { socket.broadcast.emit(‘user connected‘); });
volatile 意思大概是说,当服务器发送数据时,客户端因为各种原因不能正常接收,比如网络问题、或者正处于长连接的建立连接阶段。此时会让我们的应用变得 suffer,那就需要考虑发送 volatile 数据。
var io = require(‘Socket.IO‘).listen(80); io.sockets.on(‘connection‘, function (socket) { var tweets = setInterval(function () { getBieberTweet(function (tweet) { socket.volatile.emit(‘bieber tweet‘, tweet); }); }, 100); socket.on(‘disconnect‘, function () { clearInterval(tweets); }); });
即使客户端没连线,一样可以这样发送,服务器会自动丢弃发送失败的数据。
通过命名空间可以为Socket.IO设置子程序。默认命名空间为“/”,Socket.IO默认连接该路径。
使用of()函数可以自定义命名空间。
// Server (app.js) var io = require(‘Socket.IO‘).listen(80); var chat = io .of(‘/chat‘) .on(‘connection‘, function (socket) { socket.emit(‘a message‘, { that: ‘only‘ , ‘/chat‘: ‘will get‘ }); chat.emit(‘a message‘, { everyone: ‘in‘ , ‘/chat‘: ‘will get‘ }); }); var news = io .of(‘/news‘) .on(‘connection‘, function (socket) { socket.emit(‘item‘, { news: ‘item‘ }); }); // Client (index.html) <script> var chat = io.connect(‘http://localhost/chat‘) , news = io.connect(‘http://localhost/news‘); chat.on(‘connect‘, function () { chat.emit(‘hi!‘); }); news.on(‘news‘, function () { news.emit(‘woot‘); }); </script>
房间是Socket.IO提供的一个非常好用的功能。房间相当于为指定的一些客户端提供了一个命名空间,所有在房间里的广播和通信都不会影响到房间以外的客户端。
进入房间与离开房间
使用join()方法将socket加入房间:
io.on(‘connection‘, function(socket){ socket.join(‘some room‘); });
使用leave()方法离开房间:
socket.leave(‘some room‘);
在房间中发送消息
在某个房间中发送消息:
io.to(‘some room‘).emit(‘some event‘);
to()方法用于在指定的房间中,对除了当前socket的其他socket发送消息。
socket.broadcast.to(‘game‘).emit(‘message‘,‘nice game‘);
in()方法用于在指定的房间中,为房间中的所有有socket发送消息。
io.sockets.in(‘game‘).emit(‘message‘,‘cool game‘);
当socket进入一个房间之后,可以通过以下两种方式在房间里广播消息:
//向my room广播一个事件,提交者会被排除在外(即不会收到消息) io.sockets.on(‘connection‘, function (socket) { //注意:和下面对比,这里是从客户端的角度来提交事件 socket.broadcast.to(‘my room‘).emit(‘event_name‘, data); } //向another room广播一个事件,在此房间所有客户端都会收到消息 //注意:和上面对比,这里是从服务器的角度来提交事件 io.sockets.in(‘another room‘).emit(‘event_name‘, data); //向所有客户端广播 io.sockets.emit(‘event_name‘, data);
除了向房间广播消息之外,还可以通过以下API来获取房间的信息。
//获取所有房间的信息 //key为房间名,value为房间名对应的socket ID数组 io.sockets.manager.rooms //获取particular room中的客户端,返回所有在此房间的socket实例 io.sockets.clients(‘particular room‘) //通过socket.id来获取此socket进入的房间信息 io.sockets.manager.roomClients[socket.id]
更多API资料,请参考Socket.IO官方文档。另外网络上很多资料是基于0.9版本的,与目前1.0有比较大的区别,请仔细阅读:Migration from 0.9
其他资料:
http://www.csser.com/board/4f5ed68d417a7f6a6e000059
http://raytaylorlin.com/Tech/web/Nodejs/socket-io-tutorial/
http://raytaylorlin.com/Tech/web/Node.js/socket-io-advanced/
为了防止无良网站的爬虫抓取文章,特此标识,转载请注明文章出处。LaplaceDemon/SJQ。
http://www.cnblogs.com/shijiaqi1066/p/3826251.html
原文:http://www.cnblogs.com/shijiaqi1066/p/3826251.html