我试图做一些相对简单的事情,每次我尝试执行“插入”操作时,突然遇到“服务器...- 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?

10-08 19:30