NodeJS + Socket.IO 消息推送

//socket.io
var app = require("express")();
var http = require("http").Server(app);
var io = require("socket.io")(http);

//couchbase
var couchbase = require("couchbase");
var cluster = new couchbase.Cluster("couchbase://192.168.1.1");
var bucket = cluster.openBucket("name","pass");

var onlineUsers = {};
var onlineCount = 0;

io.on("connection" , function(socket){

	socket.on("login" , function(obj){
		socket.name = obj.userid;
		console.log(new Date() + " : 编号" + obj.userid + "员工已登录！");

		if(!onlineUsers.hasOwnProperty(obj.userid)){
			//onlineUsers[obj.userid] = obj.userid;
			onlineUsers[obj.userid] = {'c_id':obj.userid,'socket':socket};
			onlineCount ++;
		}
	});

	socket.on("disconnect" , function(){
		if(onlineUsers.hasOwnProperty(socket.name)){
			var obj = {userid:socket.name};
			delete onlineUsers[socket.name];
			onlineCount --;
			console.log(new Date() + " : 编号" + obj.userid+'已登出！');
		}
	});

});


setInterval(function(){
	
	bucket.getMulti([ "Name1" , "Name2" ], function(err, result) {
		if(err){
			console.log(new Date() + " : ERROR : " + err);
		}
		else
		{
			NodeEmit(result);
		}
	});		

} , 10 * 1000);

function NodeEmit(result){
	for(var user in onlineUsers){
			_Str_Name1 = result["Name1"].value["content"][user];
			//io.emit("cmd" + user.toString() , _Str);
			onlineUsers[user].socket.emit("cmd" + user.toString() ,_Str_Name1);
			
			// 
			if(typeof(result["Name2"].value["content"][user]) != "undefined"){
				_Str_Name2 = JSON.stringify(result["Name2"].value["content"][user]);
				//io.emit("cmd2" + user.toString() , _Str_Name2);
				onlineUsers[user].socket.emit("cmd2" + user.toString() , Str_Name2);
			}
			
		}
}

http.listen(8066 , function(){
	console.log("listening on *:8066");	
});

　　

1、一次从Couchbase 获取多个 document

bucket.getMulti([ "Name1" , "Name2" ], function(err, result) {
	if(err){			
	}
	else{			
	}
});

 

使用

 

result["Name1"]

　　　

 

2、解决CPU 占用 100%的问题。

 

原来是用IO对象直接 emit

var io = require(“socket.io”)(http);

io.emit(“cmd”+userid , _Str);

 

现在把每个连接的socket保存下来

onlineUsers[obj.userid] = {‘c_id’:obj.userid,‘socket’:socket};

推送时

onlineUsers[userid].socket.emit(“cmd” +user id, _Str);