IndexedDB 事务错误处理与失败恢复模式

概述IndexedDB 在并发或约束条件下可能产生事务失败。本文给出错误捕获与重试封装，并配合队列持久化提升稳定性。事务重试封装async function withRetry(fn, retries = 3) { let attempt = 0; while (true) { try { return await fn(); } catch (e) { attempt++; if (attempt > retries) throw e; await new Promise(r => setTimeout(r, 200 * Math.pow(2, attempt))); } } } function openDB(name) { return new Promise((resolve, reject) => { const r = indexedDB.open(name, 1); r.onupgradeneeded = () => { const db = r.result; if (!db.objectStoreNames.contains('items')) db.createObjectStore('items', { keyPath: 'id' }); }; r.onsuccess = () => resolve(r.result); r.onerror = () => reject(r.error); }); } async function putItems(records) { return withRetry(async () => { const db = await openDB('retrydb'); const tx = db.transaction('items', 'readwrite'); const store = tx.objectStore('items'); for (const r of records) store.put(r); await new Promise((resolve, reject) => { tx.oncomplete = resolve; tx.onerror = () => reject(tx.error); tx.onabort = () => reject(tx.error); }); db.close(); }); } 失败队列与刷新function openQueue() { return new Promise((resolve, reject) => { const r = indexedDB.open('queue', 1); r.onupgradeneeded = () => { const db = r.result; if (!db.objectStoreNames.contains('q')) db.createObjectStore('q', { autoIncrement: true }); }; r.onsuccess = () => resolve(r.result); r.onerror = () => reject(r.error); }); } async function enqueue(payload) { const db = await openQueue(); const tx = db.transaction('q', 'readwrite'); tx.objectStore('q').add(payload); await new Promise((resolve, reject) => { tx.oncomplete = resolve; tx.onerror = () => reject(tx.error); }); db.close(); } async function flushQueue(processor) { const db = await openQueue(); const tx = db.transaction('q', 'readwrite'); const store = tx.objectStore('q'); const req = store.openCursor(); await new Promise((resolve, reject) => { req.onsuccess = async e => { const cursor = e.target.result; if (cursor) { try { await processor(cursor.value); store.delete(cursor.key); cursor.continue(); } catch { resolve(); } } else { resolve(); } }; req.onerror = () => reject(req.error); }); await new Promise((resolve, reject) => { tx.oncomplete = resolve; tx.onerror = () => reject(tx.error); }); db.close(); }