我试图做一些相对简单的事情,每次我尝试执行“插入”操作时,突然遇到“服务器...- a.mongolab.com:36648套接字关闭”错误。
读取似乎没有错误,但每次插入似乎都会出错,而且我不确定这是我的代码(最近进行了一些小的更改)还是我在MongoLab使用的免费服务器的可靠性问题(其中最近显示自己崩溃了几分钟)。
奇怪的是,记录本身似乎还可以保存,我只是把错误找回了!
谁能看到我的代码有问题,或者还有其他问题吗?
var mongoClient = require('mongodb').MongoClient;
var http = require('http');
var connectionString = "...";
var pictureWallsCollectionName = 'PictureWalls';
//this is what barfs. see *** details
exports.saveWall = function (req, res) {
//reformat
var toSave = {
_id: req.body.wallId,
pictures: req.body.pictures
};
var status;
mongoClient.connect(connectionString, function (err, db) {
if (err) { return console.error(err); }
var collection = db.collection(pictureWallsCollectionName);
//*** no err yet... ***
collection.insert(
toSave,
function (error, response) {
//*********************
//*** err here! ******
//*********************
db.close();
if (error) {
console.error(error);
//bad
status = 500;
}
else {
console.log('Inserted into the ' + collection_name + ' collection');
//good
status = 200;
}
});
response.status(status).end(http.STATUS_CODES[status]);
});
}
//this seems to work pretty reliably. including it just in case it's relevant
exports.findByWallId = function (req, res) {
var id = req.params.id;
console.log('Retrieving wall: ' + id);
mongoClient.connect(connectionString, function (err, db) {
if (err) { return console.dir(err); }
var collection = db.collection(pictureWallsCollectionName);
collection.findOne(
{ _id: id },
function (err, item) {
db.close();
if (err) {
console.error(err);
//something bad happened
var status = 500;
res.status(status).end(http.STATUS_CODES[status]);
}
else {
console.log('Found wall with ID ' + id);
//reformat and send back in the response
res.send({
wallId: item._id,
pictures: item.pictures
});
}
}
);
});
};
最佳答案
编辑:我最初的问题的一部分是重复的参数名称。有关详细信息,请参见链接的问题。
原始回应:
问题最终是我调用我的:
res.status(status).end(http.STATUS_CODES[status]);
...在异步插入完成之前,因此将其倒空。
但是,我不确定在这种情况下如何发出响应。在这里查看我的新问题:
How Do I Properly Issue Response To Post When Waiting For Async Method To Complete?