| | |
| | | } |
| | | } |
| | | |
| | | mongoClient.connect(config.URL, function(err, db) { |
| | | mongoClient.connect(config.URL, { |
| | | server: { |
| | | poolSize: 10, |
| | | keepAlive: 120, |
| | | auto_reconnect: true, |
| | | reconnectTries: 1000, |
| | | reconnectInterval: 5000, |
| | | socketOptions: { |
| | | keepAlive: 300000, |
| | | connectTimeoutMS: 30000 |
| | | } |
| | | } |
| | | }, function(err, db) { |
| | | if (err) { |
| | | console.log(err.message); |
| | | return; |
| | |
| | | return; |
| | | } |
| | | |
| | | //console.log(moment().format('YYYY-MM-DD HH:mm:ss') + " => " + value); |
| | | |
| | | doWork(db, socket, value); |
| | | }); |
| | | |
| | |
| | | console.log('Closed socket: ' + socket.remoteAddress +' '+ socket.remotePort); |
| | | }); |
| | | }).listen(config.PORT, config.HOST); |
| | | |
| | | |
| | | console.log('TCP Server listening on ' + config.HOST + ':' + config.PORT); |
| | | }); |