Spring Boot客户端无法重试GCP Pub/Sub未确认消息问题排查

你的问题核心在于未正确处理暂不可用的消息，结合Spring Cloud GCP Pub/Sub的机制，主要原因和解决方式如下：

1. 核心问题：未主动触发消息重试 #

当你直接return不做任何ack/nack操作时，Spring Cloud GCP的订阅者客户端默认会自动延长消息的租约（Ack Deadline），导致消息一直被客户端持有，不会被Pub/Sub重新分发。这就是消息只被拉取一次后就停滞的根本原因。

默认情况下，订阅者会持续延长未确认消息的租约，直到你主动调用ack()或nack()，所以单纯依赖"不确认等待重试"的逻辑完全不生效。

2. 正确的处理逻辑 #

针对需要延迟重试的场景，你需要显式调用nackWithScheduleDelay()方法，指定消息重新回到队列的延迟时间，而不是什么都不做。同时，确保业务失败时也按同样逻辑处理。

修改后的EventHandler代码如下：

@Component
@Slf4j
@RequiredArgsConstructor
public class EventHandler {

    private static final int RETRY_DELAY_SECONDS = 600; // 10分钟

    @ServiceActivator(inputChannel = "inputChannel")
    public void process(SomeEvent someEvent,
                        @Header(GcpPubSubHeaders.ORIGINAL_MESSAGE) BasicAcknowledgeablePubsubMessage message) {
        logger.info("Received event {}", someEvent);
        long now = System.currentTimeMillis() / 1000L;
        if (someEvent.getEarliestRetryTime() > now) {
            logger.warn(
                    "Event not ready to run yet {}",
                    new Date(someEvent.getEarliestRetryTime() * 1000)
            );
            // 延迟10分钟后重试
            message.nackWithScheduleDelay(RETRY_DELAY_SECONDS);
            return;
        }

        // 执行业务逻辑
        boolean success = doStuff();
        if (success) {
            message.ack();
        } else {
            // 业务失败，同样延迟10分钟重试
            message.nackWithScheduleDelay(RETRY_DELAY_SECONDS);
        }
    }
}

3. 额外配置检查 #

• 订阅的重试策略：如果希望统一控制全局重试间隔，可以在GCP控制台或通过Spring配置设置订阅的重试策略（最小/最大重试间隔），不过nackWithScheduleDelay()的优先级更高，会覆盖全局策略。
• Flow Control配置：你设置的max-outstanding-element-count:10是指客户端最多持有10个未确认的消息，如果大量消息被延迟重试，这个配置不会影响重试逻辑，但要确保不会因为未处理消息占满名额导致新消息无法拉取（不过使用nackWithScheduleDelay()后，消息会立即释放名额）。
• 关闭自动租约延长（可选）：如果你坚持依赖租约到期重试，可以关闭自动租约延长，但这种方式不可控（租约到期时间可能与你期望的10分钟不符），配置如下：

spring:
  cloud:
    gcp:
      pubsub:
        subscriber:
          enable-auto-ack-deadline-renewal: false
          ack-deadline-seconds: 600 # 设置租约为10分钟

不过这种方式不推荐，因为如果业务处理时间超过租约，消息会被提前重试，导致重复执行。

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