我的任务是创建一个简单的Spring RabbitMQ聊天应用程序。其中一个要求是同一时间只能有一个具有给定昵称的用户在线。用户通过其队列名称来区分。现在，我遇到了一个捕获队列声明错误的问题。在configuration类中，我声明一个队列bean，如下所示public Queue privateQueue(String nickname) {
String queueName= "prv." + nickna
浏览 20提问于2021-05-28得票数 0
我使用Spring应用程序和Spring-兔子(版本2.2.2)。由于我的应用程序的性质是非常动态的，所以队列和绑定是使用RabbitAdmin.declareXXX方法动态声明的，因此它们不被声明为Spring。根据我的理解(和测试)，RabbitAdmin用于在rabbitmq服务器重新启动时自动恢复拓扑的功能仅用于声明为Spring的交换/队列/绑定(我是
浏览 4提问于2021-08-17得票数 0
实际上，在我的RabbitMQ配置中，我为每个队列声明了10个消费者。所以所有的使用者线程都是在我的Spring Boot应用程序完全启动之前创建的，所以它在应用程序启动时会花费一些时间。当我的项目结束时，我想延迟加载所有的Rabbitmq队列。我尝试在configuration类上使用@Lazy，但似乎不起作用。
有没有办法声明延迟加载队列？
浏览 2提问于2021-01-17得票数 2
我们的java spring引导应用程序在成功连接到某个exchange /主题之后，正在创建/声明队列(如果它们不存在)。如果队列不存在，(来自rabbitmq管理面板)是否可以禁止某些用户(在本例中是这个春季引导应用程序使用的用户)创建/声明队列？
谢谢!
浏览 0提问于2018-10-04得票数 1
回答已采纳
由于一些复杂的原因，我的spring启动应用程序需要在Rabbitmq服务器启动之前启动。使用spring boot initializer生成一个简单的带有AMQP的spring boot app，添加相应的配置并@RabbitListener监听某个队列。如果Rabbitmq服务器已经运行，则app与服务器连接成功；
如果应用程序先启动，然后启动Rabbitmq服务器，日志会按重复多次的顺序显示以下异常，然后应用程序</e
浏览 3提问于2019-06-12得票数 0
{"ha-mode":"exactly","ha-params":2}@Configuration ... 1 common frames omittedx-queue-locator-master:client-local
因此，如果声明给定<
浏览 13提问于2022-09-27得票数 0
我有一个Rabbitmq集群设置(没有HA)。我的使用者是spring应用程序，它提供了一个故障转移机制，它可以在其中连接到下一个可用节点。由于队列不是镜像的，所以我可以在前面声明队列，当第一个节点关闭时，连接将被建立到第二个节点。这有道理吗？
另一个问题，让我们说我在Rabbitmq集群上有一个负载平衡。我的应用程序使用负载平衡进行连接。是在所有节点上声明队列，还是根据LB的路由策略在节点上声明<
浏览 4提问于2017-06-16得票数 0
回答已采纳
1回答
使用Spring的现有队列
、、、、
我正在尝试使用AMQP编写一个Java应用程序来与RabbitMQ服务器对话。我必须使用现有的队列和交换，并且没有权利自己声明它们(我也不想)。问题是，我无法阻止Spring集成试图在RabbitMQ中声明队列，这将返回一个错误。spring.cloud.stream.rabbit.bindings.input.consumer.bind-queue=false spring.cloud.stream.rabbit.
浏览 0提问于2018-10-16得票数 1
回答已采纳
我正试图在春季使用RabbitMQ创建一个出版商和消费者应用程序。每件东西都正常工作，当发布者发送消息时，使用者接收到它并成功地使用它。但是，正如您在下面的图片中所看到的，RabbitMQ接口没有向我展示创建的队列和交换。不排队不交换这就是我写的代码：package com.example.rabbitmq.springrabbitmqconsumer
浏览 3提问于2022-01-15得票数 1
我们有一个更大的多服务java spring应用程序，它在启动时在RabbitMQ中声明了大约100个交换和队列。应用程序的服务有时通过RabbitMq相互通信，因此以一个示例发布者为例，它将消息发布到上面的ExampleListener绑定到的示例Exchange。我们“修正”了这个问题，在我们开始发送任何RabbitMq消息之前，只需等待3秒钟就可以让它有时间声明所有队列、交换和绑定，但这似乎是一个非常不理想的解
浏览 19提问于2022-09-15得票数 2
由于某些原因，即使我在Spring AMQP队列配置中指定了该设置，我的队列也没有创建为持久队列：Queue queue() {}
我正在使用Spring AMQP连接到RabbitMQ并在Direct Exchange上监听该队列。
浏览 0提问于2016-01-22得票数 0
在我们的应用程序中，我们使用RabbitMQ和spring(1.4.3.RELEASE)。我们在那里有两条队伍。它们都配置了TTL(60000和100000)。当我们启动应用程序时，它会出现以下错误：
池-4-线程-1错误org.springframework.amqp.rabbit.connection.CachingConnectionFactory -通道关闭:信道错误；协议方法：#方法(应答-代码=406，回复-文本=先决条件_FAILED不等效的arg‘x-消息-ttl’中的队列'q
浏览 8提问于2015-02-26得票数 4
回答已采纳
1回答
我试图在每次启动我的应用程序时完成，从RabbitMQ API中获取所有存在的队列和交换。：
spring.rabbitmq</e
浏览 26提问于2022-11-29得票数 1
回答已采纳
我正在将遗留的spring应用程序切换到spring启动。exchange name = mq-test.topicqueueName = aa.mq-test
因此，在rabbitmq管理视图中，我可以看到但
浏览 0提问于2019-05-30得票数 1
回答已采纳
1回答
如果我使用发布者确认，我可以(合理地)确定发送到RabbitMQ服务器上的exchange的消息以及从RabbitMQ服务器接收确认的消息不会丢失，即使RabbitMQ服务器崩溃(例如断电)。(channel.basicReject，我使用Spring AMQP。)如果原始消息从使用者正在侦听的队列中退出队列，并且RabbitMQ服务器随后崩溃，我是否仍然可以确定，在RabbitMQ服务器重新启动后，我最终会在绑定到死信交换的
浏览 6提问于2019-06-25得票数 1
每当我的Spring应用程序启动时(如果队列还不存在的话)，我想创建rabbitmq队列。
在当前架构中，我们使用rabbitmq手动创建durabl队列。但是，我们希望我们的应用程序能够检测配置中的新队列，并在不存在队列时创建持久队列。
浏览 2提问于2017-01-26得票数 2
我使用的是RabbitMQ和Spring的RabbitTemplate。以前，我们使用JmsTemplate和任何调用来发送或接收自动创建的队列。
浏览 8提问于2017-10-22得票数 14
回答已采纳
我正在使用RabbitMQ，并试图重构我当前的原生java实现，以使用Spring AMQP抽象。使用Spring库声明交换、队列和它们的绑定是通过AMQPAdmin接口实现的，但是我不确定这种配置应该在什么时候发生。但是，何时显示交换/队列的声明呢？
我是否将AMQPAdmin与web应用程序一起部署，并在
浏览 0提问于2010-10-06得票数 4
回答已采纳
我正在用Spring编写一个服务，我正在使用Spring AMQP来连接Rabbitmq。我有两个rabbitmq集群，一个仅用于发布消息(消息通过联合插件发送到另一个集群)，另一个集群用于声明最终用户将从中消费的队列。
节点位于aws lb之后，每个群集都有一个lb。对于将包含我添加到配置中的队列的集群，queue-master-locator=random，因此新队列将在集群中的所有节点中声明，即使我的服务没有与它们的连接。因此，
浏览 25提问于2018-12-20得票数 3
云服务器
ICP备案
云直播
对象存储
腾讯会议
腾讯云开发者
