Fastify中Async的正确用法及最佳实践技术问询

针对你提出的Fastify路由、插件及数据库场景下的异步问题，逐个解答如下：

问题1：交易模型中的getInitialTransaction为async，但插件初始化用done()回调，写法是否错误？是否应改为async？ #

当前写法没有错误，但可以优化为async风格。

• 你的插件初始化逻辑只是定义并挂载一个async函数到Fastify实例，没有执行异步操作，所以使用done()回调完全合法。
• 如果要改成async函数，只需去掉done参数，直接完成逻辑即可，代码更简洁（见下方修正示例）。两种写法功能等价，核心看团队风格偏好。

问题2：若将const model改为async，注册时是否需要使用await fastify.register(transaction)？ #

必须使用await。
Fastify的register方法返回Promise，当插件是async函数时，只有用await（或.then()）等待插件初始化完成，才能保证后续代码执行时，插件已经完成挂载。如果省略await，可能出现路由注册时fastify.transaction还未定义的错误。

问题3：设置Fastify插件为async或sync的通用准则是什么？ #

核心判断标准是插件初始化过程中是否包含异步操作：

• 同步插件：如果插件仅做同步操作（比如挂载同步函数、配置静态选项），用带done的回调函数或async函数都可以，同步回调写法更简洁。
• 异步插件：如果插件初始化需要执行异步逻辑（比如数据库连接、读取文件、调用外部API），必须使用async函数，或者在done回调中处理异步错误（如done(err)）。
• 统一使用async写法确实能避免多数异步顺序问题，尤其团队协作时，统一风格可减少出错概率，只要没有不必要的await，性能影响可以忽略。

问题4：数据库查询是否最好保持async，避免阻塞应用？ #

必须保持async。
Node.js基于单线程事件循环，同步数据库查询会阻塞整个事件循环，导致所有请求挂起，系统性能急剧下降。异步查询会将IO操作交给底层线程处理，事件循环可继续处理其他请求，在查询密集场景下，async是唯一正确的选择。你代码中await connection.query的写法符合最佳实践。

修正后的代码示例 #

models/transaction.js（async版本）

import fp from 'fastify-plugin'

const model = async (fastify, options) => {
    const getInitialTransaction = async (uuid) => {
        const connection = await fastify.mysql.getConnection()
        try {
            const [rows] = await connection.query(
                `SELECT t.id, t.amount, t.points, t.currency, t.reference, t.email, m.name AS merchantName, m.points_enabled AS pointsEnabled
                FROM transactions t
                JOIN merchants m 
                ON m.id = t.merchant_id
                WHERE t.uuid = :uuid
                AND t.status = 3`, { uuid: uuid }
            )
            return rows[0]
        } catch (e) {
            console.log(e)
            throw e
        } finally {
            connection.release()
        }
    }
    // 将方法挂载到Fastify实例
    fastify.decorate('transaction', { getInitialTransaction })
}

export default fp(model)

routes/transactions.js（添加await）

import formbody from '@fastify/formbody'
import transaction from '../../models/transaction.js'
import * as schema from '../../schemas/transaction.js'

const routes = async (fastify, options) => {
    await fastify.register(formbody)
    // 异步插件必须用await等待注册完成
    await fastify.register(transaction)

    fastify.get('/transactions/initial', schema.getInitialTransactionSchema, async (req, rep) => {
        const transaction = await fastify.transaction.getInitialTransaction(req.query.uuid);
        rep.code(200).send(transaction)
    })
}

export default routes

内容的提问来源于stack exchange，提问作者Dally