SpringCloudStream - RabbitMQ粘结剂的慢消费者

Question

我有一个usecase将http POST发送到一个HTTP，它作为Spring应用程序与的http源代码一起创建。此过程用于发布5k记录/秒。我有一个Sink应用程序来将数据持久化到Mongo。在应用程序中阅读的速度非常慢，为每秒20毫希。我使用以下属性，没有区别。我使用相同的前缀加载属性- spring.cloud.stream.rabbit.binder。请让我知道如何在读取来自RabbitMQ绑定器的数据时实现并发性。

application.properties

spring.cloud.stream.binder.rabbit.default.prefix=z.
spring.cloud.stream.bindings.input.destination=http-source
spring.cloud.stream.bindings.input.durableSubscription=true
spring.cloud.stream.bindings.input.group=default
spring.cloud.stream.rabbit.binder.addresses=localhost:5672
spring.cloud.stream.rabbit.binder.username=guest
spring.cloud.stream.rabbit.binder.password=guest
spring.cloud.stream.rabbit.binder.listener.concurrency=100
spring.cloud.stream.rabbit.binder.listener.max-concurrency=500
spring.cloud.stream.rabbit.binder.listener.prefetch=1000
spring.cloud.stream.rabbit.binder.listener.acknowledge-mode=NONE

server.port=${listen.port}

####################################################
# Mongo
#      Configuration - DEV
####################################################
mongodbDatabasename=*****
mongodbPassword=*****
mongodbUsername=*****
mongodbReplicaName=
mongodbAddresses=localhost:27017
mongodbAuthenticationDatabase=users
mongodbAuthMechanism=SCRAM-SHA-1
region=DEV
collectionName=*****
mongodbSocketTimeout=25000
mongodbConnectionTimeout=5000
maxConnectionForHost=5
minConnectionForHost=100

谢谢，谢谢你的帮助，卡西克

Answer 1

我相信您需要将并发性和其他与消费者相关的属性设置为按绑定的使用者属性(前缀为：spring.cloud.stream.rabbit.bindings.<channelName>.consumer. )。您可以参考更详细的这里

不确定您是如何得到前缀为spring.cloud.stream.rabbit.binder.listener.concurrency的属性的。你在文档里看到这个了吗？