使用Dexie.js处理请求队列异步

const Dexie = require('dexie');

// 创建数据库和表
const db = new Dexie('RequestQueueDB');
db.version(1).stores({
  requests: '++id, url, status'
});

// 添加请求到队列
async function addRequest(url) {
  return await db.requests.add({ url, status: 'pending' });
}

// 处理请求队列
async function processQueue() {
  const pendingRequests = await db.requests.where('status').equals('pending').toArray();
  for (const request of pendingRequests) {
    try {
      // 模拟请求处理
      console.log(`Processing request: ${request.url}`);
      // 更新请求状态为处理中
      await db.requests.put({ id: request.id, status: 'processing' });
      // 模拟请求完成
      await new Promise(resolve => setTimeout(resolve, 1000));
      // 更新请求状态为完成
      await db.requests.put({ id: request.id, status: 'completed' });
    } catch (error) {
      console.error(`Failed to process request: ${request.url}`, error);
      // 更新请求状态为失败
      await db.requests.put({ id: request.id, status: 'failed' });
    }
  }
}

// 示例使用
(async () => {
  await addRequest('https://example.com/api/1');
  await addRequest('https://example.com/api/2');
  await processQueue();
})();

async function processQueue() {
  const pendingRequests = await db.requests.where('status').equals('pending').toArray();
  for (const request of pendingRequests) {
    await db.transaction('rw', db.requests, async () => {
      const currentRequest = await db.requests.get(request.id);
      if (currentRequest.status === 'pending') {
        try {
          console.log(`Processing request: ${request.url}`);
          await db.requests.put({ id: request.id, status: 'processing' });
          await new Promise(resolve => setTimeout(resolve, 1000));
          await db.requests.put({ id: request.id, status: 'completed' });
        } catch (error) {
          console.error(`Failed to process request: ${request.url}`, error);
          await db.requests.put({ id: request.id, status: 'failed' });
        }
      }
    });
  }
}

async function processQueue() {
  const pendingRequests = await db.requests.where('status').equals('pending').toArray();
  for (const request of pendingRequests) {
    await db.transaction('rw', db.requests, async () => {
      const currentRequest = await db.requests.get(request.id);
      if (currentRequest.status === 'pending') {
        try {
          console.log(`Processing request: ${request.url}`);
          await db.requests.put({ id: request.id, status: 'processing' });
          await Promise.race([
            new Promise(resolve => setTimeout(resolve, 5000)), // 5秒超时
            new Promise(async resolve => {
              await new Promise(resolve => setTimeout(resolve, 1000));
              await db.requests.put({ id: request.id, status: 'completed' });
              resolve();
            })
          ]);
        } catch (error) {
          console.error(`Failed to process request: ${request.url}`, error);
          await db.requests.put({ id: request.id, status: 'failed' });
        }
      }
    });
  }
}