沈斌
2018-04-17 d76a08aeb381091be31f03e7c62988fd3b2b8760
server.js
@@ -103,7 +103,7 @@
    var length = map[data.slice(0, 12)];
    if(length > 0) {
        var value = data.slice(0, length);
        console.log(moment().format('YYYY-MM-DD HH:mm:ss') + " => " + value);
        //console.log(moment().format('YYYY-MM-DD HH:mm:ss') + " => " + value);
        queue.publishMessage(value);
@@ -113,7 +113,19 @@
    }
}
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;
@@ -161,6 +173,6 @@
            console.log('Closed socket: ' + socket.remoteAddress +' '+ socket.remotePort);
        });
    }).listen(config.PORT, config.HOST);
    console.log('TCP Server listening on ' + config.HOST + ':' + config.PORT);
});