使用Firebase-iOS监听实时聊天数据时App崩溃问题排查

嘿，我看了你遇到的问题——当两个用户同时在聊天室时App崩溃，错误是Thread 1: EXC_BAD_INSTRUCTION (code=EXC_I386_INVOP, subcode=0x0)，出现在消息监听的函数里。结合你的代码，我梳理了几个核心问题和对应的修复方案：

一、崩溃的核心原因分析 #

你的代码里有几个很容易在并发场景下触发崩溃的风险点：

• 随处可见的强制解包（!）：比如chatRoomId!、uid!、messageData["senderId"] as! String!，当并发操作导致数据未同步完全时，这些可选值可能为nil，直接触发崩溃。
• .childChanged回调里的不安全类型转换：你用了let messageData = snapshot.value as! Dictionary<String, String>强制转换，一旦Firebase返回的数据不是严格的[String:String]（比如包含数字、布尔值，或者并发更新导致数据临时不一致），就会崩溃。
• UI操作不在主线程：Firebase的回调是在后台线程执行的，但你直接在回调里调用self.messages.append(message)、self.finishReceivingMessage()这类UI方法，并发场景下多线程操作UI必然会导致不可预测的崩溃。
• 重复添加监听：每次视图出现都调用observeMessages，会重复注册Firebase监听，多个监听同时触发时会导致数据混乱。

二、具体修复步骤 #

1. 把所有强制解包换成安全的可选绑定 #

先处理那些可能为nil的可选值，比如在函数开头就做校验：

private func observeMessages() {
    // 先校验必要的可选值，避免后续强制解包崩溃
    guard let chatRoomId = chatRoomId, let uid = uid else {
        print("缺少必要的聊天室ID或用户ID")
        return
    }
    
    messageRef = ref.child("ChatRooms").child(chatRoomId).child("Messages")
    let messageQuery = messageRef.queryLimited(toLast:25)
    
    // 后续代码...
}

对于消息数据的取值，也用可选绑定替代强制转换：

// 替换原来的强制解包写法
if let id = messageData["senderId"] as? String, let photoURL = messageData["photoURL"] as? String {
    // 处理图片消息逻辑
}

2. 修复.childChanged的类型转换问题 #

把危险的强制转换改成可选绑定，兼容可能的数据类型：

updatedMessageRefHandle = messageRef.observe(.childChanged, with: { (snapshot) in
    let key = snapshot.key
    // 用可选绑定安全解析数据
    guard let messageData = snapshot.value as? [String: AnyObject], 
          let photoURL = messageData["photoURL"] as? String else {
        print("解析childChanged的消息数据失败")
        return
    }
    
    // 图片更新逻辑放到主线程执行
    if let mediaItem = self.photoMessageMap[key] {
        DispatchQueue.main.async {
            self.fetchImageDataAtURL(photoURL, forMediaItem: mediaItem, clearsPhotoMessageMapOnSuccessForKey: key)
        }
    }
})

3. 所有UI操作必须切换到主线程 #

Firebase回调在后台线程，所以所有更新UI的代码都要包在DispatchQueue.main.async里：

// 添加文本消息到列表时
if let message = JSQMessage(senderId: id, senderDisplayName: name, date: Date(timeIntervalSince1970: time), text: text) {
    DispatchQueue.main.async {
        self.messages.append(message)
        self.finishReceivingMessage()
    }
}

// 添加图片消息时
if let mediaItem = JSQPhotoMediaItem(maskAsOutgoing: id == self.senderId) {
    DispatchQueue.main.async {
        self.addPhotoMessage(withId: id, key: snapshot.key, mediaItem: mediaItem)
    }
    if photoURL.hasPrefix("gs://") {
        self.fetchImageDataAtURL(photoURL, forMediaItem: mediaItem, clearsPhotoMessageMapOnSuccessForKey: nil)
    }
}

4. 移除重复的监听 #

在视图消失时移除Firebase的监听，避免重复注册：

override func viewWillDisappear(_ animated: Bool) {
    super.viewWillDisappear(animated)
    // 移除消息添加的监听
    if let handle = newMessageRefHandle {
        messageRef.removeObserver(withHandle: handle)
    }
    // 移除消息更新的监听
    if let handle = updatedMessageRefHandle {
        messageRef.removeObserver(withHandle: handle)
    }
}

三、额外优化建议 #

• 调试时可以在崩溃点加断点，查看snapshot.value的实际内容，确认是否和你预期的类型一致。
• 标记消息为已读的操作，建议用Firebase事务来避免并发冲突：

updateRead.runTransactionBlock({ (currentData) -> TransactionResult in
    var data = currentData.value as? [String: Any] ?? [:]
    data["status"] = "read"
    currentData.value = data
    return TransactionResult.success(withValue: currentData)
})

内容的提问来源于stack exchange，提问作者A. Albert