Google pubsub流控制

Google Pub/Sub是一种可扩展的消息传递服务，用于在分布式系统之间进行可靠且实时的异步通信。它提供了一种简单而可靠的方式来将消息从发布者发送到订阅者，同时具备流控制的能力。

流控制是指在消息传递过程中对消息的发送速率进行限制，以避免过载和资源浪费。Google Pub/Sub通过以下方式实现流控制：

限制发布者速率：发布者可以设置每秒发送的消息数量，以确保不会发送过多的消息导致系统负载过高。
限制订阅者速率：订阅者可以设置每秒处理的消息数量，以控制自身的处理能力，避免消息堆积和处理延迟。
消息确认机制：订阅者在处理完一条消息后，需要向Google Pub/Sub发送确认消息，以告知系统该消息已被成功处理。这样可以确保消息不会被重复处理，也可以触发后续消息的发送。

Google Pub/Sub的优势和应用场景包括：

可扩展性：Google Pub/Sub能够处理大规模的消息传递需求，支持高并发和高吞吐量的消息处理。
可靠性：Google Pub/Sub提供了持久化存储和消息重试机制，确保消息不会丢失，并能够处理网络故障和系统崩溃等异常情况。
实时性：Google Pub/Sub能够实现实时的消息传递，适用于需要快速响应和实时更新的场景，如实时监控、实时数据分析等。
解耦合：通过使用Google Pub/Sub，发布者和订阅者之间可以解耦合，降低系统的复杂性和耦合度，提高系统的可维护性和可扩展性。

推荐的腾讯云相关产品是腾讯云消息队列CMQ，它是腾讯云提供的一种高可靠、高可用的消息队列服务，适用于分布式系统之间的消息通信。CMQ提供了类似于Google Pub/Sub的功能，并且与腾讯云的其他产品和服务无缝集成。

更多关于腾讯云消息队列CMQ的信息，请访问：腾讯云消息队列CMQ产品介绍

在Azure事件网格中确认事件传递

event-handling、azure-eventgrid

Google的pub/sub服务为消息的订阅者提供了一个端点，以显式地确认消息的成功传递。如果未使用此端点，则subscriber必须在超时之前返回200响应，否则发布/订阅会认为消息传递不成功，并将在超时后重试发送消息。因此，对于长时间运行的订阅者进程，可以在运行主进程之前先发送确认，而不是等到进程完成。我没有在Azure Event Grid中找到类似的机制，所以如果事件处理程序花费了很长时间(根据，超时只有30秒)，那么在过程的中间，event grid会重试向同一个订阅者发送更多的事件： “事件网格在传递消息后等待30秒的响应。30秒后，如果终结点没有响应，消息将排队等待重试。事件网

浏览 1提问于2020-06-25得票数 1

3回答

如何使用Node.js在云PubSub中控制确认

node.js、google-cloud-functions、google-cloud-pubsub

基本上我已经创建了一个云函数(写了一个Node.js代码)，它将在云发布主题的消息上触发，并将数据加载到Bigquery表中。 topic中的消息被云函数读取后被删除。我知道订阅者在内部发送确认和结果，消息从主题中删除。我想控制发送给发布者的确认。怎么才能实现，没有找到相关的文档。

浏览 2提问于2017-10-18得票数 12

2回答

webhook与发布者和订阅者

java、google-app-engine、webhooks

我偶然发现了webhook和发布者/订阅者的概念。在webhook中，当依赖的应用程序发生更新时，第三方应用程序发送信息，第三方将发送HTTP post请求到您的应用程序的上述URL，而在发布者和订阅者中，订阅者将注册主题并对该主题进行发布者写入，然后注册者(如第三方)将基于订阅的主题将信息发送给订阅者。两者是相似的还是不同的？我很困惑，有没有人能解决这个问题？

浏览 1提问于2017-07-22得票数 5

2回答

实现持久的发布/订阅？

.net、wcf、messaging、publish-subscribe

假设我有一个发布者和多个监听器。当发布者发送消息时，它必须被所有侦听器接收。如果其中一个听众关闭了，他应该会在重新启动后立即收到消息。我如何实现这一点？我在考虑使用队列:每个监听器创建自己的队列，并向发布者发送一条带有队列位置的订阅消息。发布者将该位置保存到一个文件或DB中，并开始向该队列发送消息。因此，这将是时间线： Publisher已启动。目前还没有监听器。发布者发送消息% 1。发布者发送消息2。发布者发送消息3。侦听器1启动并订阅publisher。发布者发送消息4。监听程序1接收消息4。 Listener 2启动并订阅publisher。发布者发送消息5。监听程

浏览 2提问于2011-05-27得票数 0

回答已采纳

1回答

PubSub确认截止日期

google-cloud-platform、google-cloud-pubsub、google-cloud-run

我有一个云函数，它将消息发布到PubSub，并触发云运行来执行归档文件过程。当有大文件时，我的cloud Run python代码需要一些时间来处理数据，它看起来像是PubSub在20秒(默认确认截止时间)后重试消息，这将从我的Cloud run触发另一个实例。我已经将确认截止时间增加到600秒，并重新部署了所有内容，但它在20秒后仍在重试消息。我遗漏了什么吗？云函数发布消息代码： # Publishes a message try: publish_future = publisher.publish(topic_path, data=message_bytes)

浏览 17提问于2021-07-02得票数 2

回答已采纳

1回答

向客户端传递不能被请求的实时消息的最佳方法是什么？

websocket、rabbitmq

我们需要向客户端提供实时消息，但它们的服务器位于代理之后，我们无法初始化连接；web钩子变体无法工作。考虑到这一点，什么是传递实时信息的最佳方式：代理背后的客户端客户端可以关闭很长一段时间，所有消息都必须传递。协议/方式必须足够通用，这样即使是PHP开发人员也可以很容易地使用它我想到了三个变体： WebSocket - client打开一个websocket连接，我们发送存储在DB中的消息，同时消息实时启动。 RabbitMQ -所有消息都存储在一个持久的持久队列中。如果合作伙伴在一段时间内不会从队列中读取数据，该怎么办？ HTTP partner将按

浏览 3提问于2013-09-24得票数 0

2回答

如果没有成功的响应，Pub/Sub会立即发送消息吗？

google-cloud-functions、google-cloud-pubsub

我有一个云函数订阅了Pub/Sub主题。根据，如果云函数返回一个不成功的响应，它将重新发送消息：端点通过返回HTTP成功状态代码来确认消息。一个不成功的响应表示消息应该被憎恨。我的问题是:如果一个不成功的回应，信息将立即被愤怒，或Pub/Sub将遵守确认的最后期限来重新发送消息？更新：我认为这个问题没有任何意义，我会解释原因。由于您无法访问Pub/Sub函数中的Response对象，因此无法直接发送响应代码(我对此不太确定，因此如果我错了，请纠正我)。因此，不成功的反应只能由以下几个方面引起：超时，这是基于确认的最后期限，所以在这种情况下，确认的最后期限显然是尊重。

浏览 0提问于2019-07-08得票数 5

回答已采纳

1回答

什么是google云发布/订阅延迟

google-cloud-pubsub

我有一个应用程序，需要非常低的延迟(实时游戏)。目前，在我的解决方案中，消息从客户端前端服务器路由到目标服务器所需的时间不到2毫秒。有人知道在Google Cloud Pub/Sub中路由一条消息到另一台服务器需要多长时间吗？谢谢!

浏览 2提问于2016-03-24得票数 6

1回答

python、zeromq、pyzmq

根据ZeroMQ文档，当排队的消息数量达到高峰时，pub套接字就应该丢弃消息。在下面的示例中，这似乎不起作用(是的，在绑定/连接之前设置了hwm )： import time import pickle from threading import Thread import zmq ctx = zmq.Context() def pub_thread(): pub = ctx.socket(zmq.PUB) pub.set_hwm(2) pub.bind('tcp://*:5555') i = 0 while True:

浏览 2提问于2018-11-17得票数 2

2回答