Google PubSub - 获取最后一条消息

Posted

技术标签:

【中文标题】Google PubSub - 获取最后一条消息【英文标题】:Google PubSub - getting last message 【发布时间】:2016-10-12 21:31:41 【问题描述】:

我开始使用谷歌应用引擎及其提供的服务。 我特别感兴趣的一项服务是云发布订阅。

我的计划是有一个 nodejs socket.io 服务器订阅某个 pubsub 主题,并且每当主题收到发布时,它都会将该发布发送到所有套接字。

在另一端,我将有一个 .NET/Java 服务将消息发布到各种主题。

我的问题是 - 有没有办法获取发布到某个主题的最后一条消息?

可能会出现nodejs服务器宕机,发布服务有一段时间没有发布任何东西的情况。

如果我使用 Redis,我可以进行发布和设置,在 pubsub 中发布和设置的等价物是什么? memcache 会是一个好的解决方案吗?

谢谢

【问题讨论】:

【参考方案1】:

Google Cloud Pub/Sub 不提供以事务方式发布和写入数据库的方法。您需要发布到 Pub/Sub,并有一个将“最后一个值”写入数据库的订阅者。根据您需要的可靠性和耐用性,memcache 可能是一个不错的选择,或者 DataStore 可以提供更好的可靠性。这将提供最终的一致性。

【讨论】:

以上是关于Google PubSub - 获取最后一条消息的主要内容,如果未能解决你的问题,请参考以下文章

通过 Google Cloud Dataflow 将 PubSub 消息插入 BigQuery

如何使用当前的 pubsub 订阅者从 google Pub/Sub 系统获取消息

您可以使用 Google Pub Sub 批量提取消息吗?

获取 google cloud pubsub 的指标

拉谷歌 PubSub 消息时 io.grpc 帧大小超过最大值

使用 Google Cloud PubSub 不断收到“向 Cloud PubSub 发送测试消息时出错...”