Nodejs Socket повесить трубку и ECONNRESET - HTTP-запрос от Meteor до Node js server

Я использую сервер node для обработки всех моих служб push-уведомлений, таких как gcm и apn.

У меня есть 2 разных сервера. Один запускает Meteor, а другой работает Node.JS для обработки push-уведомлений. (Оба являются разными серверами)

Мое главное приложение работает на сервере Meteor.

Я отправляю HTTP-запрос на сервер Node.js для отправки уведомлений.

Обычно он работает нормально, но иногда на сервере Meteor я получаю эту ошибку всякий раз, когда я вызываю сервер Node.js:

И вот мой код со стороны Метеор, где я делаю HTTP-запрос на сервер node js:

Может ли кто-нибудь вести меня в правильном направлении? Кроме того, я был бы очень признателен за то, что вы также знаете некоторые хорошие практики.

Есть еще одна проблема, с которой я столкнулся. Мой сервер Node.js завершает работу через 24 часа. Я не знаю, почему это происходит. Он выходит без каких-либо ошибок или исключений в терминальной консоли. Я должен перезапустить его каждый раз.

Ответы

Ответ 1

Хорошо, я сам нашел эту проблему. Его код сервера node. Я положил return в оператор switch, который не является допустимым способом для возврата ответа в выражении, поэтому я просто удалил возврат из:

До:

switch (callType) {
   case 'systemPushNotifications':
      return pushNotificationClass.sendPushNotificationsV2(response);
   break;
}

Теперь:

switch (callType) {
   case 'systemPushNotifications':
      pushNotificationClass.sendPushNotificationsV2(response);
   break;
}

Вышеупомянутый return завершал код перед: res.send("OK");

Ответ 2

Учитывая, что ошибка ECONNRESET обычно возникает, когда * другая сторона TCP connection закрыта внезапно.

В случае вашей заявки это может быть связано с overloading сервера и просто убивает соединение в качестве возврата, которое аналогичным образом блокирует соединение с вашим meteor server

Чтобы получить дополнительную информацию об ошибке, упомянутой в этом потоке. Чтобы обработать ошибку, вы должны использовать event listener для отображения полного stack traces этого

Как упоминалось в этой теме Farid Nouri Neshat

Чтобы иметь одного слушателя для группы вызовов, вы можете использовать домены, а также улавливать другие ошибки во время выполнения. Убедитесь, что каждая операция async, связанная с http (Server/Client), находится в другом контексте domain по сравнению с другими частями кода, домен будет автоматически прослушивать события ошибки и будет распространять его на свой собственный обработчик. Поэтому вы только слушаете этого обработчика и получаете данные об ошибках.

но поскольку домен уже устарел, вы должны использовать кластеры, как указано здесь, в docs, который использует server.listen(message) и server.listen(handle)

или вы также можете использовать NODE_DEBUG=net или использовать strace

Обновление

Для отключения сервера я думаю, что ошибка может заключаться в обработке bodyparser. Для плохого файла json ошибка не показана.

Node действие по умолчанию после неперехваченного исключения - это exit (crash) в процессе.

Обработка bodyparser для json файла может быть выполнена следующим образом.

var parseJson = bodyPaser.json();

app.use(function (req, res, next) {
    req.getBody = function (callback) {
        parseJson(req, res,function (err) {
          callback(err, req.body);
        });
    };
    next();
});

Ссылка, взятая из открытой проблемы GITHUB здесь

Обновление 2

В основном socket hangup означает, что сокет не завершает соединение в течение указанного периода времени

В соответствии с source вы можете видеть, что это происходит, если сервер никогда не отправляет ответ

.Эту ошибку следует поймать и обработать с помощью

Повторить запрос.
обработать его позже, установив больше time period или поместив res.end() в конец вашей функции, чтобы завершить соединение.
или вы можете использовать [http.get()][8] с запросами get, которые автоматически вызовут функцию req.end()

Надеюсь, это поможет вам немного! Ура!