diff --git a/frontend/src/services/websocket.js b/frontend/src/services/websocket.js
index 73a1563..297855c 100644
--- a/frontend/src/services/websocket.js
+++ b/frontend/src/services/websocket.js
@@ -267,11 +267,17 @@ class WebSocketService {
   _onMessage(data) {
     try {
       const msg = JSON.parse(data)
-      // Task 9：ACK 报文（event 以 ".ack" 结尾）走 pendingAcks 处理
+      // Task 9：ACK 报文（event 以 ".ack" 结尾）会先走 pendingAcks 处理
       // 后端 ws.NewResponse 固定在原 event 后追加 ".ack"
+      //
+      // 修复（2026-04-23）：历史实现在命中 _handleAck 后直接 return，
+      // 导致通过 on('xxx.ack') 订阅 ACK 事件的 listener（chat store 的
+      // _onSendACK / _onReadACK）永远收不到回调，表现为
+      // "发送方消息一直卡在 _sending=true，气泡下方不显示 已读/未读"。
+      // 两条通路互不冲突：sendWithAck() 按 seq 命中 pending；
+      // on('xxx.ack') 按 event 命中 listener。此处改为并行分发。
       if (typeof msg.event === 'string' && msg.event.endsWith('.ack')) {
         this._handleAck(msg)
-        return
       }
       this._emit(msg.event, msg)
     } catch (e) {
diff --git a/frontend/src/store/chat.js b/frontend/src/store/chat.js
index d6421e2..dc92918 100644
--- a/frontend/src/store/chat.js
+++ b/frontend/src/store/chat.js
@@ -507,19 +507,42 @@ export const useChatStore = defineStore('chat', () => {
 
   // ==================== 内部工具方法 ====================
 
-  /** 追加消息到缓存（带去重检查，防止重连/ACK 导致重复） */
+  /**
+   * 追加消息到缓存
+   *
+   * 去重 + 临时消息合并（2026-04-23 加固）：
+   *   - 若已存在同 id 的消息：真重复，直接丢弃
+   *   - 若匹配到相同 client_msg_id 的本地临时消息（_sending=true）：
+   *     就地把服务端权威字段（id/created_at/...）合并进去，并清除
+   *     _sending / _failed 标记；这样即使 ACK 丢失、但广播帧到了，
+   *     也能把发送方的"转圈"状态变成已入库可读/未读态，避免 UX 卡死
+   *   - 否则追加一条新消息
+   */
   const _appendMessage = (conversationId, message) => {
     if (!messagesMap.value[conversationId]) {
       messagesMap.value[conversationId] = []
     }
     const list = messagesMap.value[conversationId]
-    const isDup = list.some(m =>
-      (message.id && m.id === message.id) ||
-      (message.client_msg_id && m.client_msg_id === message.client_msg_id)
-    )
-    if (!isDup) {
-      list.push(message)
+
+    if (message.id) {
+      const idIdx = list.findIndex(m => m.id === message.id)
+      if (idIdx !== -1) return
     }
+
+    if (message.client_msg_id) {
+      const tmpIdx = list.findIndex(m => m.client_msg_id === message.client_msg_id)
+      if (tmpIdx !== -1) {
+        list[tmpIdx] = {
+          ...list[tmpIdx],
+          ...message,
+          _sending: false,
+          _failed: false
+        }
+        return
+      }
+    }
+
+    list.push(message)
   }
 
   /** 更新会话列表中的预览信息 */