多订阅者共享GCP Pub/Sub订阅的负载均衡及消息限制问询

核心结论 #

• maxOutstandingMessages是每个订阅者实例独立遵循的限制，而非多个订阅者共享。
• GCP Pub/Sub服务器不会先将单个订阅者的10条额度填满再转向其他订阅者，而是采用动态负载均衡策略分配消息。

负载均衡逻辑细节 #

GCP Pub/Sub服务器会基于以下维度动态分配消息：

• 每个订阅者的当前未确认消息数：只要订阅者的未确认消息数低于自身设置的maxOutstandingMessages（即还有剩余额度），服务器就会向其分配新消息，维持未确认消息数接近阈值但不超过。
• 订阅者的活跃状态与确认速度：服务器会优先向消息确认速度更快、持续发送拉取请求的订阅者分配更多消息，避免资源闲置；对于处理速度较慢的订阅者，会减少分配量，防止未确认消息积压。
• 多订阅者并行分配：服务器会同时向多个活跃的订阅者分配消息，不会等待某一个订阅者填满额度后再处理其他订阅者，以此实现负载在多个Pod间的均匀分布。

额外问题解答 #

1. 是否会先给某一个订阅者发送满10条消息后再转向下一个？
   不会。服务器会并行处理多个订阅者的拉取请求，只要订阅者有剩余的消息接收额度，就会持续分配消息，不会出现"填满一个再处理下一个"的情况。

2. maxOutstandingMessages是每个订阅者各自遵循10的限制，还是4个订阅者共享这10条的限制？
   是每个订阅者独立遵循的限制。每个Kubernetes Pod作为独立的订阅者实例，各自最多持有10条未确认消息，整个订阅的总未确认消息数上限为4*10=40条（当所有订阅者都处于活跃且未确认消息的状态时）。

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