使用 mongodb 制作具有排序和分页功能的动态联系人聊天列表

Question

我需要使用 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);
                    }
                }
            });
        }
    }
});

Answer 1

分页可以在 MongoDB 中以多种方式实现。

您可以使用limit 和offset，尽管在请求更高页面时这会变慢。

另一种方法是将greaterThan 与您看到的最后一个联系人一起使用limit 来获取接下来的15 个联系人。

无法轻松防止不一致（如果在寻呼期间发送新消息）。

也就是说，MongoDB 可能不是实时聊天的好选择，因为它不支持流式查询。