我一直在遵循上的RabbitMQ指南，我正在使用RabbitMQ版本2.8.7，并尝试在同一主机上启动2个节点。我以相同的方式启动两个节点，使用以下命令 RABBITMQ_NODE_PORT=5674 RABBITMQ_PID_FILE='/var/log/rabbitmq/rabbit-disc' RABBITMQ_NODENAME=rabbit-disc rabbitmq-server -detached RABBITMQ_NODE_PORT=5673 RABBITMQ_PID_FILE=

因此，我们将有一个主题交换，看起来像 {class}.{genus} 因此，我们有一些消费者与这一主题紧密相关 mammal.* （或鸟。*等） 现在假设稍后我们要包括物种信息，因此主题交换现在如下所示： {class}.{genus}.{species} 现在，旧的消费者已经破产了：( 然而，他们本可以像以前那样约束自己 mammal.*.# 并且能够倾听未来添加的任何信息。然而，这是我的团队自己想到的，这让我问： 这是好的做法吗 我是否应该注意这方面的权衡 是否有另一种方法让制作人

使用RabbitMQ的java客户机，我创建了一个连接池机制，该机制具有一组已建立且可用的RabbitMQ连接。一旦客户机租用了一个连接，客户机就会创建一个通道。如果我必须发送执行任务并发送100条消息，则对于这些消息中的每一条，客户端将租用一个连接并使用API创建一个通道，例如： rqConnection = MyPoolManager.leaseConnection(); rqChannel = rqConnection.createChannel(); 我可以在我的池中预先建立一个通道作

我正在开发一个原型，我的数据通过Flume流到HDFS。我还需要把数据输入Storm。Flume是一个推送系统，Storm更具拉力，所以我不认为尝试将喷口连接到Flume是明智的，但我认为应该在两者之间设置一个消息队列。同样，这是一个原型，所以我在寻找最佳实践，而不是完美。我正在考虑将一个符合AMQP的队列作为水槽水槽，然后从喷口中提取消息 这是一个好方法吗？如果是这样，我想使用一个消息队列，它在Flume世界（作为水槽）和Storm世界（作为喷口）中都具有相对强大的支持。如果我使用AMQP，那

我试图实现一种“独占消费者”或“独占队列”，以避免最终用户必须锁定任何东西：代理将选择一个消息消费者来获取队列的所有消息，以确保排序，如果该消费者失败，代理将自动故障切换并选择另一个消费者 我想知道芹菜和RabbitMQ的组合是否能成功。尽管RabbitMQ有“独占”队列的概念，但我认为您无法获得所需的回退行为 经纪人不会“选择”单个消费者。故障模式可以通过不使用自动确认、拒绝出错和让工作人员死亡/重新启动来解决 如果只有一个使用者，这将保留消息顺序。随着负载平衡，您的里程数可能会有所不同。尽管

我可以通过计算/api/connections中的元素来获得当前连接的数量，如果我想从rabbitmq服务器启动获得所有连接的数量，我该怎么办？请给我一些建议即使使用管理api，您也无法从rabbitmq获得任何回顾性统计数据（至少是现成的） 作为一种解决方法，您可以在的帮助下收集此类数据，然后在应用程序级别处理事件。awesome！这对我真的很有帮助，有node.js模块吗？是的，当然，只要谷歌一下就可以了（我不是nodejs的人，但是关于nodejs+amqp有很多问题，它利用了一些libs

我正在使用Spring AMQP在Java中使用RabbitMQ。我正在使用主题交换发送消息 我想使用带有指定routingKey的自动声明队列来使用消息，而实现这一点的唯一方法是使用线程，在线程中我将等待传递（使用consumer.nextDelivery（））。有没有其他方法可以异步执行此操作 Spring AMQP还有一个MessageListener接口，我只能使用它来侦听命名队列。有没有一种方法可以使用MessageListener使用自动声明队列中的消息 谢谢大家! 有没有一种方法可

servicestack 这是实现从ServiceStack webservice发布消息的正确方法吗？

标签：servicestack Rabbitmq

给出下面的代码，这是将requestDTO（LeadInformation）通过ServiceStack中的消息传递抽象发布到RabbitMq的正确/最快的方法吗？这个impl可以工作，但是考虑到ServiceStack的内置功能，我可能遗漏了一些东西 public override void Configure(Container container) { // https://github.com/ServiceStack/ServiceStack/wiki/The-IoC-cont

在Spring文档中，rabbitmplate、queue、exchange和binding都是通过Spring引导设置的。我不明白的是，rabbitmplate.convertAndSend（…）如何将它发送到创建的exchange，因为方法调用没有指定exchange，它只包括路由键（通过队列名称）和消息本身——我认为它隐式地将消息发送到默认的exchange，而不是创建的exchange。消息将到达预期队列，因为路由密钥与队列名称匹配 如果要指定交换和路由密钥，请使用以下API方法： //

我正在尝试用bunny和事件机运行AMQP。每当我尝试使用worker时，bunny都会抱怨以下问题：无法建立到任何已配置主机的TCP连接 当我运行netstat时，我在任何地方都看不到端口5672。此外，nmap-p 5672 0.0.0.0的输出给出以下结果： Nmap scan report for 0.0.0.0 Host is up (0.000092s latency). PORT STATE SERVICE 5672/tcp closed amqp 我的配置文件（$HO

假设队列的使用者已断开连接一段时间，在此期间会产生大量消息 RabbitMQ在没有持久模式的情况下为断开连接的使用者保留消息多长时间？ （它会在消费者断开连接后立即丢弃队列吗？还是会保留队列直到内存允许？） 持久模式是否为消费者提供了一种功能，使其能够使用迄今为止发布的任何消息？（即随机访问队列、无序获取消息或从队列开始消费） 有一些 通过设置x-message-TTL参数，可以为给定队列设置TTL 来queue.declare，或通过设置消息ttl策略 不，没有。消息将一直保持在队列中，直到它

是否有一种方法可以在配置文件（如ActiveMQ）中定义队列： 是的，这是可能的 最简单的方法： 从webUI手动添加队列 默认情况下，webUI在端口15672上公开。 添加队列访问 从webUI导出配置文件。 访问主页。在底部有导入/导出定义部分和下载代理定义按钮 只需下载该文件，它将包含所有已定义的队列 示例配置文件，包含用户、虚拟主机和队列： 我已经使用Notepad++中的JStool插件和JSFormat选项格式化了文件。 默认情况下，该文件是单行的，可读性不强 “下载代理定义”旁边

我们有一个应用程序可以发布到单一exchange（使用amqp）。此外，我们还有许多应用程序对使用来自此exchange的邮件感兴趣。为此，它们创建队列和从队列到exchange的绑定 我们希望确保每个应用程序的队列和绑定只能由该应用程序和该应用程序连接的用户管理。我设想使用虚拟主机，以便exchange位于每个应用程序的用户都有权读取的/common虚拟主机中，并且每个应用程序的队列和绑定都位于用户有权完全访问的自己的/虚拟主机中 但是，文档表明，用户不能在一个通道内同时访问多个虚拟主机，并且

我在谷歌上搜索我的问题的答案，但我没有找到一个明确的答案。是否可以在rabbitmq中批发送消息？这在前面已经讨论过，rabbitmq现在不支持批发布。你必须自己把它们打包成一封信 请参阅：这之前已经讨论过，RabbitMQ现在不支持批量发布。你必须自己把它们打包成一封信 请参阅：AFAIK，根据官方文档（与您的问题主题最密切相关，有Java示例），有一个称为“批处理发布者确认”的东西 我的意思是，您基本上不能一次发布多条消息（我还深入研究了Java的API，甚至在最新版本中，如5.12.0，完

我有一个控制台应用程序，它正在向RabbitMQ交换发布消息。使用MassTransit构建的订户是否可以使用此邮件 这是发布者代码： public virtual void Send(LogEntryMessage message) { using (var connection = _factory.CreateConnection()) using (var channel = connection.CreateModel())

如何仅将rabbitmq web mqtt插件绑定到环回接口 我正在尝试使用配置文件/etc/rabbitmq/rabbitmq.conf listeners.tcp.1 = 127.0.0.1:5672 management.listener.ip = 127.0.0.1 management.listener.port = 15672 mqtt.listeners.tcp.1 = 127.0.0.1:1883 web_mqtt.tcp.ip=127.0.0.1 web_mqtt.tcp.p

我有一个使用RabbitMQ客户端接收消息的.net微服务，我需要测试以下内容： 1-使用者已成功连接到rabbitMq主机 2-消费者正在收听队列 3-消费者正在成功接收消息 为了实现上述目标，我创建了一个发送消息的示例应用程序，我正在调试consumer以确保它正在接收消息 如何使此测试自动化？因此，请将其包含在我的微服务CI中 我想在我的CI中包括我的示例应用程序，这样我就可以触发一条消息，然后运行一个消费者单元测试，等待一段特定的时间，然后在收到消息时通过，但这对我来说似乎是一个错误的做

我在传输层将massttransit与RabbitMQ一起使用，并面临消息重复数据消除的需求 如果重复消息已排队（即使消费者正在处理该消息），则应跳过向队列添加新消息。例如，可以通过消息的内容来识别重复项 发送DoWork1、DoWork2、DoWork3可以并行处理，但发送DoWork1、DoWork2、DoWork2应跳过重复，并且只要DoWork1、DoWork2处理过，相同的消息可以排队，不应被视为重复 解决方案1：在交换层使用“”，这对我来说很理想，但不确定是否解决了所描述的问题 解决

我需要一些帮助。我正在尝试将Apache beam与RabbitMqIO源代码（版本2.11.0）和AfterWatermark.pastEndOfWindow触发器一起使用。看起来RabbitMqIO的水印没有前进，并且保持不变。由于此行为，AfterWatermark触发器无法工作。当我使用不考虑水印的其他触发器时（例如：AfterProcessingTime，AfterPane），下面是我的代码，谢谢： public class Main { private static final L

有没有办法配置使用RabbitMQ交换/队列传递的消息的“精确一次”处理？基本上，我们有一个消费应用程序，它由集群中的两个节点组成，这两个节点都将订阅Rabbit上的同一队列，但是在给定时间，这两个节点中只有一个应该处理消息。我的第一个想法是，考虑到rabbit使用“循环”消息传递，这将是开箱即用的，但是我们不能保证将来不会有其他消费者。为每个消费应用程序创建特定队列并使用默认循环分配功能是最佳做法吗？队列的其他消费者将与现有消费者一样成为循环消息消费的一部分。发送到报价单的每条消息将只发送给一

RabbitMQ是否创建队列/交换（如果已存在） 我是否应该在创建队列和交换之前检查它们是否已经存在 RabbitMQ服务器本身并不创建交换或队列。您必须使用web管理GUI，或通过客户端打开的连接创建交换和队列。最后一个选项是动态创建客户端所需的交换、队列和绑定的好方法 请务必注意，一旦创建了exchange或队列，就不能使用不同的属性再次创建。例如，如果您的客户端创建了扇出交换，则它无法再次创建与直接交换相同的交换。使用与首次创建时使用的相同类型和属性再次创建它是安全的。这只是不起作用，不会

在使用Spring RabbitMQ时，我从AMQP内部获得ClassCastException。我们在生产中的应用程序日志中发现了这一点，但我们无法重现这一点，但这对我们来说是一个真正的痛苦。 基本上，一旦发生这种情况，整个堆栈似乎都会失败，因为我们看到在该通道上发送的DeliveryTag无效，这导致RabbitMQ关闭该通道 我们使用的是AMQPClient 5.4.3和SpringRabbit 2.1.2，RabbitMQ缓存模式为连接（由于HAProxy和故障切换），ACK模式为手动，

我遇到了一个问题，我也找不到任何解决方案 我有两个RMQ服务器，我们称它们为RMQ1和RMQ2。消息首先发布到RMQ1上的main_exchange，并将其路由到RMQ1上的main_queue。RMQ1上没有设置消费者。 RMQ2中的队列是RMQ1的联合队列，消费者在RMQ2队列上工作。 我在两台服务器上都有retry\u queue和retry\u exchange，并且main\u queue的DLX设置为retry\u exchange 问题是，当我拒绝或拒绝RMQ2（联合队列）上的消息

我需要能够通过RabbitMQ发送pdf或word之类的文件（我认为答案可能更一般，不是特定于RabbitMQ，而是我正在使用RabbitMQ的任何代理） 有没有办法将它们作为MIME发送，或者我需要转换成base64然后再发送 或者我在这里有点不对劲：（请帮忙。RabbitMQ不查看消息正文，您可以发送任何东西，任何二进制数据。接受您的回答。简单明了：（必须使用其他库进行二进制压缩-谢谢。嗨@Shahzeb。你是如何进行二进制压缩/提取的？@Ryan2Johnson 9，那是7年前：）对不起，

我正在读《兔子的行动》一书，仍然在第二章，但有一件事作者说得让我困惑。您设置了一个exchange并发送了一条消息，两个订阅者正在侦听队列。当第一条消息传入时，第一个订阅者将获得它，消息被确认后将被删除。当下一条消息到达时，它以循环的方式传递给下一个侦听器。我想，如果我发送消息，我希望所有订户都能收到。我的理解错了吗？这很简单。如果希望所有订阅者都获得消息的副本，请使用通配符绑定创建多个队列 假设您有一个主题交换，并且您使用诸如fred.interest或fred.boring这样的路由键发布所

我想为Rabbitmq服务器实现高可用性。我已经阅读了Rabbitmq提供的文档，文档上是使用DRBD，我不想使用DRBD进行共享存储，从我的角度来看，我已经使用两个节点进行了集群并准备镜像队列。 rest需要实现高可用性帮助我 谢谢可以在RabbitMQ站点上找到HA文档，网址为 主设置如中所述 这不涉及DRBD，只是关于如何跨多个服务器镜像队列的指南 我已经根据上面的说明实现了一个HA兔子集群，因此我可以证明它们的清晰性。 如果您有任何关于HA设置的具体问题尚不清楚，我很乐意回答。HA文

使用java客户机QueueingConsumer，我编写了以下代码来帮助客户恢复 while (true) { try{ .. create connection .. create channel & queue while (true) { final QueueingConsumer.Delivery delivery = consumer.nextDelivery(); ....

我在这些交流中发现了两个链接。 但无法理解作者想说的话。有人知道这两个交换和一个问题 是否存在这样的交换：如果未找到具有路由密钥的客户端，则不会丢弃消息，而是将其存储在队列中，并且当找到相关路由密钥时，消息就可以提取了？联邦交换用于将消息从一个RabbitMQ服务器复制到另一个服务器（可能是远程机器） 存在备用exchange，以便在无法路由邮件时将邮件路由到该exchange，因为没有与邮件路由密钥匹配的绑定。当然，您必须创建所述交换，然后将其添加为发布消息的交换的备用 使用备用exchang

有没有办法确保当您NACK消息并将其发送到死信交换/队列时，该消息将是持久的？默认情况下，即使原始消息通过SetPersistent（true）设置为persistent，死信消息也不会跟随套件。RabbitMQ不会修改死信消息的属性，过期消息除外： 如果消息是在deliver_mode=2的情况下发布的，则应将其作为持久性发布到死信队列中是否有理由不将整个死信队列设置为持久性？这是一个选项吗？到目前为止，我只发现可以在消息级别设置持久性。因为rabbit处理死信发布，所以我找不到方法让它在Ba

我有一个由3个rabbitmq节点组成的集群，分布在3个不同的服务器上。第二和第三个节点连接第一个节点并形成集群。在测试故障转移的过程中，我发现一旦主节点被杀死，我就无法让它重新加入集群。文档中没有说明启动后必须使用join_cluster或任何其他命令。我尝试加入\u群集，但被拒绝，因为名为的群集与节点主机相同。有没有办法让这一切顺利进行 cluster_status显示以下内容（不是从主节点）： 节点“兔子”的群集状态。。。 [{nodes，[{disc，['rabbit@'，'rabbit

本地安装的rabbitMQ服务器必须为外部用户提供5672端口。但是失败了！我只能连接到localhost:5672！我的rabbitmq.config文件为空！ 那么，我如何让外部用户连接到5672端口？ 另外，我创建了具有完全权限的新用户User1，如果您使用的是Mac，那么您可能需要检查/usr/local/etc/rabbitmq/rabbitmq-env.conf以查看文件是否具有带有“localhost”的节点IP地址。删除它将允许其他人连接到您的RMQ实例。如果您使用的是Mac，那

不确定这是否是预期的，但这里是我在Ubuntu 16.04上发现的。我通过应用程序和实例计数命名了所有内容。在logstash示例中，您有1.logstash.test.com 2.logstash.test.com 3.logstash.test.com。但是rabbitmq服务器不会以该名称开头，主机名不能有子域名 Setting up rabbitmq-server (3.5.7-1) ... Job for rabbitmq-server.service failed because t

考虑到我有一个包含X条消息的大队列。无论何时制作requeue=True的nack，它都会将消息放在X条消息的顶部，并将其重新交付给同一消费者，从而造成瓶颈，而不让消费者处理其他消息 有没有办法将消息放在队列的尾部，将其视为新消息，这样如果我有X条消息，我可以在重新查询消息之前先处理它们？在这个问题中，我不想在出现错误时确认消息，然后再将其丢失，我想跟踪未处理的消息 我意识到我可以创建另一个队列来保存未处理的消息，并让其他消息流动 这对你有什么好处？我的意思是，假设你把它放在最后，它最终会到达消

RabbitMQ文档指出，消息可能会重复，消费者必须处理这一点。为了测试适当的代码，我想让RabbitMQ生成这些重复的消息，并相应地设置redelivered标志。如何执行此操作？使用默认配置，如果您从侦听器引发异常，它将被重新传递-如果队列中有多个使用者，则无法保证同一实例将获得重新传递

我已成功在openshift上安装rabbitmq群集 但是，我没有找到使用openshift路由公开amqp（5672）或amqps（5671）端口的方法 我在openshift文档中看到了不受支持的内容。 路由器支持以下协议： 超文本传输协议 HTTPS（带SNI） 网袋 带SNI的TLS WebSocket流量使用与其他流量相同的路由约定并支持相同的TLS终止类型。 这样做的最佳方式是什么 请找到我的设置 oc版本 oc v1.4.1 kubernetes v1.4.0+776c994

我的队列是持久的，消息是持久的。我已经设置了3个RabbitMQ服务器集群，在所有服务器之间对所有队列进行HA镜像。关闭Rabbitmq3时，我的主节点似乎是Rabbitmq3。我得到以下错误 Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND

在我的系统中，我使用springcloudstream和RabbitMQ来发送和接收事件。我让RabbitMQ运行，服务A启动，服务B关闭服务A向服务B发送事件。然后我打开了我的服务B，现在我希望Rabbit能够取消活动，但什么也没发生。这是正确的行为吗？我不熟悉RabbitMQ，但我认为它应该保证所有事件最终都会找到它的接收者。我的应用程序很简单，基于，没有额外的配置。我错过了什么？如果您的消费者没有组，则该队列是一个匿名的自动删除队列。你需要一个团队来坚持。看 生产者不会将队列绑定到exch

我正在通过Rabbitmq官方网站提供的AMQP。 上面说 队列持久性持久性队列被持久化到磁盘，因此能够生存 代理重新启动。不持久的队列称为暂时队列。不 所有场景和用例都要求队列是持久的 队列的持久性不会使消息路由到该队列 队列经久耐用。如果经纪人被带走，然后又被带回来， 但是，在代理启动期间，将仅重新声明持久队列 将恢复持久消息 但是，当MessageBroker崩溃时，我对以下场景感到困惑：- 消息由生产者传递到消息交换，但不路由到标记为持久的队列 消息由生产者传递到消息交换，生产者依次路由

我计划升级3节点rabbitmq集群。但是我需要在不停机的情况下执行升级，而且我不想错过队列中的任何消息。你能给我一些如何实现这一目标的建议吗 要升级的版本：3.6.3-->3.7.5 问候, Rahul N.RabbitMQ团队监视并有时只回答有关StackOverflow的问题 一个简单的谷歌搜索将显示以下链接，展示如何在不停机的情况下升级： 如小组中所讨论的，我们需要单独联合VHOST中的队列 我们需要联合虚拟主机，然后将消费者的流量转移到新的绿色集群。一旦消费者开始使用绿色集群的信息

我正在使用RabbitMQ。消费者api使用的是SpringCloudSteam。 目前，由于maxAttempts为3，如果使用者未能处理消息，则它将再次排队。这种情况会发生三次。 如果第三次消息也失败，那么它将被发送到DLX->DLQ 如下图所示 现在，如果侦听器端发生特定异常，我想跳过重试。如何跳过此重试并将消息直接发送到DLX->DLQ以获取特定异常 下面是配置文件 spring: application: name: consumer-api cloud: s

我正在使用RPC模式处理带有RabbitMQ的对象。 您可能怀疑，我有一个对象，我想让该进程完成，然后向RPC客户端发送ack。 默认情况下，Ack的超时时间约为3分钟。 我的过程需要很长时间。 如何更改每个对象的ack超时，或者如何处理这些类似的进程？RabbitMQ不提供任何类型的确认消息超时机制。官方Python教程中对此进行了讨论： There aren't any message timeouts; RabbitMQ will redeliver the message only wh

我在上下文消息传递文件中声明了队列和交换，如下所示： <bean id="rabbitExchangeABCD" class="org.springframework.amqp.core.DirectExchange"> <constructor-arg value="${EX_ABCD_ORDER}" /> </bean> <bean id="rabbitDestinationABCD" class="org.springframew

标题说明了一切。我看到我可以捕获通道关闭事件，但是如果我从中远程删除正在使用的队列，我就不会得到任何错误。我正在使用aio pika 6.6.0和Python 3.7.7

当我需要为我的消息创建路由时，我会遇到这样的情况，但我希望使用带有否定的匹配模式，如！myPattern 例如： 我在主题交换中绑定了一个队列，路由键是#.巴西。#。因此，这意味着该队列将仅在消息的路由键包含“.brazil.”时接收消息，如message.brazil.dank 现在，我想创建另一个队列并绑定到同一主题交换，但我想接收所有不包含模式。#，类似的消息！（#巴西#） 我正在使用头交换进行一些测试，但是x-match参数只能有两个可能的值：any和all，我需要类似的东西，除了基本上

我想使用vert.x为rabbit mq实现断路器。如果rabbit mq关闭，则根据配置，电路开路 我为vert.x断路器做了单独的POC，还能够连接Rabbit MQ客户端。使用vert.x 现在，我想构建断路器，若电路断开，那个么客户端将不在队列中推送消息，并保留在数据库中，一旦电路闭合，它将开始在mq中推送db消息。请帮忙 我已经使用以下链接创建工作poc 用于断路器的代码段 CircuitBreakerOptions options = new CircuitBrea

我使用下面的代码在同一通道上等待确认（ack/nack/返回/超时） 我发送的routingKey不正确，因此rabbitMq应根据以下api文档引发异常。但是我没有从api中得到异常 我们正在使用waitForConfirmsOrDie的超时（60秒） 如果我对api的期望不正确，请有人提出建议。这不直观，但返回的消息不会生成nack；返回消息后会收到肯定的ack。NACK仅由代理错误或队列大小限制设置为拒绝发布的溢出行为导致 对于无法导出的消息，一旦exchange验证消息不会路由到

假设我有200个事件，它们将被放置在多个队列中（或不放在多个队列中），我正在考虑使用200个唯一键将每个队列绑定到一个主题交换。通过在一个队列和一个exchange之间添加200个唯一绑定，我是否会看到性能瓶颈 如果是，我有其他选择吗 提前感谢总的来说，路由是最消耗资源的部分的可能性较小（如7月4日的雪）。有关路由的更多信息，请参阅和 对于特定情况，这取决于RabbitMQ服务器可用的资源、消息流、绑定、绑定密钥复杂性等。无论如何，最好先运行一些负载测试来找出瓶颈，但同样，路由不太可能是导致性能

我在服务器A上使用芹菜和Rabbitmq代理。有些任务需要与另一台服务器交互，例如服务器B，我使用Rabbitmq队列进行此交互 队列1-服务器A（生产者），服务器B（消费者） 队列2-服务器B（生产者），服务器A（消费者） 我的芹菜出人意料地挂了起来，我发现原因是服务器A消费代码的实现不正确 channel.start\u consuming（）保持按预期轮询Rabbitmq，但将其放入芹菜任务会创建多个不会过期的轮询器。我可以添加到期时间，但无法保证将数据发送到服务器B的时间完成。下面粘贴的

我有一个用例，我必须使用更新的属性对消息重新排队，消息正在重新排队，但消息属性没有更新 public class TestListener implements MessageListener{ @Override public void onMessage(Message arg0) { MessageProperties properties = arg0.getMessageProperties(); int count = properties.getMessage

我不知道为什么RabbitMQ服务落在Windows Server 2008 R2上。它以前可以工作，但现在无法再稳定服务。我甚至无法访问位于的代理 有什么魔术吗？此日志消息似乎对我毫无意义：=INFO REPORT====25-Jul-2018:：10:28:51===错误描述：“在~s处找到锁文件。\n上一次升级正在进行或已失败。\n数据库备份路径：~s”日志文件（可能包含更多信息）：C:/Users/{user}/AppData/Roaming/RabbitMQ/log/RabbitMQ~