如何在GCP Pub Sub中配置类似ActiveMQ的Non Persistent消息？

该需求完全可以实现，通过临时动态订阅+流式拉取的配置即可达到和ActiveMQ Non Persistent消息完全一致的效果，无需依赖固定订阅的消息生命周期配置。

具体实现逻辑 #

• 放弃原有固定订阅的方案：固定订阅的消息保留时长最低仅支持设置10分钟，无法完全匹配“不接收pod下线期间消息”的要求，还会产生不必要的堆积费用。
• 每个pod启动时，通过Pub/Sub API动态创建专属的临时拉取订阅，绑定到目标Topic，创建时配置以下参数：
  • 不开启消息回溯功能（默认关闭，无需额外配置），此时订阅仅能收到创建完成之后到达Topic的消息
  • 订阅过期TTL设置为最小值10分钟，pod运行期间每间隔小于10分钟的周期（推荐5分钟）调用一次API刷新订阅的过期时间，避免运行时订阅被自动清理
  • 开启流式拉取模式，保持pod和Pub/Sub服务端的长连接，降低消息投递延迟
• pod下线处理：优雅退出时可主动删除自身对应的临时订阅；异常退出的场景下，对应订阅会在10分钟无刷新后自动过期清理，不会残留无效资源。

配置入口 #

你可以通过三种方式完成相关配置：

1. GCP控制台Pub/Sub模块的订阅创建页，可视化配置上述参数
2. gcloud命令行工具，示例命令如下：
   gcloud pubsub subscriptions create <pod专属临时订阅名> --topic=<你的目标Topic名> --expiration-period=10m --message-retention-duration=10m
3. 各类语言的Pub/Sub官方SDK，创建订阅的接口中直接传入对应参数即可

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