我正在使用节点服务器来处理我所有的推送通知服务,如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] }
要么
错误:读取ECONNRESET
在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 /服务器-LIB / node_modules /纤维/ future.js:398:15)
在Object.call(packages / meteor / helpers.js:119:1)
在Object.sendHttpCall(server / pushNotifications.js:249:1)
在server / pushNotifications.js:244:1
在[object Object] ._。extend.withValue(packages / meteor / dynamics_nodejs.js:56:1)
在packages / meteor / timers.js:6:1
在runWithEnvironment(packages / meteor / dynamics_nodejs.js:110:1)
- - - - -
在errnoException(net.js:905:11)
在TCP.onread(net.js:559:19)
这是我的Node.JS服务器代码:
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方面的代码,我在这里向节点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小时后退出。我不知道为什么会发生这种情况。它在终端控制台中没有任何错误或异常情况下退出。我必须每次都重新启动它。
发布于 2018-04-03 09:01:44
考虑到ECONNRESET错误通常发生在*的另一侧TCP connection
突然关闭时。
overloading
,并简单地将连接终止为返回,类似的方式阻止连接到你的连接meteor server
要获得有关此线程中提到的错误的更多信息。要处理错误,您必须使用event listener
它来显示完整stack traces
的错误
正如Farid Nouri Neshat在此主题中提到的那样
要为一组调用拥有一个侦听器,您可以使用域并在运行时捕获其他错误。确保与http(服务器/客户端)相关的每个异步操作与代码的其他部分处于不同的域环境中,域将自动侦听错误事件并将其传播到它自己的处理程序。所以你只能听那个处理程序并获取错误数据。
但由于域名已经被弃用,你应该使用集群作为在这里所提到的文档,其使用server.listen(message)
和server.listen(handle)
或者你也可以使用NODE_DEBUG=net
或使用strace
对于服务器断开连接,我认为错误可能在您处理bodyparser
。对于错误的 json
文件错误未被捕获。
在未捕获的异常之后,Node的默认操作是退出(崩溃)进程。
处理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的开放式问题所采取的参考是这里
基本上这socket hangup
意味着套接字不会在指定的时间段内结束连接
根据源代码可以看到,如果服务器从不发送响应,就会发生这种情况
这个错误应该被捕获和处理
time period
或放在您的函数res.end()
的结尾来结束连接来处理它。[http.get()][8]
这些get
请求用于自动调用该req.end()
函数希望它可以帮助你一点!干杯!
发布于 2018-04-03 10:45:00
好的,我在这里发现了这个问题。它在节点服务器代码中。我把return放在一个switch语句中,这不是用express来返回响应的有效方法,所以我只是删除了返回值:
之前:
switch (callType) {
case 'systemPushNotifications':
return pushNotificationClass.sendPushNotificationsV2(response);
break;
}
现在:
switch (callType) {
case 'systemPushNotifications':
pushNotificationClass.sendPushNotificationsV2(response);
break;
}
以上return
是在以下情况之前终止代码:res.send("OK");
https://stackoverflow.com/questions/-100007930
复制相似问题