服务端代码

var fs=require(‘fs’); var vm = require(‘vm’);

var journey = require(‘journey/journey’);

var http=require(‘http’);

var url = require(“url”);

var querystring = require(“querystring”);

var connect=require(“connect”);

var jsonData;

var router = new(journey.Router);

router.map(function() {

this.post(/^\/node?(?:\/(\d+)(?:\.\.(\d+))?)?/).bind(function(req, res, data) {

    typeMethod(jsonData);

    

    res.sendBody("bbb");

    res.send(200);

});

});

var sio = require(‘socket.io’);

var express = require(‘express’); //console.log(express) //var app = module.export = express.createServer();

var app=module.export=http.createServer(function(request, response) {  
    var body = "";    
    request.on('data', function(chunk) {
        body += chunk;
	jsonData = querystring.parse(body);
    });  
    request.on('end', function() {  
        router.handle(request, body, function(result) {  
            response.writeHead(result.status, result.headers);  
            response.end(result.body);  
        });  
    });  
}).listen(6380);  \n```


var socketUser = {};
var queueUser={};

io  = sio.listen(app);

io.sockets.on('connection', function (socket){
   //响应连接

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

   //公共称登陆方法
   socket.on('queueLogin', function (data) {
   	   console.log("loginllllllll");
   	   if(!queueUser.hasOwnProperty(socket.id)) {
   		   queueUser[socket.id] = {'c_id':data.c_id,'socket':socket};
           //在线人数+1
           //onlineCount++;
       }
   });


   //监听断线

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

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

       delete queueUser[socket.id];
   });

});

//推送给一个在线的人
var pushOne = function(data){

 console.log('-推送数据['+data+']-');
 var ioData=data;
 for(var values in queueUser){
     if(queueUser[values].c_id==ioData.openId){
	      console.log('匹配人员'+ioData.openId);
	      queueUser[values].socket.emit('receiveWeight',{'data': ioData});
	      break;
	   }
  }	   

};


var typeMethod=function(data,req,res){
	var param=eval("("+data.data+")");
	var type=eval("("+data.type+")");
	switch(type){
		case 1:
			pushOne(param);
			break;
	}
};



客户端代码

var socket=‘';
function connSocketIO(openId){
	
	socket = io.connect(ip+":6380",
			{
			 "reconnect":false,
		     //"reconnect":false,
			 "auto connect":false,
				//"reconnectionDelay":100,
			 "connect timeout":100
			}
	);
	
	socket.on('conn', function (data) {

	 var postdata = {
		   'c_id'   : openId,     //用户id
	 };

 	    socket.emit('queueLogin', postdata);

	});
	
	//接收体重数据
	socket.on('receiveWeight', function (data,fn) {

		console.log("1");
	});

	socket.connect();
	
}


现在是遇到，我发一个post请求访问node.js，调用一次相应的方法，然后出现接收到多次消息的问题，例如:理想是页面接收一次’你好‘的消息，实际接收到多次’你好‘
现在是运用在手机web上的，然后是有一定几率会出现，重复执行多次也没有规律，多的有6-7次，所以重现起来都很难