Golang中Google PubSub订阅者长时间未活动时自动暂停接收消息

在 Go 中使用 Google PubSub 时，如果订阅者长时间不活动（约 3 小时），它可能会停止接收消息，而没有错误提示。这可能不是由于流量控制限制、其他订阅者竞争或发布者停止发布消息等常见原因造成的。

我在 google pubsub 中创建了一个 topic，并在该 topic 内创建了一个 subscription，并进行了以下设置

然后我用 go 编写了一个 puller，使用它的 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. 如果订阅者不确认或不确认消息，则可能会达到流量控制限制，这意味着无法再传递任何消息。鉴于您立即确认消息，在您的特定实例中似乎并非如此。
2. 如果另一个订阅者启动同一订阅，则它可能正在接收消息。在这种情况下，人们会期望订阅者收到消息的子集，而不是根本没有消息。
3. 发布者只是停止发布消息，因此没有消息可以接收。如果您重新启动订阅者并且它再次开始接收消息，则情况可能并非如此。您还可以通过查看 subscription/backlog_bytes 的 Stackdriver metric 来验证是否正在积压。

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

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

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

希望来自 Google 的人员能够让我们深入了解这里发生的情况，但我绝对没有付给他们足够的钱来获得直接支持。

终于介绍完啦！小伙伴们，这篇关于《Golang中Google PubSub订阅者长时间未活动时自动暂停接收消息》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！