JavaScript Web Worker 怎么传递 IDBObjectStore-js教程-PHP中文网

javascript web worker 无法直接传递 idbobjectstore 对象，因为 indexeddb 的数据库连接和存储对象不是可克隆的。必须通过 postmessage 发送数据库名称、操作类型和数据，由接收方在本地重新获取对应的 idbopendbrequest 或 idbdatabase 实例来执行操作。

JavaScript Web Worker 怎么传递 IDBObjectStore

Worker 如何请求主线程执行 IDB 操作

主线程持有 IDBDatabase 实例，Worker 通过消息通知主线程执行读写。主线程收到消息后，使用相同的数据库名打开连接或直接复用现有连接，执行 put 或 get 并返回结果。

JavaScript Web Worker 怎么传递 IDBObjectStore

const dbName = 'my-db';
const storeName = 'users';

// 主线程代码
const worker = new Worker('worker.js');
let db;

indexedDB.open(dbName, 1).then(e => {
  db = e.target.result;
  worker.onmessage = async (event) => {
    const { type, data } = event.data;
    let result;
    if (type === 'get') {
      const tx = db.transaction(storeName, 'readonly');
      const store = tx.objectStore(storeName);
      result = await store.get(data.id);
    } else if (type === 'put') {
      const tx = db.transaction(storeName, 'readwrite');
      const store = tx.objectStore(storeName);
      await store.put(data);
      result = { success: true };
    }
    worker.postMessage({ type: 'response', id: event.data.id, result });
  };
});

// Worker 代码
self.onmessage = (event) => {
  self.postMessage({ type: 'request', id: Date.now(), ...event.data });
};
self.onmessage = (event) => {
  if (event.data.type === 'response') {
    console.log('Got response:', event.data.result);
  }
};

主线程如何响应 Worker 的 IDB 请求

主线程需要维护一个消息队列或简单的回调映射，确保每个请求都有对应的响应。由于 IndexedDB 是异步的，主线程在处理完数据库操作后，必须将结果封装回传给 Worker。

JavaScript 测试模式

使用 Jest、Vitest 和 Testing Library 实施全面的测试策略，包括单元测试、集成测试和端到端测试，涵盖模拟、测试夹具和测试驱动开发。在编

下载

JavaScript Web Worker 怎么传递 IDBObjectStore

// 主线程增强版：处理并发请求
const pendingRequests = new Map();

worker.onmessage = async (event) => {
  const { type, id, data } = event.data;
  if (type === 'request') {
    try {
      let result;
      if (data.op === 'get') {
        const tx = db.transaction(data.store, 'readonly');
        result = await tx.objectStore(data.store).get(data.key);
      } else if (data.op === 'put') {
        const tx = db.transaction(data.store, 'readwrite');
        await tx.objectStore(data.store).put(data.value);
        result = { status: 'ok' };
      }
      worker.postMessage({ type: 'response', id, result });
    } catch (err) {
      worker.postMessage({ type: 'error', id, error: err.message });
    }
  }
};