是否可以动态启动RabbitMQ消费者。在特定时间后将客户连接到现有队列的平均方式？ 还是所有的消费者都应该提前创建？ 我的情况是，当队列被消息填满时，可能没有消费者。我可以在一段时间后连接消费者吗？
浏览 39提问于2019-06-09得票数 0
回答已采纳
1回答
我能够使用 RabbitMQ Java教程创建扇出交换，并且任何连接的消费者都将收到一份消息副本。我希望在连接任何使用者之前创建交换和绑定，而不是以动态/编程的方式声明交换和绑定。我已经通过RabbitMQ管理控制台完成了这项工作。然而，由于某些原因，我的消费者正在以循环方式接收消息，而不是所有接收消息的副本。我遗漏了什么？以下是一些代码片段：channel.basicPublish("public", ""
浏览 1提问于2013-03-11得票数 8
回答已采纳
我正在使用RabbitMQ/Spring/Spring AMQP构建一个应用程序，并且在处理我的队列布局时遇到了问题。从本质上讲，我有一个每个消费者都会监听的队列，每个消息基本上都说“这个队列已经准备好由一个消费者来处理了”。然后，使用者将侦听消息中指示的队列，使用该队列中的所有消息，最后在完成时将其删除。这些短暂的队列都是在数据进入处理时动态创建的，不能被多个使用者使用(无论哪个消费者获得了‘就绪’队列中的消息)。 在这种情况下，我很难优雅地处理消费者</e
浏览 41提问于2019-10-02得票数 0
回答已采纳
我刚刚创建了一个API，其中来自API的请求将使用请求/响应模式通过MassTransit/RabbitMQ转发到后端服务。我正在考虑在服务器之间创建一个RabbitMQ集群(每个服务器都有一个本地安装)，并且想知道如何在这个实例中设置竞争的消费者。RabbitMQ或MassTransit是否会处理此问题，以便只有一个消费者会收到请求，还是所有消费者都会收到请求并尝试响应？另外，对于RabbitMQ</em
浏览 0提问于2012-06-17得票数 1
回答已采纳
1回答
带Vue JS的RabbitMq
、、、、
我尝试使用rabbitMq来处理来自前端的消息，我已经有了rabbitMq和(AMQP)。我在rabbitMq中搜索Vue-Js或JavaScript，但没有找到任何有用的信息。那么我如何使用javaScript/vue-Js从rabbitMq中消费呢？
谢谢。
浏览 1提问于2020-02-28得票数 0
1回答
我正在学习RabbitMQ，并考虑使用它给用户提供“动态消息”更新，就像facebook提供来自朋友的动态提要一样。我的想法是:
知道如何实现这
浏览 5提问于2014-10-03得票数 0
这个队列应该由客户的web终端使用ajax池或服务器发送的事件进行监控，但最大的问题是如何构建这些队列，以便客户1的订单只交付给客户1，订单只交付给客户2，依此类推。我是否为每个客户创建队列，是否在redis中为每个客户创建pub /sub通道，然后在客户端上有特定的逻辑来仅轮询该客户端所属的队列？sns，sqs，redis，rabbitmq或其他什么适合这个吗？
浏览 31提问于2017-06-29得票数 0
我有一个rabbitmq队列，每个发布到这个队列的数据大约是1MB大小。每秒钟有4或5个数据发布到此队列。我知道消费速度取决于消费者。我认为兔子有一些机制，经过一段时间后，
浏览 2提问于2019-07-11得票数 0
回答已采纳
我正在开发一个系统，它有许多非常适合排队的任务，并且已经有了一些已经在不同程度上工作的家产遗留解决方案，我熟悉gearman，阅读了RabbitMQ教程，并且热衷于upgrade当前的解决方案，以使用这些更健壮的现有解决方案之一(由于灵活性和可扩展性以及管理插件，我倾向于使用rabbitMQ现有解决方案)。有没有人对我如何实现这个问题的解决方案有任何建议或见解？我还考虑过为每个用户创建一个队列&作业类型，但我不确定如何动态地这样做？也许我需要实现某种控制队列，它设置队列并
浏览 0提问于2013-11-07得票数 0
回答已采纳
我有一个关于RabbitMq消费者确认的查询，我阅读了RabbitMq上的文档，声明确认消息应该在消费者接收到的同一个通道上。但是，由于某种原因，在收到消息之后，由于某种原因消费者进程被停止，并且没有确认Rabbitmq，当消费者进程重新启动时，消费者开始从RabbitMq获得未被确认的消息，但是在这里，使用者不能向这些消息发送应答因此，我的问题是如何处理这个场景，以及如何在我的使用者进程读取完消息
浏览 3提问于2018-11-22得票数 0
1回答
现在我正在研究如何提高兔子的效率。例如：
2-5台EC2服务器.每个服务器都安装了一个logstash，并将其配置为向兔子发送消息。(以防万一I/O不是问题)2台EC2服务器。内存，cpu，好的磁盘，很好的带宽。不同的消费者数量可能在2-15岁之间。使用者连接到负载均衡器(ELB)。我的问题是：
如果我在兔子集群中的每个节点上创建</
浏览 2提问于2013-09-13得票数 1
1回答
我试图使用StreamBridge SpringBoot和RabbitMQ作为代理来创建动态的n个队列--我以前用这种方法创建了队列spring.cloud.stream.bindings.sender-inspring.cloud.stream.bindings.publisher-out-0.destination=sampleQueue并具有生产者
浏览 5提问于2022-11-10得票数 0
1回答
我使用以下配置为mule中的rabbitMQ创建了一个连接器，但问题是只创建了一个消费者，我想知道是否可以将mule配置为一次创建多个消费者。<amqp:connector name="amqpfiledetailConnector"
浏览 2提问于2015-12-02得票数 0
我这样启动RabbitMQ服务器：docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672:5672 rabbitmq:3使用此代码我们可以确保，即使您在处理消息时使用CTRL+C杀死一个工作人员，也不会有任何损失。我产生了两个消费者，当我对其中一个消费者执行CTRL+C操作时，另一个正在运行的消费者不会收到最初发往前一个消费者的消息。<e
浏览 173提问于2017-10-10得票数 0
我正在尝试在Java Spring框架中创建一个RabbitMq消费者。我需要实现RabbitMq RPC模型，所以基本上消费者应该从RabbitMq broker接收一些消息，对其进行处理，然后将其发送回相关的应答队列。
浏览 1提问于2015-10-21得票数 0
应用程序概述:可以创建多个动态队列。每个队列应该只有一个消费者。只有当消费者完成对一条消息的处理时，消费者才应该拿起另一条消息。static final Logger logger = LoggerFactory.getLogger(RabbitMqSenderConfig.class);
@Value("${spring.rabbitmq.addresses，我都会将详细信息发送到以target分支命名的队列中的rabbitMQ，这样所有的拉取请求
浏览 333提问于2019-12-27得票数 0
回答已采纳
RabbitMQ中的消费者利用率(显示在RabbitMQ管理控制台中)是什么？它是消费者通过消费消息而使用RabbitMQ的百分比吗？还是我误解了它？如果是这样的话，如何让消费者100%充分利用RabbitMQ呢？因为，当我增加消费者时，我看不到任何百分比的增加，但在启动新消费者的那一刻，只有几秒的时间。此外，工具提示文档说预取计数会以某种方式影响消费者的利用率，那么有没有公式来修正这个数字呢？
浏览 2提问于2015-09-14得票数 2
我一直在关注RabbitMQ教程，以便向NodeJS添加发布者和消费者。但互联网上的文档和一般教程缺乏提供正确的生产设置，以使用Nodejs集群设置的RabbitMQ客户端。从RabbitMQ channel.consume()启动一个消费者。此使用者是否在Nodejs运行的同一线程中启动？如果我运行4个NodeJS子进程，这意味着它将创建4个消费者，对吗？通过从环境变量获取worker计数来启动仅运行RabbitMQ worker的Nodejs应用
浏览 2提问于2020-02-03得票数 1
我有内存有限的RabbitMQ。如果发布者和消费者在线，这是可以的，但当需要重启消费者时，RabbitMQ会填满内存并阻止发布者。当出版商被阻止时，它将快速吞噬RAM。如何配置RabbitMQ使队列溢出到磁盘，内存是否已满？
浏览 0提问于2012-06-19得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
