【发布时间】：2018-11-27 21:57:12
【问题描述】：
我构建了一个简单的 MERN 应用，用户可以在其中对电话号码进行评分。用户只需填写电话号码，选择评级（1 - 5 星评级），他们的城市和短文本。该应用程序具有过滤和排序选项的搜索功能。这一切都足够好 ATM 但我认为当多个并发用户使用该网站时它可能会中断，因为我在提交评级 (messageSchema) 后更新了电话号码模型 (mobileSchema) - 使用 Mongoose 中间件 (post hooks)。
例如，我需要计算电话号码的评分数 (messagesCount)。我为此使用Message.countDocuments({ mobile: mobile._id })。但是，我还需要更新电话号码的其他属性（mobileSchema - lastMessageDate、globalRating、averageRating），以便操作需要一些时间。我相信当 2 个用户同时提交评分时，评分数量可能不正确 - 它会将评分数量 (messagesCount) 增加 1 而不是 2。
有没有更好的方法？可以在前一个 post hook 完成后触发 post hook 吗？
示例代码：
const mobileSchema = new Schema({
number: { type: String, required: true },
plan: { type: String, required: true },
date: { type: Date, default: Date.now, required: true, index: 1 },
messagesCount: { type: Number, default: 0, index: 1 },
lastMessageDate: { type: Date, index: 1 },
// normal mean
globalRating: { type: Number, default: 0, index: 1 },
// weighted mean
averageRating: { type: Number, default: 0, index: 1 }
});
const messageSchema = new Schema({
comment: { type: String, required: true },
city: { type: Schema.Types.ObjectId, ref: 'City', required: true, index: 1 },
rating: { type: Number, required: true, index: 1 },
date: { type: Date, default: Date.now, required: true, index: 1 },
mobile: { type: Schema.Types.ObjectId, ref: 'Mobile', required: true },
user: { type: Schema.Types.ObjectId, ref: 'User', required: true }
});
messageSchema.post('save', function (message, next) {
const messageModel = this.constructor;
return updateMobile(messageModel, message, next, 1);
});
const updateMobile = (messageModel, message, next, addMessage) => {
const { _id } = message.mobile;
const cityId = message.city._id;
const lastMessageDate = message.date;
let mobile;
hooks.get(Mobile, { _id })
.then(mobileRes => {
mobile = mobileRes;
return Message.countDocuments({ mobile: mobile._id })
})
.then(messagesCount => {
if (messagesCount <= 0) {
const deleteMobile = Mobile.findOneAndDelete({ _id: mobile._id })
const deleteSeen = SeenMobile.findOneAndDelete({ mobile: mobile._id, user: message.user._id })
const cityMobile = updateCityMobile(messageModel, mobile, cityId)
Promise.all([deleteMobile, deleteSeen, cityMobile])
.then(() => {
return next();
})
.catch((err) => {
console.log(err);
return next();
})
}
else {
if (addMessage === -1) lastMessageDate = mobile.lastMessageDate;
const ratings = hooks.updateGlobalRating(mobile, messageModel)
.then(() => hooks.updateAverageRating(mobile, messageModel))
.then(() => {
return new Promise((resolve, reject) => {
mobile.set({
messagesCount,
lastMessageDate
});
mobile.save((err, mobile) => {
if (err) return reject(err);
resolve();
});
})
})
const cityMobile = updateCityMobile(messageModel, mobile, cityId)
Promise.all([ratings, cityMobile])
.then(([ratings, cityMobile]) => {
return next();
})
.catch(err => console.log(err))
}
})
.catch(err => {
console.log(err);
})
}
【问题讨论】：
-
不直接与猫鼬相关，但here 是关于写操作的讨论。根据该信息，我会说写操作完成后会触发 post hook，但我没有检查 mongoose 文档。
标签： javascript mongodb express mongoose