server.js
@@ -7,6 +7,7 @@ var mongoClient = require('mongodb').MongoClient; var config = require('./config'); var method = require('./method'); var queue = require('./queue'); var map = { "5a0000010001": 32, @@ -101,6 +102,9 @@ if(length > 0) { var value = data.slice(0, length); console.log(moment().format('YYYY-MM-DD HH:mm:ss') + " => " + value); queue.publishMessage(value); handleData(db, socket, value); doWork(db, socket, data.slice(length)); @@ -132,7 +136,7 @@ }); socket.on('end', function(){ console.log(count) }); socket.on('error', function(error) {