如果我可以从实时数据库中获取最后一个键（最新消息），是否有可能？

Question

我想从我的实时数据库中获取最后一个密钥（最新消息），但不确定如何实现。 我从这个链接i need to get Last child of my firebase databse 看到我可以使用 orderByKey().limitToLast(1) 来获得它，但看起来我需要指定完整的 ref 才能实现这一点。那是对的吗？或者如果我可以在 val() 上 orderByKey().limitToLast(1) 有可能吗？还是有另一种方法可以实现这一目标？ 这是我在数据库中的消息结构：

我在每个键下都有一个时间戳子，如上所示，我想我可以查询它以提取最新的键，但我真的不知道该怎么做。有人可以帮忙吗？以下是我目前的代码：

database().ref(`messages/`).once(`value`, snapshot => {
 if(snapshot.exists()) {
   snapshot.forEach(function (childSnapshot) {
      if(childSnapshot.key.includes(auth().currentUser.uid)) {
      console.log("show me the key: "+childSnapshot.key)

      //not working
      console.log("show last message: "+ JSON.stringify(childSnapshot.val().orderbyKey().limitToLast(1)))
      }
    })
  }
})

console.log(JSON.stringify(messages)) => [{"-MfqYBzbusp1Cljgxpan":{"unreadMessage":true,"user":{"name":"Mike","avatar":"xxxxxx" ,"_id":"tFhmw5oQoPhk8nF2sx5rE5BFqw93"},"timestamp":1627634061437,"senderId":"tFhmw5oQoPhk8nF2sx5rE5BFqw93","notification":{"body":"Hey","title":"Project","imageUrl":" ./assets/xxxxx.png"},"text":"嘿"}}]

console.log(JSON.stringify(unreadMsgs)) => []

Answer 1

Firebase 实时数据库查询适用于平面节点列表。因此，如果您已经有特定路径 /messages/nodeid，您可以在该路径下找到最新消息，但您无法在所有 /messages 中找到最新消息。

读取来自所有聊天室的所有消息，只是为了找到该用户所在的每个聊天室的最新消息确实很浪费。随着您向应用中添加更多用户，您会增加他们的带宽成本，也会增加您自己的带宽成本。

我建议保留一个单独的节点来跟踪每个用户的聊天室，正如我在Best way to manage Chat channels in Firebase 上的回答中所解释的那样。使用这样的节点，您可以轻松地确定当前用户的聊天室，然后为每个用户加载最新消息，例如：

database().ref(`user_chatrooms/${auth().currentUser.uid}`).once(`value`, indexSnapshot => {
  indexSnapshot.forEach((indexSnapshotChild) => {
    let chatroomId = indexSnapshotChild.key;
    let query = database().ref(`messages/${chatroomId}`).orderByChild("timestamp").limitToLast(1)
    query.once(`value`, (msgSnapshot) => {
      console.log(`Last message in ${chatroomId} was ${msgSnapshot.val().text}`);
    })
  }
})

Answer 2

orderByKey 和 limitToLast 方法存在于 DatabaseReference 上，而不是您从之前获取的快照中获取的值上。似乎所有消息的父键格式为userId1userId2。如果您知道这种组合，那么您可以通过这种方式运行查询。

const uidsKey = "uid1" + "uid2"
const query = database().ref(`messages/${uidsKey}`).orderByChild("timestamp").limitToLast(1)

query.once("value").then((snapshot) => {
  console.log(snapshot.val())
})

但您似乎正在尝试获取与 user1 聊天的其他用户的 UID，并尝试首先访问所有节点。我不建议这样做，因为这可能会导致安全规则等问题。相反，如果您将这些 UID 列表保留在其他地方，那就更好了。但是如果你想保留你现在拥有的东西，试试这个：

const userUID = auth().currentUser.uid

database().ref("messages/").once("value").then(async (msgSnapshot) => {
  const keys = Object.keys(msgSnapshot.val() || {})
  const userChatKeys = keys.filter(k => k.includes(userUID))
  //const otherUserIDs = userChatKeys.map(k => k.replace(userUID, ""))

  //userChatKeys will be chat IDs where current user is included
  //now follow the same steps mentioned in first code snippet
  const queries = userChatKeys.map(chat => database().ref(`messages/${chat}`).orderByChild("timestamp").limitToLast(1).once("value"))
  const lastMessagesSnap = await Promise.all(queries)
  
  const messages = lastMessagesSnap.map(m => Object.values(m.val())[0])) 
  console.log(`messages: ${messages}`)
  const unreadMsgs = messages.filter((msg) => msg.unreadMessage === true)
  console.log(unreadMsgs.length)
})

这将记录每个用户聊天的最后一条消息。