是否有办法可实时获取PubSub订阅中的消息数量？

首先明确：Google PubSub 原生没有提供实时查询订阅未送达消息数的接口，官方监控指标pubsub.googleapis.com/subscription/num_undelivered_messages是分布式节点定期聚合的运维指标，默认2-3分钟的延迟属于预期设计，不适用于业务逻辑层面的实时判断。

针对你的批量消费启动时刻全量拉取存量消息的场景，可选择以下方案：

方案1：存量消费完成标记法（最高效，无需依赖计数） #

该方案不需要提前获取消息数量，即可准确判定启动时刻的存量消息是否全部消费完成：

• 消费流程启动时，先向目标PubSub主题发送一条特殊标记消息，消息携带唯一的消费启动标识（比如当前时间戳+随机ID）
• 正常启动异步拉取消费逻辑，对普通业务消息正常处理并ack()
• 当消费到提前写入的特殊标记消息时，即可判定启动时刻前的所有存量消息已经全部消费完成，此时可停止消费或进入增量消费模式

注意：需确保订阅的消息过滤规则不会过滤掉你写入的特殊标记消息

方案2：拉取试探法（单次获取启动时刻近似计数） #

如果确实需要在启动时拿到近似的存量消息数量：

• 临时调整异步消费者的maxOutstandingMessages参数为大于你预估的存量消息峰值的数值
• 启动消费拉取1-2秒，统计本地接收到的未ack消息总数，统计完成后对所有拉取到的消息执行nack()，让消息重新回到订阅队列等待后续正式消费
• 该方式拿到的计数误差在秒级，完全可以满足启动时刻的批量消费数量评估需求

方案3：独立计数埋点（长期高频实时计数需求） #

如果业务需要长期、频繁获取实时未消费消息数：

• 在生产端增加埋点：每向PubSub主题发送一条消息，就向低延迟KV存储（比如Redis、Cloud Memorystore）执行原子加1操作
• 在消费端增加埋点：每成功ack()一条消息，就向同一个KV存储执行原子减1操作
• 需要获取计数时直接查询KV存储中的值即可，延迟可控制在毫秒级

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