pubsub/spring-cloud-gcp-pubsub中订阅者的重试设置
pubsub/spring-cloud-gcp-pubsub是一个用于在Google Cloud Pub/Sub中实现消息发布和订阅的Spring Cloud项目。在该项目中，订阅者的重试设置是指在消息传递过程中出现错误或失败时，系统如何进行自动重试以确保消息的可靠传递。
订阅者的重试设置通常包括以下几个方面：
- 重试策略：定义了在出现错误或失败时应该如何进行重试。可以根据具体需求选择不同的重试策略，例如指数退避、固定延迟、随机延迟等。
- 重试次数：指定了在连续失败后最多尝试重试的次数。可以根据业务需求和消息的重要性来设置合适的重试次数。
- 重试间隔：指定了每次重试之间的时间间隔。可以根据具体情况设置合适的重试间隔，以避免对系统造成过大的负载压力。
- 错误处理：定义了在重试过程中出现无法恢复的错误时应该如何处理。可以选择将错误信息记录下来以供后续分析，或者选择将错误信息发送给其他系统进行处理。
在pubsub/spring-cloud-gcp-pubsub中，可以通过配置相关参数来设置订阅者的重试设置。具体的配置方式可以参考该项目的文档和示例代码。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ。腾讯云消息队列 CMQ 是一种高可用、可伸缩、可靠的消息队列服务，可帮助用户实现分布式系统间的异步通信。CMQ 提供了消息发布和订阅的功能，支持自定义重试策略、重试次数和重试间隔，以确保消息的可靠传递。您可以通过腾讯云官网了解更多关于腾讯云消息队列 CMQ 的信息：腾讯云消息队列 CMQ
请注意，以上答案仅供参考，具体的重试设置和推荐产品应根据实际需求和情况进行选择。
相关·内容
1回答
我有一个云函数，它将消息发布到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
回答已采纳
protocol 是 http 的，然后这个 endpoint 也是 http:// 开头的，一切都符合要求。
但是不管是在腾讯云的后台上操作，还是用代码创建，都是相同的错误。
是这个 endpoint 有什么特殊要求吗？
我的这个 endpoint 是 http://xxxx-xxx.xxx.cn/api/hook
请求：
Nonce=5051285672901422566&endpoint=http%3A%2F%2Femail-hook.gxxxong.cn%2Fapi%2Fauth%2Fme&protocol=http¬ifyStrategy=EXPO
浏览 605提问于2018-06-26
我想知道如果有一个SNS主题有消息写入它会发生什么，但在一段时间内，没有SQS队列。假设有一个容器通常被订阅到SNS主题来处理这样的消息，但是它崩溃和烧毁，花了10分钟被复活；在没有队列的情况下，写到该主题的消息会发生什么情况？他们是永远消失了，还是有礼貌地等待某个队列出现，订阅并接收这些消息？
浏览 5提问于2021-01-25得票数 0
回答已采纳
2回答
似乎GCP云函数在调用时总是确认Pubsub推送消息，即使函数崩溃或失败。
这阻止了新的发布/订阅“死信”主题功能的使用，该功能要求在将消息转发到不同的主题之前，消息传递失败。目前，消息从不会失败。
有没有办法利用“死信主题”或使用云函数的pubsub重新交付？除了在函数本身设置“重试”标志之外，这并不能解决这个问题。
浏览 1提问于2020-05-15得票数 4
我正在使用PubSub和。
有时，我的服务被触发不止一次，即使在云上运行的服务成功响应(HTTP 204无内容)时也是如此。
我的服务大约需要200秒来响应PubSub发布的帖子。
我的问题是：如何限制PubSub的尝试次数？或者我犯了一些错误，比如多个订阅(我只有一个订阅，只是在控制台上检查)？
奇怪的是，当我触发Cloud时，PubSub多次调用我的服务(见下面的截图)
我将按照以下方式部署我的PubSub和Cloud：
export PROJECT_ID=...
export PROJECT_NUMBER=$(gcloud projects describe --format
浏览 4提问于2021-05-27得票数 2
回答已采纳
我有一个云运行服务，它使用HTTP订阅PubSub主题。
当我的服务返回HTTP400时，PubSub一直在尝试。如何减少传递尝试，并在每次尝试之间添加一个时间？
浏览 4提问于2021-06-23得票数 0
回答已采纳
我有一个推送订阅，它向云运行服务发送消息。如果Cloud服务没有成功地确认消息(负确认)，我希望在每次重试之间的时间间隔总是相同的情况下，重新发送消息的次数最多(例如，每次重试在1分钟后进行10次重试)。
我知道我可以用一个死信队列来设置消息重发的最大次数(我也可以在没有死信队列的情况下设置这个数字吗？)因此，只需在最大值之后丢弃/删除消息。不将消息传递到另一个队列的尝试次数？)。
此外，使用重试策略，我可以设置最小退避(例如，1分钟)。为了决定什么时候以后，第一次重试会发生，但是在那之后，PubSub的重试策略会使用一些指数延迟。这里我可以不指定线性延迟(总是相同的时间间隔)吗？
浏览 0提问于2021-10-14得票数 2
回答已采纳
我目前正在使用以下方法https://docs.spring.io/spring-cloud-gcp/docs/1.2.4.BUILD-SNAPSHOT/reference/html/#spring-integration集成PubSub 基本上，我订阅了一个主题，我收到消息并对其做一些事情。 我想，在我的业务规则出现任何错误的情况下(比如因为X，Y，Z原因而不接受消息)，将其发送到dlq。 我看到就在一个半月前，谷歌推出了PubSub的DLQ：https://cloud.google.com/pubsub/docs/dead-letter-topics 但我不确定将其与spring集成方法
浏览 28提问于2020-07-21得票数 1
回答已采纳
我有一个函数，它有一个简单的测试代码，如：
exports.helloPubSub = (event, context) => {
const message = event.data
? Buffer.from(event.data, 'base64').toString()
: 'Hello, World';
console.log(context);
throw new Error("Fail");
};
当我向Pub/sub发布消息时，函数会失败
浏览 3提问于2020-06-02得票数 3
回答已采纳
有没有办法设置我发布的Google Pubsub消息(Bad request)的过期时间，这样它就不会在失败时无限期地重试？
我无法将此配置为使用重试，因为我希望有效的错误消息可以无限期地重试
浏览 2提问于2015-08-28得票数 3
在GKE中，如果我有一个设置为使用pull方法的发布/订阅主题和一个充当该主题的订阅者的API，如果这个API有一个3的复制(spec.replicas: 3)，那么API (客户端)的开箱即用行为是什么？ 即当一条消息被推送到topic时，如果接口是asynchronously pulling messages from topic (https://cloud.google.com/pubsub/docs/pull#asynchronous-pull)，并且replication为3，那么这3个pods会不会同时拉取这条消息(最终会出现重复)？在幕后是否存在某种负载平衡？开箱即用的行为是
浏览 26提问于2021-02-03得票数 0
回答已采纳
1回答
在Spring应用程序中，我使用spring流为PubSub (spring gcp-pubsub binder)订阅一个主题。
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupI
浏览 3提问于2020-07-03得票数 1
我正在建立一个近乎实时的服务。输入是云存储桶和到照片图像的blob路径。这种水平可伸缩的服务由多个组件组成，包括运行在k8s和Google函数上的ML模型，由于各种原因，每个组件都有失败的可能。ML模型是独立的，并行运行。每个组件都由组件特有的PubSub推送消息主题触发。运行一张照片的整个流程可能需要15秒。
我希望将一条含义错误消息返回给服务请求者，告诉如果出现故障，哪个组件失败了。本质上，我想报告哪个图像失败了，哪个图像失败了。
将错误返回给请求者的推荐做法是什么？
浏览 3提问于2020-08-16得票数 0
回答已采纳
我有一个将数据写入Google Cloud pubsub的应用程序，根据pubsub的文档，由于重试机制而导致的重复是偶尔会发生的事情。还有失序消息的问题，这在pubsub中也没有保证。
此外，根据文档，可以使用Google Cloud Dataflow对这些消息进行重复数据删除。
我想让这些消息在消息队列(即云pubsub)中可用，以供服务使用，并且云数据流似乎确实有一个pubsubio编写器，然而，您不会回到写入pubsub可能会创建重复的完全相同的问题吗？这不也是顺序的问题吗？如何使用pubsub (或任何其他系统)按顺序传输消息？
是否可以使用云数据流从pubsub主题读取并写入另一个
浏览 46提问于2019-03-12得票数 2
5月1日快乐，
我正在做一个简单的POC来利用PusSub的死信主题特性。我将订阅配置为在20次最大传递尝试之后将邮件重新发布到一个单独的死信主题(下面是使用的订阅拉码和示例消息)。
注意:我使用云控制台配置了订阅。
Problem/challenge:即使尝试了36次传递，测试消息仍然没有被重新发布到死信主题。根据文档，我将假设我的测试消息将被重新发布到死信主题，并且不应该在20次尝试之后传递。我遗漏了什么？
请求订阅代码
const {PubSub} = require('@google-cloud/pubsub');
var moment = require(
浏览 3提问于2021-05-01得票数 1
我正在成功地使用MassTransit (与RabbitMQ一起)实现了一个竞争的使用者拓扑:我可以在一个队列中有0或多个消费者，每个用户一次预取和使用一个消息(典型的负载平衡场景)。
为了处理可能的故障，我可以想象两种情况：
使用者崩溃了(在消息中没有ACK )如果没有注册其他使用者，或者传递给下一个正在运行的=>，消息将保持在队列中
，使用者在处理数据时抛出一个异常，消息被发送到_error队列->，我能避免这种情况吗？在本例中，我希望消息遵循与上面步骤相同的规则:如果没有其他消费者或被传递给正在运行的使用者，则保持队列状态(即使它是以前失败的)。
这与Mass
浏览 4提问于2021-09-28得票数 1
回答已采纳
我有一个云函数订阅了Pub/Sub主题。
根据，如果云函数返回一个不成功的响应，它将重新发送消息：
端点通过返回HTTP成功状态代码来确认消息。一个不成功的响应表示消息应该被憎恨。
我的问题是:如果一个不成功的回应，信息将立即被愤怒，或Pub/Sub将遵守确认的最后期限来重新发送消息？
更新：
我认为这个问题没有任何意义，我会解释原因。
由于您无法访问Pub/Sub函数中的Response对象，因此无法直接发送响应代码(我对此不太确定，因此如果我错了，请纠正我)。
因此，不成功的反应只能由以下几个方面引起：
超时，这是基于确认的最后期限，所以在这种情况下，确认的最后期限显然是尊重。
浏览 0提问于2019-07-08得票数 5
回答已采纳
我有一个spring服务，订阅来自google cloud pubsub (拉取)主题的消息。它总体上工作正常。但我想要更多地控制重新发送的消息。我的服务有时需要阻止消息，或者只是让ackDeadline通过，这样我以后就会再次获得消息。在测试单个消息时，nack消息几乎立即返回给我，而那些我根本没有确认或nack的消息，在ackDeadline默认10秒后返回。我希望它推迟对这些消息的重复消费。我以为重试设置就是为这种情况设计的。我还应该提到的是，我目前正在使用模拟器进行本地测试，并从代码创建订阅。我正在使用PubSubAdmin进行管理。 根据此docu，我已尝试在我的配置文件配置中设置
浏览 37提问于2019-02-05得票数 3
回答已采纳
我已经使用本教程部署了简单的PubSub云函数触发器：
为了测试，我将大消息(超过8MB)推送到PubSub主题。
结果，云函数在日志中返回了以下错误消息：Function execution could not start, status: 'request too large'
问题是，Cloud Function开始不断地启动，产生持续的资源使用和日志消息。只有在我手动清除相关的PubSub主题后，它才会停止。
是否有防止此类行为的机制/配置？理想情况下，云函数触发器执行后，PubSub消息不会被再次拾取。
浏览 0提问于2020-08-04得票数 0
4回答
我正在使用Pubsub(推送)和Cloud Run，我将在其中部署一个使用Spring Boot构建的Java应用程序。 我有两个案子。假设我有Service A在云上运行时，由于负载较高，需要运行10个容器/实例。我想： 推送消息(来自云函数)到全部(广播)的容器Service A 推送消息(来自云函数)到单一任意容器Service A 背景：我的Cloud Run服务将使用服务器发送的事件将数据直接推送到客户端/浏览器。这当然意味着容器/实例将保持一种状态。在某些情况下，我需要将消息推送到所有sse/ws连接 在所有容器上(想象一个带有公共聊天室的聊天应用程序，其中每个人都可以看到发布的
浏览 69提问于2021-02-14得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
