NodeJS：为什么这段代码会引发警告？答案

【问题标题】：NodeJS: Why is this code throwing a warning?NodeJS：为什么这段代码会引发警告？
【发布时间】：2020-06-04 05:02:24
【问题描述】：

我有以下代码，它可以工作，但仍然会引发警告。我在 Node v12 中运行。

(node:15985) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 3)

这是循环的源代码，谢谢：

const links = await knex('links').where('active', true);
const links = await knex('links').where('active', true).catch((e) => console.log(e)) // does not work neither

for (let index = 0; index < links.length; index++) {
  const element = links[index];
  console.log('Running with', index, element.uri);

  (async () => {
    try {
      const { statusCode } = await got({
        url: `${element.protocol}://${element.uri}:${element.port}`,
        method: 'GET',
        timeout: 5000
      })

      const check = {
        statusCode: statusCode,
      }

      await knex('checks').insert(check);
    } catch (error) {
      const check = {
        status: 'error',
      }

      await knex('checks').insert(check);
    }
  })().catch(() => {});
}

【问题讨论】：

我猜这是第一个await knex，因为那里没有catch。
我替换为：await knex('monitors').where('active', true).catch((e) => console.log(e))，但还是一样的错误

标签： node.js promise async-await

【解决方案1】：

你有 2 个没有 catch 块的 promise：

正如@Phix 在评论中指出的那样，第一行有一个：

// On the first line
await knex('links').where('active', true)

在代码末尾的catch块中：

await knex('checks').insert(check);

【讨论】：

评论 await knex('checks').insert(check); 并做 const links = await knex('links').where('active', true).catch((e) => console.log(e)) 仍然会引发错误
它肯定会有所帮助，但可能会在您共享的代码之外使用承诺。也许您需要共享引发错误的代码的更大部分

【解决方案2】：

我根据自己的理解对原代码做了一些改动。我还怀疑await knex('checks').insert(check); 是未处理承诺的问题。所以我添加了一个 try & catch 来处理它。 finally 不是必需的。我只是想让流程更清楚一点。我希望它能解决问题，至少提供一些想法。

// assign the async salad to a const to make the flow a bit more clear
const fetchData = async () => {
  try {
    let check;
    const { statusCode } = await got({
      url: `${element.protocol}://${element.uri}:${element.port}`,
      method: 'GET',
      timeout: 5000
    })
    check = {
      statusCode: statusCode,
    };
  } catch (error) {
    check = {
      status: 'error',
    }
  } finally {
    // use a try catch to handle the potential async call
    try {
      await knex('checks').insert(check);
    } catch {
      throw new Error('Error')
    }

  }
};

// if await knex('checks').insert(check) fails, we can catch the error it throws 
try {
  fetchData()
} catch (erroe) {
  console.log(error);
}

【讨论】：