我需要使用 nodejs 和 mongodb 建立聊天。在此聊天中,我需要通过订购最新帖子并应用每页分页 15 个项目来安装联系人列表。我想知道如何使用 mongodb/mongoose 动态地执行此操作。
例如,在第一页上,我会查找最后发送消息的人订购的联系人。如果加载第二页,并且有任何新消息到达,则聊天列表的顺序可能已更改。
我如何处理我的查询并进行这种处理?
我的用户架构是:
var schema = new Schema({
name: {type: String, required: true},
email: {type: String, required: true, unique: true},
password: {type: String, required: true, select: false},
created_at: {type: Date, required: true, default: Date.now}
});
我的消息架构是:
var schema = new Schema({
content: {type: String, required: true},
type: {type: String, required: true, default: 'text'},
status: {type: String, default: 'not_read'},
created_at: {type: Date, default: Date.now},
read_at: {type: Date},
userFrom: {type: Schema.Types.ObjectId, ref: 'User', required: true},
userTo: {type: Schema.Types.ObjectId, ref: 'User', required: true}
});
提前谢谢你。
编辑 1:
var itensPerPage = 15;
var skip = page !== undefined ? page * itensPerPage : 0;
pages = Math.ceil(pages / itensPerPage);
Message
.aggregate([
{ '$sort': {
'created_at': -1
}},
{ "$skip": skip },
{ "$limit": itensPerPage },
{ '$match': {
$or: [
{ userFrom: psychologist.id_user },
{ userTo: psychologist.id_user }
]
}},
{ '$group': {
'_id': {
'userFrom': '$userFrom',
'userTo': '$userTo'
},
}
},
])
.exec(function (err, id_users) {
if(err){
callback(new Error("Something went wrong while trying to agregate the psychologist users."), null);
}else{
var users_from_id_map = id_users.map(function(x) { return x._id.userFrom} );
var users_to_id_map = id_users.map(function(x) { return x._id.userTo} );
var chatlist = [];
var received = users_from_id_map.length;
for(var i = 0; i < users_from_id_map.length; i++){
Message
.findOne({$or : [{userFrom: users_from_id_map[i], userTo: users_to_id_map[i]}]})
.sort('-created_at')
.exec(function (err, message) {
if(err){
callback(new Error("Something went wrong while trying to find last message."), null);
}else{
if(message){
var user_chat_id;
if(psychologist.id_user.equals(message.userFrom)){
user_chat_id = message.userTo;
}else{
user_chat_id = message.userFrom;
}
var is_mine = false;
if(message.userFrom.equals(psychologist.id_user)){
is_mine = true;
}
chatlist.push({
id_user: user_chat_id,
lastMessage: {
content: (message.content.length > 35 ? message.content.substring(0,35)+"..." : message.content),
date: message.created_at,
is_mine: is_mine
}
});
}else{
chatlist.push({
id_user: user_chat_id,
lastMessage: null
});
}
received--;
if(received == 0){
next(err, psychologist, chatlist, pages);
}
}
});
}
}
});
最佳答案
分页可以在 MongoDB 中以多种方式实现。
您可以使用 limit
和 offset
尽管这在请求更高的页面时会变慢。
另一种方法是将 greaterThan
与您看到的最后一个联系人一起使用,同时使用 limit
来获得接下来的 15 个联系人。
无法轻易避免不一致(如果在寻呼期间发送新消息)。
也就是说,MongoDB 可能不是实时聊天的好选择,因为它不支持流式查询。
关于javascript - 使用 mongodb 制作具有排序和分页功能的动态联系人聊天列表,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40471857/