我正在使用 Node 服务器来处理我的所有推送通知服务，例如 gcm 和 apn。

我有 2 台不同的服务器。一个运行 Meteor，另一个运行 Node.JS 来处理推送通知。 (两者都是不同的服务器)

我的主应用在 Meteor 服务器上运行。

我向 node.js 服务器发出 HTTP 发布请求以发送我的通知。

通常它工作正常，但有时在 Meteor 服务器上，每当我调用 node.js 服务器时都会收到此错误:

socket hang up\n    at Object.Future.wait (/home/myPc/.meteor/packages/meteor-tool/.1.1.10.ki0ccv++os.linux.x86_64+web.browser+web.cordova/mt-os.linux.x86_64/dev_bundle/server-lib/node_modules/fibers/future.js:398:15)\n    at Object.<anonymous> (packages/meteor/helpers.js:119:1)\n    at Object.HTTP.call (packages/meteorhacks_kadira/lib/hijack/http.js:10:1)\n    at Object.sendPushNotificationsMeteorServer (server/pushNotifications.js:249:1)\n    at server/classes/pushNotifications.js:244:1\n    at [object Object]._.extend.withValue (packages/meteor/dynamics_nodejs.js:56:1)\n    at packages/meteor/timers.js:6:1\n    at runWithEnvironment (packages/meteor/dynamics_nodejs.js:110:1)\n    - - - - -\n    at createHangUpError (http.js:1473:15)\n    at Socket.socketOnEnd [as onend] (http.js:1569:23)\n    at Socket.g (events.js:180:16)\n    at Socket.emit (events.js:117:20)\n    at _stream_readable.js:944:16\n    at process._tickCallback (node.js:448:13)',
details: { [Error: socket hang up] stack: [Getter] },
data: { [Error: socket hang up] stack: [Getter] },
user: null,
userId: null,
toString: [Function] },
user: null,
userId: null,
toString: [Function] }

或

 Error: read ECONNRESET
     at Object.Future.wait (/home/mbm/.meteor/packages/meteor-tool/.1.1.10.12ml1tp++os.linux.x86_64+web.browser+web.cordova/mt-os.linux.x86_64/dev_bundle/server-lib/node_modules/fibers/future.js:398:15)
     at Object.call (packages/meteor/helpers.js:119:1)
     at Object.sendHttpCall (server/pushNotifications.js:249:1)
     at server/pushNotifications.js:244:1
     at [object Object]._.extend.withValue (packages/meteor/dynamics_nodejs.js:56:1)
     at packages/meteor/timers.js:6:1
     at runWithEnvironment (packages/meteor/dynamics_nodejs.js:110:1)
     - - - - -
     at errnoException (net.js:905:11)
     at TCP.onread (net.js:559:19)

Here is my Node.JS server code:

realFs                = require('fs');
var gracefulFs        = require('graceful-fs');
gracefulFs.gracefulify(realFs);

var http              = require('http');
var express           = require('express');
var app               = express();

var path              = require("path");

configClass           = require('./classes/config.js').configClass;
helperClass           = require('./classes/helper.js').helperClass;
pushNotificationClass = require('./classes/pushNotification.js').pushNotificationClass;

var hostname          = 'http://localhost'; 
var port              = 6000;

var bodyParser        = require('body-parser');

nodeGcm               = require('node-gcm');
apn                   = require('apn');
apnService            = new apn.Connection(helperClass.getAPNOptions());

// -- BODY PARSER -- //
app.use(bodyParser.json({limit: '50mb'}));
app.use(bodyParser.urlencoded({limit: '50mb', extended: true}));

process.on('uncaughtException', function (err) {

  console.error(err);
  console.log("Node NOT Exiting...");
});

// All post requests
app.post('/', function(req, res){

  try {

    var response = JSON.parse(req.body.pushNotificationApiParams);
    var callType = req.body.callType;

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

    console.dir(e.stack);
    realFs.appendFile('errorLogs/'+helperClass.getCurrentDateFormated()+'.log', helperClass.formatLog('Exception in main Post Method  : '+e.stack) , function (err) {
      if (err) throw err;
    });
  }

  res.send("OK");
});



app.listen(port, function () {
  console.log('Listening at '+hostname+':'+port);
});

这是我来自 Meteor 端的代码，我在其中向 Node js 服务器发出 HTTP 发布请求:

var headers = {
   'Content-Type' : 'application/x-www-form-urlencoded'
};

var postFields = {
   callType : 'systemPushNotifications',
   pushNotificationApiParams  : JSON.stringify(pushNotificationApiParams)   // contains push notifications data                 
};

HTTP.call("POST", 'http://localhost:6000', { params:postFields, headers:headers });

谁能指引我正确的方向？此外，我也非常希望了解一些好的做法。

还有

我还面临一个问题。我的 node.js 服务器在 24 小时后退出。我不知道为什么会这样。它在终端控制台中退出，没有任何错误或异常。我每次都必须重新启动它。

最佳答案

考虑到ECONNRESET错误通常发生在TCP连接的*另一端突然关闭时。

• 如果您的申请 这可能是由于服务器的 overloading 并且简单地终止连接作为返回，它以类似的方式阻止与您的 meteor 服务器

要获得有关此 thread 中提到的错误的更多信息. 要处理错误，您必须使用 event listener 来显示它的完整 stack traces

正如 Farid Nouri Neshat 在此线程中所述

To have one listener for a group of calls you can use domains and also catch other errors on runtime. Make sure each async operation related to http(Server/Client) is in different domain context comparing to the other parts of the code, the domain will automatically listen to the error events and will propagate it to it's own handler. So you only listen to that handler and get the error data.

但由于该域已被弃用，您应该使用 docs 中提到的集群。它使用 server.listen(message) 和 server.listen(handle)

或者您也可以使用 NODE_DEBUG=net 或使用 strace

更新

对于 server disconnect，我认为错误可能出在您的 bodyparser 处理中。对于 bad> json 文件 错误未被捕获。

Node's default action following an uncaught exception is to exit(crash) on the process.

可以通过以下方式处理 json 文件的 bodyparser。

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 开放问题的 here

更新 2

基本上socket hangup表示socket没有在指定时间段内结束连接

根据source你可以看到它发生如果服务器从不发送响应

.这个错误应该被任何一方捕获和处理

• 正在重试请求。
• 稍后通过设置更多时间段或将res.end()放在函数的末尾来结束连接。
• 或者您可以将 [http.get()][8] 与 get 请求一起使用，该请求将自动调用 req.end()函数

希望对你有所帮助!干杯!

关于javascript - Nodejs Socket 挂断和 ECONNRESET - 从 Meteor 到 Node js 服务器的 HTTP 发布请求，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41241938/