如何配置GCP PubSubTemplate的pull拉取超时时间
回答
你提到的Pull请求无消息时的等待时长就是Pub/Sub长轮询的最大等待时间,在spring-cloud-gcp 3.3.0版本下完全支持自定义配置,分两种使用场景对应配置方式:
- 同步主动拉取场景(即你主动调用
PubSubTemplate.pull()方法拉取消息的模式):直接在application.properties/application.yml中配置参数spring.cloud.gcp.pubsub.subscriber.pull-timeout即可,参数值为数字类型,单位默认是毫秒,配置后底层发起Pull请求时会自动将该值作为等待时长传入,超过时长仍无消息就会返回空响应。 - 异步监听场景(即使用
@PubSubListener注解自动消费消息的模式):配置参数spring.cloud.gcp.pubsub.subscriber.max-await-timeout,参数值传Duration类型对应的值(比如15s代表15秒),控制底层长连接拉取的空闲等待时长,逻辑和REST接口的等待规则完全一致。
如果你没有用框架自动装配的Subscriber实例,是手动编码构建Subscriber客户端,直接在构建Subscriber实例时调用setMaxAwaitDuration()方法,传入你想要设置的Duration类型时长参数即可,不需要走配置文件。
补充说明:3.3.0版本默认的等待时长是10秒,不建议把这个值设置超过30秒,否则容易触发网络链路的空闲超时规则,导致拉取请求被意外中断报错。
内容的提问来源于stack exchange,提问作者2240
相关产品推荐
相关产品推荐

