Здесь я получаю данные сокета tcp, анализирую их и помещаю в mon go db.
При запуске приложения несколько раз я получаю огромные данные (событие socket 'data'), как только устанавливается соединение установлено, а затем процесс останавливается в строке 15 и после нескольких минут повторного применения начинается с метода run ().
Но если данные не принимаются сразу при запуске приложения и установлении соединения, а принимаются через несколько секунд после подключения создание, затем он работает без сбоев.
фрагмент кода, как показано ниже, Также требуется улучшение дизайна
const streamer = require("/server.js");
async function run() {
logger.debug('Initialize mongo, net-server');
try {
// Initialize the database environment or exit with exception error
await mongo.init();
} catch (err) {
logger.error(err);
process.exit(1);
}
server.start(); // net server listen to TCP dump
setInterval(() => {
if (server.isServerRunning() && server.isDataAvailable()) { //**line 15 getting stuck here
// get collected data, parse and put into mongo
}
}, 3000);
}
run();