我目前正在开发一个使用RabbitMQ消息代理的应用程序。我对消息传递的工作原理感到困惑，我已经查看了他们的官方文档，但无法澄清我的担忧。假设我的应用程序可以从两个队列获取消息，对于队列A，生产者直接将消息推送到此队列，而队列B通过交换获取消息。我的问题是，如果同时有来自队列A和队列B的消息到达消费者，消费者将如何消费这些消息？
浏览 1提问于2020-06-02得票数 1
RabbitMQ适合交换化身吗？还是我需要设计自己的系统？
我是RabbitMQ的新手，但我在编写应用程序，服务器，.
浏览 4提问于2014-04-03得票数 1
1回答
它将此消息发送到默认的"AMQP默认“交换。我没有另一端的使用者来使用这些消息，因为我只是在确保服务器仍在运行。这些消息会随着时间的推移而累积并导致内存泄漏吗？
谢谢!K
浏览 4提问于2013-11-05得票数 0
回答已采纳
我想知道RabbitMQ是如何在内存和磁盘中物理存储消息的？我想知道这些的内部结构。不幸的是，其主页上的官方文档并没有公开内部细节。
浏览 1提问于2016-07-19得票数 34
回答已采纳
只要在本地机器上进行一些测试，就可以在某个地方检查由RabbitMQ (deliveryMode = 2)发布和保存的消息。或者至少有一段时间消息实际上是持久化的。第一次尝试是RabbitMQ管理，我发现所有选项和最接近的内容如下：
Database directory: /usr/local/var/lib/rabbitmq/mnesia/rabbit@localhost
浏览 6提问于2017-11-30得票数 0
回答已采纳
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
根据下列员额：
要备份，我们必须：
2- (Tar)文件夹"/var/lib/还注意到：/var/lib/rabbitmq/mnesia/rabbit@rabbitmq-node1/msg_store_transient的内容似乎存储了排队的消息，总是在rabbitmq服务器重新启动后
浏览 3提问于2014-11-24得票数 5
回答已采纳
我正在编写一个Java应用程序，它使用从输入RabbitMQ队列读取消息，处理消息，然后将新消息写入输出RabbitMQ交换。当在编译时知道输入队列名时，这是非常有效的。现在，我有了一个新的要求，即应用程序需要支持在运行时发现新的RabbitMQ队列，然后使用这些新队列进行输入(从新队列读取消息)。通过RabbitMQ中的REST获取队列列表很简
浏览 3提问于2021-02-04得票数 0
回答已采纳
1回答
我想知道，在RabbitMQ中何时创建单个队列以及何时创建多个队列是否有规则？还是由生产者来决定是否将消息发送到单个队列或多个队列，技术上没有区别？它应该依赖于db的模式吗?也就是说，一个表应该对应于单个队列吗？
浏览 2提问于2016-02-01得票数 1
回答已采纳
2回答
我听说在rabbitmq的延迟更多，因为所有的流量首先被转移到一个中心节点。如果有人能告诉我一些文档，这些文档可以突出说明在什么场景中应该使用什么，那就太好了。谢谢大家
浏览 3提问于2017-10-21得票数 6
1回答
我想要向两个队列发送一条消息。另外两个应用程序将处理此队列。一切都很好，但是当处理程序抛出异常时，我发现了问题。它将发送一个和两个重试队列的消息加倍，因为重试队列通过绑定关键字进行匹配，这对于此队列是相同的。 最后，通过3次重试，我的dlqs上有16条消息。你能帮我解决这个问题吗？是否可以创建基于队列的重试策略，而不是基于路由键？:rabbitmq@rabbitmq:5672
浏览 22提问于2020-04-19得票数 7
回答已采纳
1回答
我正在用rabbitmq开发Laravel 5.1.46 (LTS)，用于使用的消息队列QUEUE_DRIVER=rabbitmq'rabbitmq' => [
'host' => env('RABBITMQ_HOST
浏览 3提问于2019-08-16得票数 0
我是RabbitMQ的新手。我想知道在HA的情况下内存是如何使用的。例如，在Kafka中，如果数据存在或不存在，分区将使用特定数量的内存，复制.In RabbitMQ也是如此，队列是如何分配内存的？镜像队列是否占用每个复制节点相同大小的内存？
浏览 0提问于2017-06-11得票数 1
我们目前在Azure使用一种服务总线，由于各种原因，我们正在切换到RabbitMQ。在负载很重的情况下，当后端的特定任务出现问题时，我们的一个队列可以有多达100万条消息等待处理。RabbitMQ每个队列最多可以有5万条消息。问题是，当消息暂时累积时，我们如何设计rabbitMQ基础结构以继续工作？注意:我们希望将我们的RabbitMQ服务器托管在kubernetes集群中的一个坞映像中。我们设想一个交换，它会在后面的节点中加载<em
浏览 6提问于2022-04-21得票数 1
回答已采纳
假设我有m条消息在队列中，我有n条消息需要发布。如何以随机顺序插入队列中的n条消息，而不是附加到队列末尾？换句话说，我如何使用rabbitMQ进行混洗？
浏览 0提问于2016-04-19得票数 3
rabbitmq服务器或集群重启后，所有队列都恢复了所有消息，即使消息已经确认(从rabbitmq服务器启动时开始)，并重新处理所有消息。队列详细信息根据我的理解，在消息参数中将persistenet设置为false，如果代理重新启动，消息将不会继续存在。此外，我还将队列的durabele设置为false。
浏览 1提问于2018-07-10得票数 0
rabbitmq.server.host.name=localhost&rabbitmq.server.port=5672&rabbitmq.server.user.name=guest&rabbitmq.server.password=guest&rabbitmq.queue.name=queue1&rabbitmq.exchange.name=exchange1/>
</p
浏览 2提问于2015-06-30得票数 0
我想要实现一个优先级工作队列，其中一组消息的优先级一旦在队列中就会改变。由于它是一个具有可变处理时间的工作队列，所以不使用循环算法分配消息，而是在资源空闲时(使用每个用户限制)从队列中提取消息。我想出了两个实施方案：
使用来自RabbitMQ的优先级队列，当出现优先级更改请求时，从队列中读取具有此优先级的消息，并以不同的优先级重新发送消息。对每一组消息使用多个
浏览 1提问于2019-05-26得票数 2
在我的例子中，RabbitMQ使用的总内存为6.2GB，Erlang作者使用了其中的6.1GB。但是，我在硬盘上的任何地方都找不到这个大小的分页。如果RabbitMQ崩溃会发生什么？sockets_used,19}]},
当RabbitMQ失败或崩溃时，队列中的消息会丢失，或者什么？Erlang R16B03 (erts-5.10.4)
浏览 0提问于2016-02-10得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
