《rabbitmq》专题
-
RabbitMq ACK/重新发布
此处的文档：http://www.rabbitmq.com/semantics.html 声明当信道关闭时，它被重新分配以进行传递 消息可以使用以requeue参数(Basic.recover、Basic.reject和Basic.NACK）为特征的AMQP方法返回到队列，也可以由于在保留未确认消息时通道关闭而返回到队列。对于2.7.0之前的RabbitMQ版本，这些场景中的任何一个都会导致消息在
-
如何将消息发布到具有高tps的rabbitmq,多线程
由于channel不是线程安全的，所以我可以在发布之前同步channel实例，或者每次需要时创建一个channel并关闭它。 但在我看来，由于锁定或创建和破坏通道的代价，这两种方法都没有很好的性能。
-
RabbitMQ中的一个通道-一个队列？
到目前为止，对于RabbitMQ中的一个队列，我使用了一个通道，但现在我动态创建了多个队列，所以我必须为每个队列创建一个新通道，还是一个通道可以从不同的队列接收/发送消息？
-
如何使消费者与rabbitmq同步
在RabbitMQ级别上是否有任何机制允许我使用下一个消息直到上一个消息被加密为止？还是必须在服务器之间开发某种锁定机制？
-
使用证书身份验证进行任何连接尝试时RabbitMQ SSL握手失败
我目前正在尝试迁移一些Java组件，以通过SSL客户端证书而不是PLAIN方法执行RabbitMQ连接身份验证，但是，几天后，我仍然在努力，因为所有java组件连接尝试都会遇到握手错误。在尝试使用SSL证书时查看RabbitMQ：握手错误，或者在使用SpringAMQP时查看RabbitMQ SSL给握手失败，不幸的是没有为我使用任何结果。 我试图使其工作的环境是一个运行UbuntuLTS14.0
-
当使用RabbitMQ时，如何分别配置消费者和生产者的spring boot应用程序？
我看了一个教程，它解释了如何将RabbitMQ集成到Spring Boot应用程序中。在本教程中，（使用者）和（生产者）类位于同一个项目中。我想在两个不同的Spring Boot应用程序中实现它们。但是，由于类的原因，我无法将教程项目拆分为两个使用者项目和生产者项目。因为它耦合了（使用者）和（生产者）类。 如何实现和配置两个不同的cosnumer和producer Spring Boot应用程序？
-
将Spring云Spring服务连接器与RabbitMQ一起使用，并启动发布服务器配置函数
我连接RabbitMQ与斯普林云配置： 2.设置RabbitTemplate.set强制性（true）和setConfirmCallback（）： 3.将消息发送到队列以调用发布者确认并打印日志。 但出版商确认没有工作。日志尚未打印。无论真假，日志都不应该缺席。
-
配置服务器与RabbitMQ连接问题
我让RabbitMQ在CloudFoundry中运行，并尝试从本地运行的配置服务器进行连接，下面是在应用程序中配置的内容。yml文件 抛出以下启动异常 下面是pom.xml的依赖关系 我可以使用应用程序中提供的信息连接到控制台。yml但不确定为什么会抛出TimeoutException，任何输入都会非常有用，
-
在Python中是否可以将RabbitMQ直接回复功能与Pika生成器使用者一起使用？
我想在Python中的Pika客户端库中使用RabbitMQ的直接回复功能。它适用于基本消费者。但它引发了发电机使用者的以下例外情况： 鼠兔。例外情况。ChannelClosedByBroker:（406，“前提条件_失败-快速回复使用者不存在”） 有没有一种方法可以将直接回复功能用于生成器使用者？ 使用基本消费者的示例客户端代码（它的工作原理）： 使用生成器消费者的示例客户端代码（它引发了异常）
-
交换类型问题RabbitMQ...消费者期望“粉丝出局”，但生产者实际是“话题”
我有一个docker环境，其中消息服务（Rabbitmq）和我的服务（myapp）在docker中配置。myapp在给定的消息通道和消费者代码中产生类型为"fanout"的消息，我尝试设置Rabbitmq的复杂性，以便类型为"fanout"的消息可以被消费。 当使用者设置rabbitmq thingy时，如上所示：我得到以下前提条件错误：由以下原因引起： 通用域名格式。兔子。客户关机信号异常：通道
-
是否将节点RED连接到RabbitMQ优先级队列？
我有一个用以下选项声明的RabbitMQ队列： 我试图从Node-RED连接到队列，使用插件，在连接源下设置了以下拓扑： 我得到以下错误： “AMQP输入节点断开连接错误：操作失败：QueueDeclare；406（Premission-failed），消息为“Premission_failed-vhost中队列'myqueue'的参数'x-max-priority'不相等”：未收到任何，但cur
-
是否从RabbitMQ中删除所有队列？
我安装了Rabbitmqadmin，并能够列出所有的交换和队列。如何使用Rabbitmqadmin或Rabbitmqctl删除所有队列。
-
Spring boot rabbitmq在vhost'/'中没有交换''xxxxxxx''
我写一个简单的Rabbitmq生产者与Spring启动2.2.7。 在代理端，我设置了一个直接交换示例，一个名为samples的队列。默认值，并将它们绑定在一起添加示例。默认绑定键。 运行应用程序时，我得到以下错误 rabbitmq服务器配置是正确的，因为我有一个python生产者已经成功地将消息放入“samples.default”队列。 在SpringBoot中，我使用了jackson序列化，
-
Rabbitmq: exchange->routingkey->队列命名结构
我使用直接交换，因为我希望一份工作分配给一个消费者。 有不同的消费者群体，他们将消费不同的工作。假设我的应用程序名为“foo”。然后我就有工作了 酒吧1 酒吧2 酒吧3.... 将有一组独立的消费者来处理“bar1”作业，然后是另一组消费者来处理“bar2”作业，依此类推 我试图找出任何特定的命名/路由结构是否有好处，但没有找到任何指向这种或那种方式的东西。 问题1）我应该使用多个交易所名称交易所
-
RabbitMQ：当消费者关闭时发布消息，以后的消费者不能在没有命名队列的情况下使用消息
我有一个生产者和一个消费者。消费者的多个实例正在运行。当生产者发布消息时，我的意图是通过所有实例消费该消息。所以，我使用的是直接交换。生产者将带有主题的消息发布到直接交换。消费者正在通过独占队列收听该主题。当消费者启动并且生产者发布消息时，此过程运行良好。但是当消费者关闭并且生产者发布消息时，消费者在启动时不会消费此消息。 我在谷歌上搜索了这个问题。建议使用命名队列。但是，如果使用命名队列，则消息