Постоянно падает сервер на node.js?

Question

[Олег Абармов]

//-----------------------------------------------
var mysql = require('mysql');
var connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'track',
    password : '***********',
	database :'TRACK'
});

//----------------------------------------------
var net = require('net');

var HOST = '***.***.**.**';
var PORT = 8888;


net.createServer(function(sock) {
    
    sock.on('data', function(data) {
	    var date = new Date();
		var sDate= date.getSeconds()+":"+date.getMinutes()+":"+date.getHours()+" "+date.getDate()+"."+(date.getMonth()+1)+"."+date.getFullYear();
   	
       
        console.log('DATA :' + sDate +  " : " + sock.remoteAddress + ': ' + data);
        sock.write('You said "' + data + '"');
        
		var sSQL="insert into `track` (`text`) values ('" + data + "')";
		connection.query(sSQL, function(error, result, fields){   
	
		});
    });
    
    sock.on('close', function(data) {
      //  console.log('CLOSED: ' + sock.remoteAddress +' '+ sock.remotePort);
    });
    
}).listen(PORT, HOST);

console.log('Server listening on ' + HOST +':'+ PORT);

Вот такой код сервера, запускаю через
screen node server.js

Отрабатывает 10- 20 часов и падает.
Помогите разобраться в чём причина.

Comments

[Lynn «Кофеман»]

И что, ничего не выводит кода падает что ли?

Answer 1

[Олег Абармов]

помог модуль forever
var forever = require('forever-monitor');
//------------------------------------------------------------
var child = new (forever.Monitor)('/var/www/nj/server.js',
{
'minUptime': 50,
'spinSleepTime': 10,
'logFile': '/var/www/nj/log_fr.txt', // Path to log output from forever process (when daemonized)
'outFile': '/var/www/nj/out_fr.txt', // Path to log output from child stdout
'errFile': '/var/www/nj/err_fr.txt' // Path to log output from child stderr
}

Comments

[чсмчсмчмсчмчсмчсм]

для этого есть юниты. /etc/systemd/system

Answer 2

[Александр Прозоров]

Могу предположить, что процесс падает из-за разрыва соединения по таймауту со стороны mySQL если длительное время не было активности на подключении. В этом случае исключение имеет следующий вид:

Error: Connection lost: The server closed the connection.
    at Protocol.end (*path_to_project*/node_modules/mysql/lib/protocol/Protocol.js:103:13)
    at Socket.<anonymous> (*path_to_project*/node_modules/mysql/lib/Connection.js:88:28)
    at Socket.emit (events.js:117:20)
    at _stream_readable.js:944:16
    at process._tickCallback (node.js:442:13)

Лечится выставлением таймаута для подключения к mySQL вручную:
mysqlConnection.query("SET SESSION wait_timeout = 604800"); // 7 days timeout

А вообще конечно надо запускать node-процесс под супервайзером (pm2, forever, supervisor) и заворачивать поток ошибок в соответствующий error.log. Там сразу будет видно с каким исключением завалился процесс. В противном случае с такими вопросами обращайтесь на битву экстрасенсов.

Comments

[Тимур Шемсединов]

Нужно переподключаться, а не отсрочивать проблему.

[Александр Прозоров]

Тимур Шемсединов:
Во первых вы её не отсрочиваете. Таймаут срабатывает не через определённое время после установления соединения, а через определённое время отсутствия активности на соединении.

Во вторых, из моего ответа совершенно не следует, что не надо следить за разрывом соединения. Вы в своём ответе совершенно правильно всё написали.

Ну и в третьих, существует ещё один подход к обработке разрыва соединения - "let it fail". Когда вы намерено не обрабатываете исключение при разрыве что приводит к крешу процесса, который тут же поднимается супервизором. Тоже вполне себе рабочий подход при определённых ситуациях.

[Тимур Шемсединов]

Согласен, что таймаут нужно тоже продлевать, чтобы не приходилось часто переподключаться.

[Александр Прозоров]

Тимур Шемсединов: на практике, отключение по таймауту происходит например ночью, если на ресурс никто не заходит. Таймаут длинной в неделю в этом случае с запасом решает этот вопрос. А так, каждое обращение к sql-серверу этот таймаут и продлевает.

Answer 3

[Тимур Шемсединов]

Вообще нужно логировать вывод, он же не просто падает, а что-то говорит, наверняка, или ошибка или память закончилась. Скорее всего у вас отпадает connection и следующие запросы не проходят, нужно сделать переподключение, вынесите соединение в function openConnection и повесьте событие, примерно так connection.on('error', function(err) { if (err.code === 'PROTOCOL_CONNECTION_LOST') openConnection(); });
И пожалуйста, не клейте SQL из строк, используйте параметры запросов. Тут вот моя библиотечка старая, в ней примеры и дополнительные удобства: https://github.com/tshemsedinov/node-mysql-utilities

Comments

[Александр Прозоров]

Кстати, спасибо вам на модуль node-mysql-utilities. Использую его с момента публикации статьи на хабре.

[Тимур Шемсединов]

Эх, а мне ее так и не довелось использовать ни в одном реальном проекте, даже поддерживать толком не успеваю, там многое нужно зарефакторить вообще, обновил малость сейчас.

Answer 4

[Сергей Сулаков]

Еще как вариант: создавать не соединение, а пул

const pool = mysql.createPool({
    host     : 'localhost',
    user     : 'root',
    password : '',
    database : 'chat'
});

а затем "получаем" соединение:

pool.getConnection(function(err, connection) {
	if(err) {
		console.log(err);
	}
	let sql = "SELECT * FROM `table`";
	connection.query(sql, [], function(err, results) {
		connection.release(); // always put connection back in pool after last query
		console.log(results);
		if(err) {
			console.log(err);
		}
	});
});

Comments

[anakondoz]

pool решил мою проблему, спасибо

Answer 5

[AlSutman]

Я решил проблему след образом: поставил pm2, это менеджер процессов, и стартанул свое приложение через pm2 start npm -- start и каждый раз, когда что-то падает, он просто перезапускается, еще ни разу не подвел, очень рекомендую.

Answer 6

[Азиз Мамоян]

Делайте собственную функцию для запросов. 
Если запрос не прошел - Пробуем подключиться к базе еще раз и затем заново выполнить запрос.
Если вторая попытка тоже не прошла - возвращаем пустой ответ, чтобы не было ошибок на стороне сервера и он не крахнулся.


let mysqldb = require("mysql");
let mysql = null;

function connect(callback=null){
    console.log("MYSQL TAKE CONNECT");
    mysql=mysqldb.createConnection({host: "localhost", user: "*", password: "*", database:"*"});
    mysql.on('error', function(err) {
      console.log("---" +err.message);
      console.log("---" +err.code);
    });
  if(callback)setTimeout(callback,100);
}

connect();//Первичное подключение


//Функция для запросов к базе
function my_mysql_query_function(q, paramas, callback=null, reconnect=true){
//Пробуем сделать запрос
    mysql.query(q,paramas,function(err,rows){
      if(err){//Запрос не прошел
        console.log("mysql_query failed! calling again...");
        if(reconnect)//Если разрешено  повторить попытку
          connect(function(){ //Переподключаемся к базой
           my_mysql_query_function(q,params,callback,false);//Повторяем заново с меткой false == больше не пробовать 
          });
        else callback([]); //Если нельзя больше пробовать подключаться - возвращаем пустой массив ответа
      }else{
        if(callback) callback(rows); // если запрос успешный то возвращаем массив ответа
      }
    });
}

Comments

[Азиз Мамоян]

Много попыток выполнить запрос делать не надо, так как пользователей может быть тысячи и они так нагрузят сервер. 1 попытку только. Пусть возвращает пустой ответ или ответ с ошибкой, но в любом случаи клиент может повторить запрос, а сервер не крахнется