腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(3053)
视频
沙龙
1
回答
RabbitMQ
的
消费者
并没有加起来
rabbitmq
、
spring-amqp
我们有一个Java应用程序,它使用
Spring
AMQP
从rabbitmq获取消息。对于一些队列,
消费者
的
数量
没有增加,导致消息传递速度变慢。例如,即使将
最大
消费者
设置
为50,对于9000条消息
的
负载,
消费者
的
数量
在大部分时间内保持为6。 但是,对于其他队列,情况并非如此。也就是说,其他队列
的
消费者
计数达到了35。我们使用SimpleMessag
浏览 2
提问于2016-09-30
得票数 0
1
回答
Spring
AMQP
有没有
办法
设置
所有
虚拟机
的
最大
消费者
数量
?
spring-amqp
、
spring-rabbit
我有4个
spring
boot应用程序实例在4个不同
的
JVM上运行。
有没有
办法
设置
最大
的
全球
消费者
?目前我有setMaxConcurrentConsumers(1);集合。我希望在4个JVM上创建一个
消费者
。我目前正在使用SimpleRabbitListenerContainerFactory,并希望这个功能可以在那里使用。基本上,我想我是在问如何在RabbitMQ
的
Spring
-
AMQP<
浏览 28
提问于2018-12-27
得票数 1
回答已采纳
1
回答
在
Spring
AMQP
中,我们可以在
消费者
端
设置
超时吗
rabbitmq
、
spring-amqp
、
spring-rabbit
在
Spring
AMQP
中,我们可以在
消费者
端
设置
超时吗?我们有一个
AMQP
消息到达
消费者
端
的
用例public class TestListener implements MessageListener {onMessage(Message message) { // some error logic which got hanged the consumer thre
浏览 23
提问于2017-02-03
得票数 0
1
回答
弹性兔
amqp
@RabbitListener
设置
最小和
最大
消费
数量
java
、
spring
、
rabbitmq
、
spring-amqp
、
spring-rabbit
我使用
的
是
spring
amqp
rabbit @RabbitListener注解,来自: annotation
spring
-rabbit 1.7.1.RELEASE我想知道是否有一种方法可以为每个队列配置
消费者
数量
我一直在挖掘文档,但还没有找到任何东西,
有没有
办法
在相关
的
容器中为每个队列配置
消费者
的
数量
?提前谢谢。
浏览 2
提问于2017-04-02
得票数 1
回答已采纳
1
回答
在春季
AMQP
中增加同时消费的人数有价格吗?
rabbitmq
、
message-queue
、
spring-amqp
Spring
AMQP
说 在对我
的
应用程序进行性能测试时,我注意到,相对于队列中
的
项目数,提高并发使用者
的
数量
会使应用程序更快。但是,我不知道在增加
消费者
数量
的
同时是否付出了代价呢?我
的
意思是,如果我大幅增加并发使用者
的
数量
,是否会耗尽服务器上<e
浏览 5
提问于2014-10-12
得票数 4
1
回答
RabbitMQ &
Spring
amqp
重试,不阻塞
消费者
rabbitmq
、
spring-amqp
、
spring-retry
我正在使用RabbitMQ和
Spring
amqp
,我不希望丢失消息。通过对重试使用指数退避策略,我可能会阻止我
的
消费者
,他们可能正在处理他们可以处理
的
消息。我想给失败
的
消息几天
的
时间来重试指数退避策略,但我不希望
消费者
阻塞几天,我想让它在其他消息上继续工作。
有没有
办法
用
Spring
amqp
和RabbitMQ实现这一点?
浏览 4
提问于2014-06-28
得票数 0
2
回答
rabbitmq中
的
预取计数与无ack之间
的
区别是什么
rabbitmq
、
spring-amqp
、
spring-rabbit
我想知道在rabbitmq中预取计数和无ack
的
区别是什么?如果我将预取计数
设置
为10,是否会创建10个
消费者
线程?
浏览 9
提问于2016-09-26
得票数 3
回答已采纳
1
回答
使用
Spring
AMQP
监听许多短暂
的
、动态创建
的
队列
java
、
rabbitmq
、
spring-amqp
、
spring-rabbit
我正在使用RabbitMQ/
Spring
/
Spring
AMQP
构建一个应用程序,并且在处理我
的
队列布局时遇到了问题。从本质上讲,我有一个每个
消费者
都会监听
的
队列,每个消息基本上都说“这个队列已经准备好由一个
消费者
来处理了”。然后,使用者将侦听消息中指示
的
队列,使用该队列中
的
所有
消息,最后在完成时将其删除。这些短暂
的
队列都是在数据进入处理时动态创建
的
,不能被多个
浏览 41
提问于2019-10-02
得票数 0
回答已采纳
1
回答
Spring
AMQP
-检测被拒绝
的
邮件?
rabbitmq
、
spring-amqp
、
spring-rabbit
在
Spring
AMQP
中
有没有
一种方法来检测
消费者
何时拒绝了一条消息? 我
的
应用程序声明了交换,但是使用者声明了队列。我知道
消费者
可以
设置
一个死信交换,但我想把这个责任从
消费者
身上去掉。我需要以某种方式被通知
消费者
拒绝了一条消息。
浏览 25
提问于2019-12-07
得票数 1
回答已采纳
1
回答
如何配置
Spring
SimpleMessageListenerContainer receiveTimeout以扩大到合理
的
用户
数量
spring
、
rabbitmq
、
amqp
、
spring-amqp
用例:后端以不同
的
速率使用消息并将消息插入到DB中。问题:我试图找到
spring
SimpleMessageListenerContainer
的
适当配置,以便让
spring
将用户
的
数量
增加/减少到足够
的
数量
,以便处理传入
的
流量。1000 例如:注入速率: 100毫升/秒container.setReceiveTimeout(100L); // 100 ms ->
消费者
1
浏览 13
提问于2022-11-22
得票数 0
1
回答
如果
设置
autoAck=true,是否立即将消息发送给使用者?
rabbitmq
、
spring-amqp
其中有一个包含10000条消息
的
队列。启动使用者(autoack=true)时,我可以从rabbitmq_management中看到消息
数量
迅速变为零。这是否意味着
所有
10000条消息都在
消费者
一方?它存放在哪里(我正在使用
Spring
-
AMQP
)?如果我
的
使用者配置
的
并发性是1,并且处理一条消息需要很长时间,那么是否有可能耗尽内存(如果消息
的
数量
很大)?
浏览 5
提问于2021-02-19
得票数 0
回答已采纳
1
回答
覆盖SimpleMessageListenerContainer.setDefaultRequeueRejected(false)行为
rabbitmq
、
spring-amqp
、
spring-rabbit
我们一直在使用一个框架来使用
Spring
AMQP
,该框架
设置
了SimpleMessageListenerContainer.setDefaultRequeueRejected(false), 这意味着如果从
消费者
抛出异常
有没有
方法可以在不更改SimpleMessageListenerContainer.setDefaultRequeueRejected(true)
的
情况下更改此行为
浏览 58
提问于2017-01-23
得票数 3
1
回答
Spring
AMQP
Rabbit模板发送超时
java
、
spring
、
timeout
、
rabbitmq
、
amqp
我正在使用
Spring
AMQP
libarary (1.1.4.Release)向Rabbit MQ Exchange发送消息。此RabbitTemplate是使用CachingConnectionFactory创建
的
,并将PublisherConfirms和PublisherReturns
设置
为true。最近,当生产者和
消费者
都在发送消息
的
过程中关闭了与RabbitMQ代理/交换
的
连接时,我们遇到了网络问题。这会导致抛出org.springframewor
浏览 1
提问于2014-03-19
得票数 3
1
回答
使用
Spring
集成和RabbitMQ
的
耐用RPC
rabbitmq
、
amqp
、
spring-integration
我已经创建了一个简单
的
消息发送者和
消费者
,并使用
spring
集成和RabbitMq将它们链接在一起。当
消费者
在发送者之前启动时,这种方法工作得很好,但如果
消费者
在发送者之后启动,我就不会收到响应。我可以看到
消费者
收到了消息,但没有返回响应。 在进一步
的
检查中,我
浏览 0
提问于2012-10-24
得票数 3
回答已采纳
1
回答
通过一个春兔服务中
的
一个
消费者
并发处理多个
amqp
消息
java
、
spring
、
rabbitmq
、
spring-rabbit
那么,
AMQP
接收方
的
多个实例如何共享
消费者
总数呢?因此,我希望将concurrentConsumers
的
全局
数量
设置
为10,运行两个consumerSerivce实例,并让每个实例运行大约5个
消费者
。这可以由rabbitMq来管理吗?我需要
的
是让我
的
amqp
服务从队列中获取一定
数量
的
消息,在单独
的
线程中处理它们,在每个线程中进行http调用,并返回带有"
浏览 3
提问于2020-01-22
得票数 0
1
回答
带有预取
的
Spring
单用户并行性
spring
、
multithreading
、
rabbitmq
、
spring-amqp
我们有一个使用
Spring
来使用来自RabbitMQ代理
的
消息
的
项目。我们希望增加消费端
的
并发性,以便多个工作线程可以并行地处理消息。handleDelivery方法
的
DefaultConsumer可以生成一个新
的
Runnable来完成工作,并在工作结束时确认消息。预取计数有效地控制了使用者生成
的
最大
Runnable数。在SimpleMessageListenerContainer中,对于每个
AMQP
使用者,
所有
消息
浏览 8
提问于2016-05-03
得票数 1
回答已采纳
1
回答
Spring
RabbitMQ -为每个连接缓存多个通道?
java
、
rabbitmq
、
amqp
、
spring-amqp
使用
Spring
AMQP
的
默认缓存策略是创建具有多个通道
的
单个连接。创建通道
的
数量
取决于监听器
的
并发性。当我们有几个监听器时,假设有10个监听器,每个监听器需要5个并发。这会创建一个具有50个通道
的
连接,这远远超过了推荐
的
数量
浏览 1
提问于2020-11-19
得票数 2
1
回答
我能有多少
消费者
?(
Spring
-boot + RabbitMq)
spring-boot
、
rabbitmq
、
spring-amqp
、
spring-rabbit
我在RabbitMq中使用
Spring
,出现了一个问题,我可以创建
的
用户
数量
有限吗?我在哪里能找到这个价值?
浏览 3
提问于2021-12-03
得票数 0
回答已采纳
1
回答
触发消费组再平衡
spring-kafka
有没有
办法
在不重启
spring
kafka容器
的
情况下(并且在元数据
最大
寿命之前)手动触发重新平衡?从Kafka 2.6开始,就有了enforceRebalance()来触发来自
消费者
API
的
重新平衡,但它在
spring
kafka容器中是私有的。
浏览 26
提问于2021-11-22
得票数 0
回答已采纳
1
回答
@KafkaListener并发多个主题
apache-kafka
、
spring-kafka
我想要创建一个并发
的
@KafkaListener,它可以处理多个主题,每个主题都有不同
数量
的
分区。 我注意到
Spring
只为这个主题初始化了一个每个分区
的
使用者,而且大多数分区都是这样。示例:我已经将并发
设置
为8。我得到了一个@KafkaListener,它可以收听以下主题。主题A有最多
的
分区- 5,所以
Spring
初始化了5个
消费者
。我期望
Spring
初始化8个
消费者
,根据我
的
并
浏览 3
提问于2018-08-29
得票数 6
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RabbitMQ之消息确认机制
springcloud微服务架构开发实战:分布式消息总线
RabbitMQ消息确认机制
什么是 Azure 服务总线?
Spring 中的 bean 是线程安全的吗?
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券