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();

}