-
-1 votesanswersviews
在RabbitMQ中队列Ghost消费者
在测试环境中，即使应用程序停止，也有兔子消费者连接到 RELAY-* 队列 . 这导致消息被这些“幽灵”消费者消耗给队列，并且实际应用程序不接收任何数据，除非应用程序的消费者首先接收它 . 例如，rabbitTST队列 RELAY-TASK-PUBLISH-QUESTION-STORE RELAY（grails app）应该是唯一的消费者，它现在在服务器上关闭，但目前有14个消费者 . 不是兔子... -
1 votesanswersviews
RabbitMQ，如何在重新排队尝试后删除消息
我试图通过使用RabbitMQ和JAVA来构建一种异步服务器 . 我有两个交换Original_Exch和Dead_Exch，每个交换一个队列 . 两个交易所都被宣布为DLX（彼此队列的死信交换） . 现在出现问题，我正在以json字符串的形式向Original_Exch发布消息，该字符串包含电子邮件信息（例如To，Subject，Message body，attachment等） . 从队列绑定... -
2 votesanswersviews
使用Spring ampq在rabbitmq中重新排列消息
我是rabbitmq的新手，我正在尝试以下方案 生产环境 者发送消息 消费者收到消息 执行我自己的逻辑 如果逻辑失败 - 重新排队 如果消费者失败（机器发生故障），请重新排队消息 我使用Spring rabbitTemplate实现了基本发件人 rabbitTemplate.convertAndSend(.....); 而对于消费者我实现了一个消息监听器 pu... -
2 votesanswersviews
主题与RabbitMQ交换含糊不清
我有点困惑 . 我正在尝试实现主题交换，但我不确定需要什么 . 我想要几个路由键和1个主题交换（默认的amq.topic） . 我的钥匙就像： customer.appA.created customer.appB.created customer . * . created 我希望我的队列是持久的，但是我需要1个'customer'队列或2个队列用于appA和appB吗？我让我的... -
0 votesanswersviews
用于多交换队列模型的RabbitMQ消费者设计
我有一个RabbitMQ设置，配置如下 . 每个Exchange都是 FANOUT 类型 多个队列附加到每个Exchange . BlockingConnection 由消费者制作 . Single Consumer来处理所有回调 . 问题 - 某些有效负载比其他有效负载需要更长的时间来处理，这导致消费者即使在其他队列中存在有效负载时也保持空闲 . 题 - 我应该如何实施消... -
0 votesanswersviews
RabbitMQ在扇出交换时重试逻辑
RabbitMQ周围的当前系统 我们有一组队列和交换来支持消息 . Main exchange ：这是从消息 生产环境 者收到消息以便第一次处理的地方 . 这可能是一个主题或扇出（当前问题是关于扇出） Main Queue(s) ：这是消费者从中选择要处理的消息的队列 . Dead exchange and queue ：错误消息的简单基本设置 . Delay queue ：如果需... -
0 votesanswersviews
消费者和 生产环境 者之间使用哪种消息
我正在使用RabbitMQ作为消息代理 . 我有一个消费者和一个制片人 . 到目前为止，我已经创建了一个具有很少原始属性问题是，只要我需要消费者中有效负载的更多信息，我需要更改有效负载，以便我可以在消费者中处理：最后这个任务可能很重 . 我想知道我是否可以使用某种 Map 作为有效载荷或不推荐？像这样，我有一个通用的有效载荷 . 另一方面，我们的应用程序中有Serializable DTO . 我... -
2 votesanswersviews
Grails rabbitmq本地过滤消息给消费者
我正在使用 grails 3.2.3 版本和 rabbitmq native plugin 3.3.2 （http://budjb.github.io/grails-rabbitmq-native/doc/manual/） . 我试图实现以下方案 . Description: 我_166296_在兔子的启动器上 . 所以任何帮助/方向都非常感谢 . 以下是我的代码 . Queue config ... -
0 votesanswersviews
RabbitMQ队列负载 balancer ，用于具有多块消息的多个消费者
我想在多个使用者之间分配来自RabbitMQ队列的消息（每个消息仅由一个消费者处理），并且能够在运行时添加/删除使用者 . 这就是RabbitMQ开箱即用的 - 如果你将多个消费者连接到同一个队列，消息会自动分发，到目前为止还是不错的 . 现在，我需要通过RabbitMQ（20-50Mb）处理大量消息 . 根据我的经验和我在互联网上发现的内容，RabbitMQ不能很好地处理大型消息，因此建议将它们... -
0 votesanswersviews
NserviceBus 6使用RabbitMQTransport无法正常工作
我们使用的是NSB v6.4.3，NServiceBus.RabbitMQ v4.4.1，RabbitMQ.Client v5.0.1 . 我的队列是自动创建的，但是当我向队列发送消息时，我收到了此错误 . "title": "Channel has been closed: AMQP close-reason, initiated by Peer, code=404... -
0 votesanswersviews
Rabbit mq检测消费者代码中没有 生产环境 者
我有一个与 生产环境 者和许多消费者的rabbitmq设置 . 告诉消费者 生产环境 者由于崩溃或其他失败而无法发送的最佳做法是什么？ 如果制作人失败，我想通知并向所有消费者展示合适的信息 . -
1 votesanswersviews
为什么我不应该使用rabbitmq主题交换？
看起来工作模式，扇出和过滤的主题都可以通过主题交换来实现 . 为什么我会使用直接或扇出交换呢？ 我们想要编写一个库中的常见模式，这些模式在库中提取了amqp的无限灵活性（命名约定，默认为持久，发送公共头，过期等） . 我们应该利用不同的交换类型或实现所有主题模式;为什么？ （我们通过spring boot，golang和php在Java中有消费者/发布者）