延迟消息处理并在处理前删除

Question

我需要这种能力来为移动应用中的操作发送推送通知，但要等待用户撤消操作直到 10 秒。

是否可以将主题中发布的消息的处理延迟 10 秒？然后（有时，如果用户撤消）在 10 秒前删除消息，如果不需要处理？

Answer 1

取决于你是否也写订阅者：

您可以控制订阅者的代码：

1. 在您的 PubSub 消息中添加一个时间戳，以便您希望处理该消息。
2. 在您的客户端（订阅者）中，只有在达到处理消息的时间戳时才具有确认消息的逻辑。
3. PubSub 将重试传递消息，直到得到确认（或 10 天）

如果您无法控制订阅者，您可以拥有my-topic 和my-delayed-topic。人们可以发布到前一个主题，并且该主题将只有一个订阅者，您将实现：

1. 像以前一样将消息发布到my-topic。
2. 您将拥有该主题的订阅者，可以执行如上所示的相同限制。
3. 如果该消息的时间已到，您的处理程序会将该消息发布/中继到my-delayed-topic。

你也可以用task-queue+pubsub-topic代替pubsub-topic+pubsub-topic来实现上面的逻辑。

Answer 2

如果架构上完全可行，您可以使用Cloud Tasks。此 API 具有以下可能适合您的用例的功能：

• 您可以安排消息（任务）的传递
• 您可以从队列中删除任务（在它们执行之前）

假设您的客户端有一些任务 ID 的存储空间：

1. 创建一个task，以后将schedule_time 设置为10s。
2. 将任务名称存储在内存中（您可以在创建时为任务分配名称，或者使用从创建响应返回的自动生成的 ID）。
3. 如果用户取消了作业，请致电DeleteTask。

Answer 3

只是想分享一下，我注意到 Pub/Sub 支持重试策略 1 是 2020-06-16 2 的 GA。

如果确认截止日期到期或订阅者以否定确认响应，Pub/Sub 可以使用指数退避再次发送消息。

如果未设置重试政策，Pub/Sub 会在确认截止日期到期或订阅者以否定确认响应后立即重新发送消息。

如果设置了最大回退时间，则默认最小回退时间为 10 秒。如果设置了最小回退时间，则默认最大回退时间为 600 秒。

您可以指定的最长退避时间为 600 秒。