如何在Pubsub中正确使用nack 解决调用后无法处理后续消息问题

AI 小北

2026-10-5

问题解决方案

你遇到的调用nack后报错、无法继续消费后续消息，通常是以下几个原因导致的，按优先级排查解决即可：

1. 未关闭Pubsub微服务的自动确认配置

NestJS的GCP Pubsub微服务适配器默认开启autoAck配置，消息送达后框架会自动调用ack确认，你后续再手动调用nack就会触发「消息已被确认」的错误，该异常未被捕获就会导致消费进程崩溃，无法处理后续消息。

解决方法：在微服务初始化配置中关闭自动确认：

// main.ts 微服务初始化配置
import { Transport, MicroserviceOptions } from '@nestjs/microservices';

const app = await NestFactory.createMicroservice<MicroserviceOptions>(AppModule, {
  transport: Transport.GCP_PUBSUB,
  options: {
    projectId: '你的GCP项目ID',
    subscription: '对应主题的订阅名称',
    autoAck: false, // 必须关闭自动确认，才能手动控制ack/nack
  },
});

2. 未捕获nack调用本身的异常

当前你的代码只捕获了业务逻辑和ack的异常，msg.nack()本身执行时如果出错（比如消息已过期、服务端已标记消息已处理），抛出的异常没有被捕获，会直接冒泡到框架层导致消费进程中断。

解决方法：给nack调用增加异常捕获逻辑，修改Controller层代码如下：

@EventPattern('topicName')
async extractMessageTopic(msg: Message) {
  try {
    console.log("--开始处理消息--");
    await this.appService.extractMessageTopic(msg)
    msg.ack() // 业务处理完成，手动确认消息
  } catch (businessError) {
    console.log("业务处理报错!", businessError);
    // 捕获nack本身的执行异常，避免异常扩散导致进程崩溃
    try {
      msg.nack() // 否定确认，消息会按订阅配置重新投递
    } catch (nackError) {
      console.log("nack调用失败，可忽略:", nackError);
    }
  }
}