基于Parse Server的聊天应用：如何获取每个远程对等方的最新消息

嘿，这个需求在Parse Server里确实没有直接的内置查询方法，但咱们可以用两种靠谱的方式实现——一种是简单直观的分步查询，另一种是用聚合管道高效处理，我给你详细讲讲：

方法一：分步查询（适合聊天对象不多的场景） #

思路很直接：先找出所有和当前用户有过聊天的对象列表，再对每个对象单独查询你们之间的最新一条消息。

假设你的消息类叫ChatMessage，核心字段有sender（Pointer<_User>类型，发送者）、recipient（Pointer<_User>类型，接收者）、content（消息内容）、createdAt（消息时间），代码示例如下：

const currentUser = Parse.User.current();

// 第一步：获取所有唯一的聊天对象ID
const peerQuery = new Parse.Query('ChatMessage');
peerQuery.or(
  peerQuery.equalTo('sender', currentUser),
  peerQuery.equalTo('recipient', currentUser)
);
peerQuery.select('sender', 'recipient'); // 只取需要的字段，提升效率
peerQuery.limit(1000); // 根据你的业务调整上限

const messages = await peerQuery.find();
const peerIds = new Set();

messages.forEach(msg => {
  const peer = msg.get('sender').id === currentUser.id ? msg.get('recipient') : msg.get('sender');
  peerIds.add(peer.id);
});

// 第二步：逐个查询每个聊天对象的最新消息
const latestMessages = [];
for (const id of peerIds) {
  const peer = new Parse.User();
  peer.id = id;

  const msgQuery = new Parse.Query('ChatMessage');
  msgQuery.or(
    // 当前用户发对方的消息
    msgQuery.and(
      msgQuery.equalTo('sender', currentUser),
      msgQuery.equalTo('recipient', peer)
    ),
    // 对方发当前用户的消息
    msgQuery.and(
      msgQuery.equalTo('sender', peer),
      msgQuery.equalTo('recipient', currentUser)
    )
  );
  msgQuery.descending('createdAt'); // 按时间倒序
  msgQuery.limit(1); // 只取第一条

  const latestMsg = await msgQuery.first();
  if (latestMsg) latestMessages.push(latestMsg);
}

// 最后可以把所有最新消息按时间重新排序
latestMessages.sort((a, b) => b.get('createdAt') - a.get('createdAt'));

方法二：聚合管道查询（高效，适合大量聊天对象的场景） #

Parse Server底层基于MongoDB，所以可以直接用MongoDB的聚合管道来实现「分组取最新」，只需要一次查询就能搞定，效率更高。

代码示例：

const currentUser = Parse.User.current();
const ChatMessage = Parse.Object.extend('ChatMessage');

// 构建MongoDB聚合管道
const pipeline = [
  // 第一步：筛选出所有和当前用户相关的消息
  {
    $match: {
      $or: [
        { 'sender.objectId': currentUser.id },
        { 'recipient.objectId': currentUser.id }
      ]
    }
  },
  // 第二步：计算出每个消息对应的聊天对象ID（peer）
  {
    $addFields: {
      peer: {
        $cond: {
          if: { $eq: ['$sender.objectId', currentUser.id] },
          then: '$recipient.objectId',
          else: '$sender.objectId'
        }
      }
    }
  },
  // 第三步：按时间倒序排序，确保最新的消息排在前面
  { $sort: { createdAt: -1 } },
  // 第四步：按聊天对象分组，每组只保留第一条（也就是最新的）消息
  {
    $group: {
      _id: '$peer',
      latestMessage: { $first: '$$ROOT' }
    }
  },
  // 第五步：把分组后的消息数据还原成原格式
  { $replaceRoot: { newRoot: '$latestMessage' } }
];

// 执行聚合查询
const latestMessages = await ChatMessage._query._aggregate(pipeline);
// 可选：再次按时间排序整个列表
latestMessages.sort((a, b) => new Date(b.createdAt) - new Date(a.createdAt));

注意事项 #

• 确保sender和recipient字段是Pointer类型，这样查询和聚合时的关联逻辑才会准确
• 聚合管道方法需要Parse Server 3.0及以上版本支持
• 如果用REST API调用，聚合管道的JSON格式和上面的JavaScript结构一致，直接传入即可

内容的提问来源于stack exchange，提问作者Emre Memis