如何设置超时到谷歌发布者和订阅者?

Question

在我的java代码中，我使用Google -pubsub。

如何设置 超时

订阅者 - 等待消息直到超时到期？ (如何设置重试策略？

发布者 - 等待消息发送timeout时间。 (如何设置重试策略？

我看到了这篇文章，但没有设法将js帖子翻译成java

这是我如何设置我的潜艇

final Subscriber subscriber = Subscriber
.defaultBuilder(subscriptionName, receiver)
.setChannelProvider(channelProvider)
.build();

和酒吧

final Publisher publisher = Publisher.defaultBuilder(topicName)
.setChannelProvider(channelProvider)
.build();

Answer 1

使用最新的 Cloud Pub/Sub 客户端库，您无需在订阅服务器中设置超时或重试策略。这些是在后台为您处理的，您只需要将MessageReceiver传递到defaultBuilder中即可。当消息可用时，它们将被发送到接收消息。如果您的订阅因任何不可重试的原因而停止，则订阅服务器将被关闭。您可以通过在订阅服务器上调用 addListener 来侦听这些通知。

在发布服务器上，可以在生成器中使用 setRetrySettings。特别是，您希望在RetrySettings.Builder上设置TotalTimeout。发布者将在此总截止时间之前对可重试错误的发布调用。