异步函数似乎没有在同步代码中运行

Question

我试图创建一个连接到数据库的命令，我创建了一个小 CLI 脚本，该脚本循环遍历特定文件夹中的文件以获取命令类模块

我的问题是，在我的一个命令中，我正在尝试连接到 sequelize，但它似乎没有做任何事情。我没有得到控制台的输出，甚至似乎也没有尝试连接

这可能是因为我仍然在努力弄清楚如何正确地执行同步/异步/等待的东西...注意我是如何使用glob.sync 的，因为我想同步循环遍历文件，但随后在我的命令我需要使用await连接到数据库

cli.js:

#! /usr/bin/env node

const patterns = [
    './node_modules/unity/src/commands/**/*.js',
    './src/commands/**/*.js',
]
const glob = require('glob')
const path = require('path')
const yargs = require('yargs')
const signature = yargs.argv._[0]
const process = require('process')

patterns.forEach(pattern => {
    glob.sync(pattern).forEach(file => {
        const commandPath = path.resolve(file)
        const command = require(commandPath)

        if (command.signature == signature) {
            command.argv = yargs.argv
            command.run()

            process.exit()
        }
    })
})

console.log('Command not found.')

这是commands 文件夹之一中的示例命令：

const { Sequelize } = require('sequelize')

class MigrateCommand {
    static signature = 'migrate'
    static argv = {}

    static run() {
        const sequelize = new Sequelize({
            dialect: 'mysql',
            host: 'localhost',
            port: 3306,
            database: 'dio_unity2',
            username: 'root',
            password: '',
        })

        const connect = async () => {
            try {
                await sequelize.authenticate()
                console.log('Connection successful.')
            }
            catch (error) {
                console.error('Unable to connect.', error)
            }
        }

        connect()

        console.log('migrate run complete')
    }
}

module.exports = MigrateCommand

我已经设置了 npx，所以我可以运行 npx unity migrate，它会根据 migrate 签名调用这个命令

现在我的控制台应该显示connection successful 或unable to connect，然后是migrate run complete，但我在控制台中看到的只是migrate run complete。就好像它根本没有尝试连接......

我不知道我在这里做错了什么。

Answer 1

You can't make an asynchronous process synchronous 无需生成新线程并同步等待它。 （有一个 npm 包可以做到这一点，通过 execSync。）

但这里的好消息是没有必要在您的代码中。您希望按顺序进行，但按顺序进行 与同步 完全不一样。方法如下：

首先，run 无法使通过authenticate 启动的异步进程同步。因此，run 应该只是 async（我们不需要 connect）：

static async run() {
    const sequelize = new Sequelize({
        dialect: 'mysql',
        host: 'localhost',
        port: 3306,
        database: 'dio_unity2',
        username: 'root',
        password: '',
    })

    try {
        await sequelize.authenticate()
        console.log('Connection successful.')
    } catch (error) {
        console.error('Unable to connect.', error)
    }

    console.log('migrate run complete')
}

接下来，在脚本中，我们使用 async 函数遍历您的模式和文件：

(async () => {
    for (const pattern of patterns) {
        for (const file of glob.sync(pattern)) {
            const commandPath = path.resolve(file)
            const command = require(commandPath)

            if (command.signature == signature) {
                command.argv = yargs.argv
                await command.run() // *** Note the `await`
                process.exit()
            }
        }
    }
    console.log("Command not found.")
})();

它以异步方式完成工作，但一个接一个（串联）。

---

如果是我，我不会使用 process.exit() 来终止进程，这是一种非常激进的进程终止形式，可能会阻止某些事情完成 (details here)，而且人们可能不太清楚稍后进行代码维护作为替代方案。现在我们已将代码放入包装函数中，我只需退出函数以打破循环：

await command.run();
return;