使用SpringBoot向Google Pub/Sub发布消息存在大幅延迟问题

针对你遇到的消息延迟（最长约2小时）问题，结合spring-cloud-gcp-starter-pubsub的默认配置，主要从以下几个方向排查和修复：

• 调整批量发布策略
  默认情况下，客户端开启了批量发布优化，会攒够一定数量/字节的消息，或等待固定延迟后才批量发送。如果你的业务场景消息量低（比如单条零散发送），就会触发等待逻辑导致延迟。可以通过配置关闭批量或调整阈值：
  在application.properties中添加：

  # 完全关闭批量发布，适合需要即时发送的场景
  spring.cloud.gcp.pubsub.publisher.batch.enabled=false
  

  或者保留批量但调整触发条件，让单条消息也能快速发送：

  spring.cloud.gcp.pubsub.publisher.batch.delay-threshold=1ms
  spring.cloud.gcp.pubsub.publisher.batch.max-messages=1
  spring.cloud.gcp.pubsub.publisher.batch.max-bytes=1024
  

• 检查发布超时与重试配置
  默认的发布超时和重试策略可能在网络波动时导致消息积压重试，极端情况下引发长时间延迟。可以调整超时时间或关闭不必要的重试：

  # 设置单次发布超时时间，避免无限等待
  spring.cloud.gcp.pubsub.publisher.publish-timeout=30s
  # 若业务允许，关闭自动重试
  spring.cloud.gcp.pubsub.publisher.retry.enabled=false
  

• 优化发布者线程池
  默认的发布线程池容量较小，当消息发送请求集中时，会出现排队等待的情况。可以扩大线程池参数：

  spring.cloud.gcp.pubsub.publisher.executor.core-pool-size=10
  spring.cloud.gcp.pubsub.publisher.executor.max-pool-size=20
  

• 排查自定义发布逻辑
  确认你自己封装的发布代码中没有手动缓存消息的逻辑（比如本地队列未及时触发发送），确保调用Pub/Sub客户端的发布方法后，没有额外的阻塞或延迟逻辑。

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