0回答
我有一个包含50个消费者和大约100个预取计数的队列。所有的使用者都来自单个JVM实例。因此，当应用程序关闭时，消息处于就绪状态。就绪状态的消息数等于(prefetch_count * no。现在的问题是，处于就绪状态的消息会发生什么情况？它会重新投递吗?还是会变得死气沉沉？
浏览 12提问于2017-06-19得票数 0
回答已采纳
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
1回答
我创建了RabbitMQ侦听器： $AMQP_config['server'], $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);}
我的RabbitMQ服务器上有5条消息。我想检查队列中的所有
浏览 1提问于2015-04-20得票数 4
我能够停止消费并重新启动消费，但问题是，当我重新启动消费时，我能够处理已经发布的消息，但是当我发布无法处理的新消息时。import com.rabbitmq.client.Channel;public class RabbitMqueueable to see the newly published messages to the queue I mean
//newly published messag
浏览 3提问于2018-07-02得票数 4
回答已采纳
如何使用C#从RabbitMQ中的队列接收单个消息我想按照先进先出的标准检索单个消息。请向我提供使用RabbitMQ从队列中获取单个消息的代码 var channel= connection.CreateModel()
浏览 12提问于2019-07-25得票数 0
很长一段时间以来，我在运行RabbitMQ消费者方面都面临着一个问题。我的几条消息最终处于被破解的状态。我的RabbitMQ版本: 3.6.15 Pika版本: 0.11.0bimport timeimport threadingrabbitmq_server = "<SERVER>"connection = None
de
浏览 0提问于2018-03-07得票数 0
回答已采纳
这就是问题所在，当出现Ack时，它总是将消息从就绪队列拖到UnAck。因此，下一次我将丢失这条从未退出队列的UnAcked消息。但是如果我停止进程(Console App)，UnAck消息将返回到就绪状态。
假设在开始时有10条消息处于就绪状态，在结束时它只处理5条消息，在那里您可以找到5条处于UnAcked状态的消息。每个Ack都生成下一个消息UnAck。如果我再次停止并运行(5条消息处于就绪状态
浏览 1提问于2015-09-16得票数 1
回答已采纳
2回答
我在RabbitMQ中有一个发送事件的频道(甚至每秒钟都可以)。我想每1000个处理一次。主要的问题是RabbitMQ接口(我使用的是pika)对每条消息都进行回调。
浏览 1提问于2019-08-06得票数 4
回答已采纳
在异常情况下，在处理来自RabbitMQ的消息时，我只想不确认并将特定的消息返回到一个不同的队列，或者重新队列到同一个队列，或者完全丢弃消息(按照basicNack中的最后一个布尔标志@requeue)整个想法是以后，我可以得到解码消息的计数和检查消息格式等，而不是一次又一次地重新队列到同一个通道，我也想发送未确认的信号到当前信道。message.getMessageProperties().getDeliveryTag(),false);catch(Ex
浏览 1提问于2014-08-18得票数 2
回答已采纳
我在Google引擎上配置了下面的水平Pod自动调用者配置，通过自定义度量- RabbitMQ messages ready count来扩展特定队列的部署：foo-queue。当插入2条消息时，它会将部署扩展到最多10个副本。我希望它能扩展到2个副本，因为targetValue是1，并且有2条消息已经准备就绪。 metrics: external:
metricName: "custom.goo
浏览 5提问于2019-09-10得票数 6
回答已采纳
3回答
我使用的是一个SimpleMessageListenerContainer，每隔一个小时左右，队列就会被卡住，没有任何东西会因为破解消息而被处理。另外，如果我想抛出一个AmqpException并重新排队，这个消息就不能工作，确认模式设置为NONE。
我的问题是，如何跟踪队列卡住的问题，是否有方法查看unack‘s消息的有效负载？或者，如果抛出异常，是否存在允许不需要确认但重新队列消息的确认模式？
浏览 2提问于2015-02-02得票数 2
回答已采纳
1回答
$rabbitmqctl list_queues
Listing queues for vhost / ...amq.gen-o9dl3Zj7HxS50gkTC2xbBQ 0兔looks的输出如下所示。我搞不懂每一列的目的是什么。我怎样才能看到每一列的意义？
浏览 0提问于2018-03-12得票数 1
1回答
我有基本的脚本来接收amqp消息并将它们转发到socket.io --它工作了几个小时，有时工作了几天，但最终它停止了转发amqp消息，同时继续发出心跳。日志显示，当amqp消息到达时，它并不试图发出socket.io消息，所以我认为问题在于amqp连接/订阅，而不是socket.io。我测试了在脚本运行时手动关闭和重新启动rabbitmq服务器，它似乎没有问题重新连接并继续正常工作。require("amqp"),
socketio = r
浏览 3提问于2014-02-06得票数 1
回答已采纳
我正在寻找一种方法来检索未确认消息，并将它们放回就绪状态，以便我的消费者可以再次发送回这些消息。
我正在使用java客户端获取消息，这些是我发送和检索消息的程序。我读到有一个方法basicRecover()可以将消息放回队列中。System.out.println("Error:"+e.getMessage()); }
有没有人可以给我提供一个代码片段，这样unack消息
浏览 7提问于2014-08-05得票数 1
作为单用户在我的开发机器上运行，我有一个通过EasyNetQ/Rabbitmq消费消息的解决方案。发送和订阅效果很好。但是，现在我正在调试消息处理程序中的一个问题，在调试过程中，我可以看到消息从Unacked中删除，并放回Ready中。这会导致产生一个新的线程，并使我的调试变得不必要地困难。有没有办法让RabbitMq放松下来，在重新发送消息之前给我多一点时间？
BR，Anders
浏览 15提问于2019-07-25得票数 2
rabbitmqadmin list vhosts显示消息，但没有队列。为什么这是可能的？| name | messages | messages_ready
浏览 3提问于2015-12-18得票数 4
我有一些代码，我想从我的Meteor应用程序的RabbitMQ中获取当前的消息计数。在Node控制台中运行代码会给出正确的回调参数，但在Meteor中相同的代码只会给出第一个参数。rabbitMQ = AMQP.createConnection({ host: '127.0.0.1' });
rabbitMQ.addListener('ready', function(){console.log('Connecting to the channel...
浏览 0提问于2013-07-13得票数 0
我在做这样的事 .process(pollingRequestStatus) // check status of the request, if not ready)当请求发生时，消息会被复制，这是否是将消息发送回同一个队列时的预期行为？我也尝试过像下面这样的建议，但是它不起作用，这个消息似乎只是被消耗掉了，而且不会
浏览 12提问于2017-08-25得票数 1
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号