《rabbitmq》专题

AMQP/RabbitMQ新手。试图掌握概念/原则，并偶然发现了这一点。 以下两种范式之间有什么区别？ Fanout Exchange：FanoutExchange- 相对 直接交换:直接交换- 两者不是都达到相同的效果吗？如果没有，请有人可以阐明它有什么不同，以及在哪些情况下比其他情况更可取？ 为什么它们有这两种类型的交换，而这两种交换都可以通过调整绑定中的路由键来实现？ 谢谢

我的RabbitMQ上有一个主题交换。发送消息时出错。 接收部分: 发送部分： 第行出错:< code > channel . EXCHANGE declare(EXCHANGE _ NAME，" topic ")；异常:无法使用不同的类型、持久性、内部或自动删除值、class-id=40、method-id=10在vhost“/”中重新声明exchange“EX _ TEST” 如何解决这个问题

RabbitMQ集群运算符在kubernetes中不起作用。 我有一个由3个节点组成的kubernetes集群1.17.17。我和一个牧场主一起部署的。根据此说明，我安装了RabbitMQ cluster-operator:https://www.RabbitMQ.com/kubernetes/operator/quickstart-operator.html 好！但是..我根据文档为实例创建了这

我试图使用RabbitMQ cluster Kubernetes操作符创建一个RabbitMQ实例，但是PersistentVolumeClaims存在一个问题。我正在使用Docker Desktop for Windows运行Kubernetes 1.18.8。 为什么不自动创建卷，我应该做什么？

我有一个三节点的rabbitmq集群。这是我正在使用的集群（不是我的）https://github.com/bijukunjummen/docker-rabbitmq-cluster。 我遇到了一个问题，如果我用ha-policy=all向队列发送大量消息，并不优雅地关闭服务器，则其他节点上的消息并不都可用。 这在Java RMQ库中可能吗？ 谢了。

我已经编写了一个定制的ejb组件，它附带了schedular。在scheduled ejb方法中，我调用RabbitMQ方法来对消息进行出列。在调试单个java文件时，整个过程都可以在eclipse中使用。但在Wildfly服务器上构建和部署时，抛出“由以下原因引起：java.lang.NoClassDefFoundError:com/rabbitmq/client/ConnectionFacto

这种方法很不一致。我肯定这不是实现这一点的正确方法。

我已经从spring的initialzr生成了一个Spring Boot配置服务器。 我已经用brew安装了rabbitmq。initialzr是使用启动版本2.1.1.RELEASE和云版本Greenwich.M3生成的。 简单的rest服务连接到rabbitmq队列。配置服务器连接到gitlab配置报告。 但是，当我提交并推送更改时，服务应用程序不会反映该更改。推送完成后，配置服务器将收到日志

我在我的消费者体内抛出一个AMQP异常。我的期望是，消息将以FIFO顺序返回队列，并在将来的某个时候重新处理。 Spring AMQP似乎没有将消息释放回队列。而是一次又一次地尝试重新处理失败的消息。这会阻止处理新到达的消息。卡在AMQP控制台内的设备将永远处于“未打包”状态。 有什么想法吗？

ActiveMQ/JMS有一个内置机制，用于确保在使用竞争消费者模式时，共享公共报头（即JMSXGroupID报头）的消息始终由队列的同一消费者使用。队列的使用者完全不知道实际的头值，因为具有公共头的消息的保证是在服务器端而不是在使用者端执行的。有关此工作方式的更多详细信息，请参见http://activemq.apache.org/message-groups.html。 用AMQP或者用Rab

我刚刚阅读了RabbitMQ的Java API文档，发现它非常丰富而且简单。关于如何为发布/消费设置一个简单的的示例非常容易遵循和理解。但这是一个非常简单/基本的示例，它给我留下了一个重要的问题：如何设置1+来向多个队列发布/消费？ 假设我有一个RabbitMQ服务器，上面有3个队列:、和。因此，我们需要一个来发布/使用所有3个队列，或者更有可能有3个单独的，每个通道专用于一个队列。 在此基础上，

RabbitMQ集群中有三个节点，如下所示。 在RabbitMQ中，有两个队列，和。 和的主副本分布在不同的节点上。这两个队列都由其他节点镜像。 三个节点前面有一个负载均衡器。 负载均衡器公开AMQP（节点端口5672）和管理HTTP API（节点端口15672）。 当应用程序通过负载均衡器建立连接时，可以到达后面随机的RabbitMQ节点。而这对于应用程序来说是不可见的。 问题：

我将RabbitMQ包用于Symfony2 web框架。我的问题是，在TERMINAL中运行多个workers后，如何避免创建多个连接（以防止使代理过载）？在下面的示例中，我运行了两个workers，结果有两个connections/channel。 config.yml services.yml

文件描述符：256个可用套接字描述符：138个可用 显然我不能打开超过138个连接。 问题1：这个限制是基于什么？我能提高它吗？我想知道在生产机器上（需要哪种EC2实例），每个用户有一个连接是否是一个好主意。我读到过限制可能与ulimit有关，但当我在命令行上运行ulimit时，我看到的是'unlimited'。 还有什么其他的策略？

好吧，我不需要详细介绍我设置的整个系统， 我遇到的问题是，当使用者取消(amqpchannel->basic_cancel)对队列的监听时，会留下一个额外的消息未被这个工作者确认。它也不会触发正常的回调来处理此消息。 队列正在阻塞（使用wait) 预取为1，这是您所能拥有的最小值 使用者可以动态侦听() 使用者可以动态忘记() 我不会告诉给定使用者使用或取消给定队列的确切方式。但这一切都是完美的工