node读取tcp数据

看到nodejs提供了net module，可以发起tcp连接，于是想到了我们的multicastserver，可以用node去接受数据，然后通过websocket，来实时显示后台发送的socket数据。

 

有想法已经很久了，但是之前只是写到获取到了socket发送来的数据，但是解析数据这块有点问题，没有能很完整的解析所有数据。最近几天又开始写了，卡在了读取byte[]成一个double，纠结了2天，未果。。后来问了群里，才知道node本来就有个buffers模块，直接调用里面的方法就好，有从8位int到32位int和float，double的读取和写入。。。尼玛，早知道就省事多了。。我也想了。。node这种跑在后端的代码，怎么可能不能读取tcp发来的这种byte[]呢。。。

 

下面是自己写的一个读取short，int，long，String，double转date的工具类，node的buffer没直接读取64位int的。。所以我自己的getLong还是有点用。。。

 

 

var byteArrayUtil=(function() {
   	getShort=function(b,offset){
	  var value = 0;
	  for (var i = 0; i < 2; i++) {
	    var shift = i * 8;
	    value += (b[i + offset] & 0x000000FF) << shift;
	  }
	  return value;
	}
	getInt=function(b,offset){
	  var value = 0;
	  for (var i = 0; i < 4; i++) {
	    var shift = i * 8;
	    value += (b[i + offset] & 0x000000FF) << shift;
	  }
	  return value;
	}
	getLong=function(b,offset){
	  var value = 0;
	  for (var i = 0; i < 8; i++) {
	    var shift = i * 8;
	    value += (b[i + offset] & 0x000000FF) << shift;
	  }
	  return value;
	}
	getDouble=function(b,offset){
	  var value = 0;
	  for (var i = 0; i < 8; i++) {
	    var shift = i * 8;
	    value += (b[i + offset] & 0x000000FF) << shift;
	  }
	  return value;
	}
	getString=function(b,offset,length){
	  var value="";
	  for (var i = 0; i < length; i++) {
	    var c=b[offset+i];
	    if(c!=0){
	    	value+=String.fromCharCode(c);
	    }else{
	    	break;
	    }
	  }
	  return value;
	}
	doubleToDate=function(time){
		var date=new Date();
		date.setFullYear(1899);
		date.setMonth(11);
		date.setDate(30);
		date.setHours(0);
		date.setMinutes(0);
		date.setSeconds(0);
		date.setMilliseconds(0);

		var baseTime=date.getTime();
		baseTime+=Math.floor(time*24*60*60*1000);

   		date.setTime(baseTime);
   		return date;
	}
	return this;
})();

 

 

然后是接受到socket的data事件后的处理代码，只是写了最最简单的控制台打印，websocket的东西之后继续加上：

 

socket.on("data",function(data){
   var offset=5;
   var buffer=new Buffer(data);
   console.log("buffer length:"+buffer.length);
   var magiccode=buffer.readUInt16LE(offset);
   //console.log(magiccode.toString(16));
   if(magiccode.toString(16)=="abcd"){
     var size=buffer.readUInt32LE(data,offset+2);
     console.log("size:"+size);
     var type=buffer.readUInt16LE(offset+6);
     //console.log("type:"+type);
     if(type==13){
       var time=buffer.readDoubleLE(offset+8);
       //console.log("time:"+time+"  typeof():"+typeof(time)); //number
       var date=byteArrayUtil.doubleToDate(time);
       console.log(date.getFullYear()+"-"+(date.getMonth()+1)+"-"+date.getDate()+" "+date.getHours()+":"+date.getMinutes()+":"+date.getSeconds());
       var queue=byteArrayUtil.getString(data,offset+16,16);
       console.log("queue:"+queue);
       var totalAgent=byteArrayUtil.getLong(data,offset+32);
       console.log("totalAgent:"+totalAgent);
     }
   }  
});

 

 

有空还是要多看看node的文档。。只凭着自己瞎搞，效率太低了。。

 

在windows上装了node-0.6.11，安装真心简单，装好后cmd里就可以用node了。。。本来的cygwin里的是0.5.0的，调用buffer的read方法时候一直报typeerror，开始还纳闷，想了好久猜测也许是版本不对，老版本大概还没这方法，换了新的果然OK了。。爽~~

buffer.readDoubleLE(offset)好棒~~