我想知道在rabbitmq中预取计数和无ack的区别是什么？如果我将预取计数设置为10，是否会创建10个消费者线程？
浏览 9提问于2016-09-26得票数 3
回答已采纳
我一直在使用C#和python中的rabbitmq客户机测试消息的吞吐量。在这两个客户端之间，我看到每个客户端所消耗的带宽都存在差异。我正在以5Hz的速度发布来自python生产者的400‘m的随机数据消息。我可以在我的rabbitmq管理控制台上看到它以5Hz接收消息。这样就可以使用~18 18Mbps的带宽。method, properties, body
浏览 29提问于2022-06-29得票数 2
最近对RabbitMQ服务器的升级中，管理面板中的使用者报告的预取计数发生了变化。
我们允许动态调整线程计数和预取计数。我们应该使用什么参数组合到Model.
浏览 2提问于2017-05-04得票数 19
1回答
在我们公司，我们在Go中构建了一个推送服务，并将其放在四台机器上以确保传输速度，当我们需要发送通知时，我们发送消息给rabbitMQ，然后推送服务将从队列中获取消息，但有时我们发现只有一台机器获得消息。以下是rabbitMQ使用者的配置： q.Name, // queue
consumerTag, // consumertrue, // auto-a
浏览 0提问于2018-06-15得票数 0
4回答
我对RabbitMQ有一个严重的问题。在接收到一定数量的消息后，消费者简单地停止接收消息。它们仍然连接在一起，但不再接收消息。我找到了关于这个问题的其他帖子，但都没有一个有效的答案。我尝试过在不使用ack或使用ack且qos预取计数为100的情况下使用消息(如对此类问题的几个响应中所示)。当我执行"rabbitmqctl list_queues name messages
浏览 0提问于2011-07-18得票数 5
我使用NServiceBus 4.x和RabbitMQ 3.2.x作为传输。我假设，通过使用RabbitMQ作为我的传输，我将被给予竞争的消费者模型作为一种选择。我观察到的是订阅者阻止访问队列中的进一步消息检索，直到消息被消耗为止。因此，在这一点上，拥有一个以上的消费者对我没有好处，没有其他好处，只有冗余。在阅读了一些关于RabbitMQ的文档之后，我假设在从订阅服务器发送Ack收据之前阻塞是正常<
浏览 6提问于2013-11-06得票数 2
回答已采纳
1回答
AMQP:确认和预取
、、、
我试着理解AMQP协议的一些方面。目前，我有项目与RabbitMQ和使用python库。因此，问题在于确认和消息预取。
浏览 2提问于2014-02-08得票数 8
回答已采纳
我对Python中的RabbitMQ实现PIKA有一个问题。我想使用队列中的1条消息，使用它，并在工作完成后确认它。然后应该接收到下一条消息。我使用了prefetch_count =1选项，告诉rabbitMQ，这个消费者一次只需要一条消息，在此消息被确认之前不需要新消息。，为什么rabbitmq发送的文档(40/秒)比确认的(0.20/秒，更正，因为暂停5秒)更多。这两者不应该是平等的吗？此外，
浏览 1提问于2019-12-13得票数 2
回答已采纳
在较低的级别上，预取计数和批处理大小(批处理)之间的区别是什么，或者它们是如何相关的？ 换一种方式来说，一个值对另一个值有影响吗？此外，除了批处理之外，有没有一种方法可以获取侦听器中的所有“预取”消息？
浏览 33提问于2020-08-19得票数 0
RabbitMQ提供了可选设置预取计数的能力。
使用spring的SimpleMessageListenerContainer，我注意到预取计数总是被设置的。我不能将预取计数设置为0，因为SimpleMessageListenerContainer将其设置为至少txSize，该值必须大于零(即使不涉及事务)。那么是否有一种方法可以禁用预取
浏览 5提问于2016-06-11得票数 1
回答已采纳
在RabbitMQ中，在使用者接收和处理消息之后，我可以ack消息，也可以nack消息。
使用requeue true对消息进行Nacking将返回到队列中，但是requeue false不会。所以我想知道消费者Ack和requeue false之间的区别是什么，或者我们可以只使用ack而不是nack
浏览 1提问于2022-03-04得票数 0
回答已采纳
我试图在rabbitmq配置中设置预取计数为100000，但它将通道的预取计数设置为34464。factory.setPrefetchCount(100000); return factory;期望省长计数设置为
浏览 0提问于2019-08-26得票数 0
我需要检查我的订阅在过去15天内是否有任何拉动，我应该考虑哪个指标？订阅/拉取消息操作计数订阅/pull_ack_message_operation_count
订阅/pull_ack_request_count
浏览 1提问于2017-03-01得票数 2
它在RabbitMQ文档中声明如下
“经验法则是，在线程之间共享通道实例是必须避免的。应用程序应该更喜欢使用每个线程的通道，而不是在多个线程之间共享相同的通道。”目前，我们正在查看预取计数，建议如果您有少量的使用者和autoack=false，那么我们应该同时使用许多消息。但是，我们发现，如果使用者使用单个执行线程发送手动确认，则预取不会产生效果。但是，如果我们
浏览 0提问于2019-02-08得票数 3
回答已采纳
2回答
我编写了一个C(Rabbitmq)工作程序，它使用Python脚本(pika)发布的队列。
但是:在工作人员开始从队列中消费之后启动额外的工作人员，意味着这些工作人员看不到队列上的任何消息(message count=0)，因此只需等待(即使队列中仍然有许多消息杀死第一个工作人员会突然启动消息流到所有其他(等待)的消费者
浏览 11提问于2014-08-01得票数 4
回答已采纳
2回答
我正在试验Spring作为微服务课程的一部分。要执行的无服务器任务- 安装以上组件，确保任务组件在本地maven存储库中可用。
但是，我看不到与无服
浏览 0提问于2018-10-23得票数 1
回答已采纳
我正在一个总线中创建多个ReceiveEndpoint，它处理不同类型的消息。在我看来是同样的问题。busControl.StartAsy
浏览 5提问于2017-04-26得票数 0
回答已采纳
1回答
我们有一个使用Spring来使用来自RabbitMQ代理的消息的项目。我们希望增加消费端的并发性，以便多个工作线程可以并行地处理消息。我首先阅读了本机RabbitMQ客户机的文档，然后介绍了使用单个使用者和预取计数>1来控制并行性的设计。直接使用RabbitMQ客户机，这似乎是很自然的。handleDelivery方法的DefaultConsumer可以生成
浏览 8提问于2016-05-03得票数 1
回答已采纳
1回答
我正在使用英特尔Xeon 2660 v3，并发布了大量的软件预取，以利用MLP以及减少失速时间。现在，我想对应用程序进行分析，以获得软件预取带来的总体收益。在“利用自适应执行提高软件预取的有效性”一文中，讨论了与软件预取相关的硬件性能计数器支持。
我把论文中的文字放在这里，作者们在这里讨论了性能计数</
浏览 4提问于2017-12-28得票数 2
1回答
我一直在使用RabbitMQ构建一个分布式网络爬虫。到目前为止，我一直在使用这个函数，这样每个函数一次只能得到一个请求。是否有办法使每次处理的消息数量最大化？我不想让这个prefetch_count成为静态的，而是在给定的时间处理尽可能多的消息。
浏览 1提问于2017-04-27得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
