Google pub/sub如何设置读取超时

Question

我想设置订阅请求的读取超时。现在唯一的选择是设置returnimmediately=true，或者只是等到pubsub返回，如果没有发布消息，这似乎是90秒。

我正在使用gcloud-node模块调用PubSub。它使用底层的请求模块进行gcloud api调用。我已经更新了gcloud-node/lib/pubsub/subscription.js的本地副本，将请求超时设置为30秒

this.request({
  method: 'POST',
  uri: ':pull',
  timeout: 30000,
  json: {
    returnImmediately: !!options.returnImmediately,
    maxMessages: options.maxResults
  }
}

更新：我可能需要澄清一下我的例子。我有两个客户端连接在同一时间和拉从同一订阅。两者之间唯一的区别是第一个配置为30秒后超时。由于两个客户机连接到同一个订阅，所以pubsub将在这两个客户机之间分配消息负载。如果我在两个客户端连接45秒后发布消息，则pubsub有50/50的机会将消息传递给尚未超时的第二个客户端。如果我发送10条消息而不是一条，第二个客户机将接收这10条消息的子集。看起来这是因为我的客户在长时间的投票中。如果客户端断开连接，服务器将不知道，并将尝试根据超时的客户端发出的请求的响应发送已发布的消息。从我的测试中，这是我观察到的行为。我想做的是能够在pull请求中发送一个超时参数，以告诉subpub在30000ms后如果在此期间没有发布消息就发回一个响应。阅读API文档，这似乎不是一个选择。

Answer 1

设置请求超时是在30秒后超时拉拔的正确方法。已取消请求的存在可能不是导致另一个请求不能立即获得消息的原因。如果您的第二次拉取（未超时）设法拉取先前发布的其他消息，则不一定要等待超时后发布的其他消息传入才能完成。它只保证返回的不超过maxmessages，而不是只在它恰好有maxmessages时才返回（如果有那么多）。发布完成后，一些稍后的pull将获得消息，但不能保证具体何时发生。