Nodejs中mongoskin处理bind后的函数时似乎有问题

Node.js 中 Mongoskin 处理 bind 后的函数时似乎存在问题

问题描述

在使用 mongoskin 绑定集合并定义自定义方法时，发现这些方法在并发执行时表现得像是串行的。这可能是因为 mongoskin 在处理这些绑定方法时存在某些限制或问题。

示例代码

// 使用 mongoskin 进行操作
var mongo = require('mongoskin');
var db = mongo.db("localhost:27017/test", {native_parser:true});

db.bind('tag', {
    inc: function(name) {
        console.log('function inc');
        this.update({name: name}, {'$inc': {count: 1}}, {upsert: true}, function() {
            console.log('inc callback');
        });
    },
    
    dec: function(name) {
        console.log('function dec');
        var self = this;
        self.update({name: name}, {'$inc': {count: -1}}, {upsert: true}, function() {
            console.log('dec callback');
            self.findOne({name: name}, function(error, item){
                if (item && item.count <= 0) {
                    self.remove(item);
                }
            })
        });
    },
    
    all: function(callback) {
        console.log('function all');
        this.find().toArray(callback);
    }
});

for (var i = 0; i < 1000; i++) {
    db.tag.inc('电影');
}

for (var i = 0; i < 500; i++) {
    db.tag.dec('电影');
}

db.tag.all(function(err, data) {
    console.log('all callback');
    for (var index in data) {
        console.dir(data);
    }
});

观察结果

多次运行上述代码，可以看到所有的 inc 和 dec 操作似乎是串行执行的，而不是并发的。这意味着 mongoskin 可能在处理这些操作时存在某种同步机制。

对比 Mongoose

为了验证问题是否出在 mongoskin 上，我们使用 mongoose 重写了相同的功能：

var mongoose = require('mongoose');
var Schema   = mongoose.Schema;

mongoose.connect('mongodb://localhost/testdb2');

var TagSchema = new Schema({
    name  : { type: String, index: true },
    count : { type: Number },
});

TagSchema.statics.inc = function(name) {
    console.log('function inc');
    this.update({name: name}, {'$inc': {count: 1}}, {upsert: true}, function() {
        console.log('inc callback');
    });
};

TagSchema.statics.dec = function(name) {
    console.log('function dec');
    var self = this;
    self.update({name: name}, {'$inc': {count: -1}}, {upsert: true}, function(error) {
        console.log('dec callback');
        if (error) {
            return;
        }

        self.findOne({name: name}, function(error, item) {
            if (error) {
                return;
            }

            if (item && item.count <= 0) {
                item.remove();
            } 
        });
    });
};

TagSchema.statics.all = function(callback) {
    console.log('function all');
    this.find().sort({count: -1}).exec(callback);
};

var Tag = mongoose.model('Tag', TagSchema);

for (var i = 0; i < 1000; i++) {
    Tag.inc('电影');
}

for (var i = 0; i < 500; i++) {
    Tag.dec('电影');
}

Tag.all(function(err, data) {
    console.log('all callback');
    for (var index in data) {
        console.dir(data);
    }
});

观察结果

使用 mongoose 时，inc 和 dec 操作是并发执行的，而不是串行的。这表明问题确实出在 mongoskin 的处理方式上。

结论

mongoskin 在处理绑定方法时可能存在某种同步机制，导致并发操作表现得像是串行的。如果需要并发处理，建议考虑使用其他库如 mongoose。