Google PubSub 订阅：重试机制

大家好，我们又见面了啊~本文《Google PubSub 订阅：重试机制》的内容中将会涉及到等等。如果你正在学习Golang相关知识，欢迎关注我，以后会给大家带来更多Golang相关文章，希望我们能一起进步！下面就开始本文的正式内容~

我是使用 google pubsub 的新手，请原谅我的无知。我用的是go语言 我们是一家使用 pubsub 发布通知的公司的客户，我们不拥有 pubsub 订阅，而只是消费者，拥有 pubsub 的公司每小时会推送 100 条消息，我们需要不断寻找消息。 我有以下示例代码用于获取在后台运行的消息

func PullMyMessages() {
   ctx := context.Background()
   client, _ := pubsub.NewClient(ctx, "myAPI", option.WithCredentialsFile("abc.json"))
   sub := client.Subscription("Mysub")
   msgSlice := make(chan *pubsub.Message, 1)
   cctx, cancel := context.WithCancel(context.TODO())
   go sub.Receive(cctx, func(ctx context.Context, m *pubsub.Message) {
      msgSlice <- m
   })
   for {
      select {
      case res := <-msgSlice:
         fmt.Printf("Got message: %q\n", string(res.Data))
         res.Ack()

      case <-time.After(5 * time.minute):
         cancel()
      }
   }
}

通过上面的代码，我能够获取订阅消息，当几分钟内没有订阅时，我将退出应用程序。 问题

1. 参考：https://cloud.google.com/pubsub/docs/handling-failures#pubsub_dead_letter_delivery_attempt-go，因为我只是订阅的消费者/订阅者才能设置重试策略集对于处理失败的消息。任何示例代码或指针都会对此有所帮助

2. 目前我希望这个应用程序在后台运行，当它在 5 分钟内没有收到任何消息时，它就会退出。理解正确吗？

我会实时删除时间因素以连续运行，但希望重试机制到位

正确答案

关于 PubSub 有几件事需要了解。

• 如果您不是订阅的所有者（或不在有权更新的列表中），则无法更改重试政策
• 订阅后，消息会保留一段时间（默认为 7 天，但也可能在 10 到 30 天之间）。这意味着，如果您有一段时间没有收听订阅，消息不会丢失，而是会堆叠在订阅中，当您的订阅者启动时，您将收到它们。
• 您可以运行已经启动的订阅者（去掉定时器的情况），但您也可以想象批量处理消息（例如，每 10 分钟收听 5 分钟的订阅）。这样您就可以利用无服务器服务并节省资源、金钱和二氧化碳！这取决于您的用例和实时要求。

今天关于《Google PubSub 订阅：重试机制》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！