Google pubsub golang 订阅者在空闲几个小时后停止接收新发布的消息

Posted 2023-02-16

【中文标题】Google pubsub golang 订阅者在空闲几个小时后停止接收新发布的消息

【英文标题】：Google pubsub golang subscriber stops receiving new published message(s) after being idle for a few hours

【发布时间】：2019-08-25 18:16:02

【问题描述】：

我在 google pubsub 中创建了一个 TOPIC，并在 TOPIC 中创建了一个 SUBSCRIPTION，设置如下

然后我写了一个puller in go，使用它的Receive 来拉取和确认已发布的消息

package main

import (
    ...
)

func main() 
    ctx := context.Background()

    client, err := pubsub.NewClient(ctx, config.C.Project)
    if err != nil 
       // do things with err
    
    sub := client.Subscription(config.C.PubsubSubscription)
    err := sub.Receive(ctx, func(ctx context.Context, msg *pubsub.Message) 
        msg.Ack()
    )

    if err != context.Canceled 
      logger.Error(fmt.Sprintf("Cancelled: %s", err.Error()))
    
    if err != nil 
      logger.Error(fmt.Sprintf("Error: %s", err.Error()))
    
  

没什么特别的，它运行良好，但过了一段时间（〜空闲 3 小时后），它停止接收新发布的消息，没有错误，什么都没有。我错过了什么吗？

【参考方案1】：

一般来说，订阅者停止接收消息的原因可能有多种：

如果订阅者不确认或不确认消息，则可以达到流控制限制，这意味着无法传递更多消息。鉴于您立即确认消息，在您的特定情况下似乎并非如此。 如果另一个订阅者启动同一个订阅，它可能正在接收消息。在这种情况下，人们会期望订阅者收到消息的子集，而不是根本没有消息。 发布者只是停止发布消息，因此没有要接收的消息。如果您重新启动订户并再次开始接收消息，则可能不是这种情况。您还可以通过查看Stackdriver metric 中的subscription/backlog_bytes 来验证是否正在积压。

如果您的问题不属于这些类别之一，最好使用您的项目名称、主题名称和订阅名称联系 Google Cloud 支持，以便他们可以将问题缩小到您的用户代码、客户端库本身或服务。

【讨论】：

如果达到我的流量控制限制 - 我怎么知道呢？我怀疑我的某些消息的工作时间过长。

【参考方案2】：

我遇到了类似的事情，我很确定没有其他订阅者在拉这些消息。

试试这个：转到主题，创建一个新的虚假订阅（随意命名，因为稍后您将删除它）。就在我这样做之后，虚假订阅（我使用python sample code client 订阅）和真实订阅都再次接收消息。奇怪的解决方案，但也许它再次唤醒了话题。

希望 Google 的某个人能给我们一些关于这里发生的事情的见解，但我绝对不会付给他们足够的钱来获得直接的支持。

【参考方案3】：

很少有更改可以帮助您更好地调查问题： - 检查接收错误 - 为接收使用单独的上下文

ctx := context.Background()
err := sub.Receive(ctx, func(ctx context.Context, msg *pubsub.Message) 
    msg.Ack()
)
if err != nil 
    log.Fatal(err)

【讨论】：

那 [我更新了 mny 问题]，它没有显示任何错误，我也使用 GRPC_GO_LOG_SEVERITY_LEVEL=info 只是为了记录其他所有内容

【参考方案4】：

您的代码以前可以工作吗？从今天开始，我在使用 PubSub 时遇到了问题。 Python PubSub 库中的get_topic()、create_topic() 等方法停止工作，但我在发送和拉取消息方面没有任何问题。昨天一切正常，但今天不行......

【讨论】：

该代码可以正常工作，但它会在一段时间后停止拉取或接收消息，而不会引发任何错误。我的团队目前正在尝试使用 python lib 作为替代方案，将更新您