Fastify 4.7.0中async preHandler未阻塞handler执行问题求助

问题根源 #

你的validateUser钩子没有被Fastify正确识别为需要等待的异步钩子，导致Fastify跳过异步等待逻辑，直接进入handler执行。

正确的钩子注册方式 #

Fastify的preHandler需要接收异步函数（或返回Promise的函数），注册时不要直接调用函数（避免写成validateUser()），否则会立即执行并返回Promise，但Fastify不会等待这个Promise完成。

路由级别钩子注册示例

// 正确的路由定义
fastify.post('/your-target-route', {
  preHandler: validateUser // 直接传递函数引用，Fastify会自动等待异步操作完成
}, async (request: FastifyRequest, reply: FastifyReply) => {
  console.log('START REQUEST IN CONTROLLER');
  // 你的业务逻辑
});

全局钩子注册示例（如果需要全局生效）

fastify.addHook('preHandler', validateUser);

异常处理修正 #

你的自定义BadRequestException需要被Fastify正确捕获处理，建议直接使用Fastify内置错误类，或者配置自定义错误处理器：

使用Fastify内置错误类

import { BadRequest } from 'fastify';

export const validateUser = async (req: FastifyRequest, reply: FastifyReply) => {
  const { data } = req.body as BodyData;
  const isValid = await MyApi.getCustomerIsValid(data);

  if (!isValid) {
    // 用Fastify内置的BadRequest错误，自动返回400状态码
    throw new BadRequest('My custom message here');
  }
};

自定义异常处理器（如果坚持用自定义异常类）

// 注册全局错误处理器
fastify.setErrorHandler((error, request, reply) => {
  if (error instanceof BadRequestException) {
    reply.status(400).send({ message: error.message });
  } else {
    reply.status(500).send({ message: 'Internal Server Error' });
  }
});

验证执行顺序 #

修正后，控制台输出顺序应该变为：

validateUser - Start prehandler
validateUser - After await
START REQUEST IN CONTROLLER

额外检查点 #

• 确认MyApi.getCustomerIsValid确实返回一个Promise，而非普通同步值
• 你使用的Fastify 4.7.0版本完全支持异步preHandler，无需版本升级

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