用node.js(socket.io)实现数据实时推送

在做商品拍卖的时候，要求在商品的拍卖页面需要实时的更新当前商品的最高价格。实现的方式有很多,比如：

1.setInterval每隔n秒去异步拉取数据(缺点:更新不够实时)

2. AJAX轮询方式方式推送数据(缺点:服务端需要在死循环中反复查询数据库)

3.websocket推送数据(缺点:仅支持html5标准的浏览器)

socket.io的简要介绍



接下来开始整理下思路

1.正如简要介绍中所说的首先要将客户端都通过socket.io挂在nodejs服务器上.

在用户进入拍卖页面后开始连接socket.io ，然后将当前客户端的'用户id','拍卖id','当前最高价','socket.id'存储至node.js全局变量socketUser中.

//客户端

var socket = io.connect("http://demo.xiaocai.name":339");

socket.on('conn', function (data) {

var postdata = {

'c_id'   : PageValue.charinfo.c_id,     //用户id

'c_name' : PageValue.charinfo.c_name,   //用户昵称

'guid'   : PageValue.infodata.id,//拍卖id

'price'  : PageValue.infodata.max_price,//当前最高价

}

socket.emit('login', postdata,function(result){

console.log('登陆成功');

});

});

//服务端

var   sio     = require('socket.io');

var   express = require('express');

var   app  =  module.export = express.createServer();

//初始化

var socketUser = {};

io  = sio.listen(app);

io.set('log level', 1);//将socket.io中的debug信息关闭

//监听连接

io.sockets.on('connection', function (socket){

//响应连接

io.sockets.emit('conn', { text: 'socketId:'+socket.id});

//监听用户登录并存储socket

socket.on('login', function (data,fn) {

socketUser[socket.id] = {'c_id':data.c_id,'guid':data.guid,'price':data.price,'socket':socket};

});

//监听断线

socket.on('disconnect', function(){

console.log('-链接断开['+socket.id+']-');

delete socketUser[socket.id];

});

});

从redis缓存中读取出当前拍卖的最高价,然后遍历该拍卖下的socketUser集合,若它的价格低于取出的最高价则向它推送最新的价格(并且更新它的最高价).GetRedisKey是个读取reids的方法该方法在底部贴出.


3.客户端接受推送的数据



GetRedisKey是公共函数中获得redis缓存的方法,这边单独贴出来