我刚刚开始使用Spring boot RabbitMQ。我想知道在spring boot rabbitmq (注解配置)的情况下，我们如何分别配置生产者代码和消费者代码。我的意思是，如果我想在spring boot中编写rabbitmq生产者代码，用python编写消费者代码，或者反之亦然-在spring boot中编写消费者代码，在python中编写生产者代码……我在但与此形成对比的是，在
浏览 2提问于2018-03-25得票数 0
我需要有关如何将RabbitMQ队列中的消息计数保存到对象的帮助。因此，这些数据可以被其他一些功能使用。我找到了一些答案，但不适用于Spring boot。请帮帮我！
浏览 3提问于2017-01-31得票数 0
我正在尝试获取我的rabbit队列上的消息数量，然后在我的测试中清除该队列。环顾四周，似乎建议我需要使用RabbitAdmin来获取计数，但不确定如何将其自动写入我的测试中？有什么想法吗？
浏览 26提问于2017-08-19得票数 2
回答已采纳
由于一些复杂的原因，我的spring启动应用程序需要在Rabbitmq服务器启动之前启动。使用spring boot initializer生成一个简单的带有AMQP的spring boot app，添加相应的配置并@RabbitListener监听某个队列。如果Rabbitmq服务器已经运行，则app与服务器连接成功；--没有
浏览 3提问于2019-06-12得票数 0
您好，我有一个从应用程序A创建的RabbitMQ队列。我想从该队列中获取消息，所以我在spring boot应用程序中使用以下依赖项创建了消息侦听器： <dependency> <artifactId>spring-boot-starter-amqp</
浏览 28提问于2020-04-01得票数 2
回答已采纳
3回答
我有一个远程RabbitMQ服务器，它有一些我想要侦听的队列。= "queueName") System.out.println(message);但是它试图创建一个新的队列如何侦听远程服务器上的现有队列？另外，是否有一种方法来检查这个队列是否存在？org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassi
浏览 1提问于2018-08-30得票数 2
回答已采纳
服务器端使用Spring Boot2.1.7编写，并使用外部代理RabbitMQ 3.7.1。在客户端，我使用的是StompJS。 当客户端订阅用户目的地时，例如。/user/queue/some-queue Spring会将其映射到/queue/some-queue-{sessionID}，然后RabbitMQ会创建具有相应名称的队列。在订阅时，我添加了标题{'auto-delete': true}，就像这里指定的<
浏览 18提问于2019-09-07得票数 0
回答已采纳
我有一个可以侦听单个RabbitMQ队列的工作应用程序。但是，当我添加另一个消耗消息的bean并试图将其绑定到另一个队列时，这两个队列都不是在RabbitMQ中创建的，手动创建时也不会从这些队列中使用任何消息。=localhostspring.rabbitmq.username=guest
spring.rabbitmq.pas
浏览 1提问于2021-03-09得票数 0
回答已采纳
我想使用一个非常简单的spring启动应用程序向rabbitmq队列demo-queue发送消息： package com.example.demo;
rabbitmq:
addresses: amqp://guest:guest@localhost:5672 当我启动应用程序时，它会记录它已连接到rabbitmq，并在控制台中打印出用但是，我没有看到rabbitmq中的队列</em
浏览 32提问于2020-11-24得票数 1
回答已采纳
1回答
针对大数据的微服务之间的通信
、、、、
我正在构建一个spring的基于云的微服务ML管道。我有一个数据摄取服务，它(当前)从SQL获取数据，这些数据需要由预测服务使用。一般的共识是写入应该使用基于异步消息的通信，使用kafka/rabbitmq。我是否应该使用API网关来调用启动管道的摄取？
浏览 0提问于2017-06-07得票数 1
因此，我有两个队列，outboundEmailQueue和storeEmailQueue：<rabbit:queue
浏览 5提问于2017-11-10得票数 0
回答已采纳
我们的应用程序使用RabbitMQ提供的几个队列中的数据。为了增加吞吐量，我们为每个队列启动几个线程，这些线程从这些队列中进行阻塞获取。对于一个新服务，我们希望使用Spring Boot，并且每个队列都有几个线程，这些线程从这些队列中获取数据。下面是用于处理从某个队列到达的数据的规范Spring Boot代码：@S
浏览 1提问于2019-02-21得票数 0
1回答
我在rabbitmq中创建了一个新用户，并显式地分配了权限。我尝试过只使用队列名，而不实际声明队列bean。我尝试将队列和RabbitAdmin注入到其他bean中，只是为了强制创建它们。列表队列也不会显示空列表，因此这并不是与我试图配置的队列中的队列配置不匹配的问题。(SpringApplication.java:370) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
at or
浏览 6提问于2017-04-25得票数 2
实际上，在我的RabbitMQ配置中，我为每个队列声明了10个消费者。所以所有的使用者线程都是在我的Spring Boot应用程序完全启动之前创建的，所以它在应用程序启动时会花费一些时间。当我的项目结束时，我想延迟加载所有的Rabbitmq队列。我尝试在configuration类上使用@Lazy，但似乎不起作用。
有没有办法声明延迟加载队列？
浏览 2提问于2021-01-17得票数 2
2回答
我无法连接到RabbitMQ.RabbitMQ不在本地机器上。return new MessageListenerAdapter(listener, "listen");我的application.properties看起来就像spring.rabbitmq.port=15671sp
浏览 1提问于2019-10-15得票数 1
1回答
Rabbit使用者
、、、
我在pivotal cloud foundry中部署了一个spring boot应用程序。我有4个应用程序实例在运行。应用程序使用RabbitMQ中队列中的消息并进行进一步处理。如果我在RabbitMQ中将队列的消费者数量设置为40，那么这40个消费者是否会平均分布在正在侦听的应用程序中？
浏览 2提问于2017-02-10得票数 2
我想在我现有的带有Spring boot()的RabbitMQ项目中使用Reactor RabbitMQ。所以我想知道如何实现它，以及当任何AMQP消息被发送到任何队列时，我如何接收AMQP消息，就像在没有反应器的情况下使用@RabbitListner注释一样。
浏览 7提问于2020-03-12得票数 0
回答已采纳
1回答
我在生产中使用rabbitmq，在集成测试中使用QPid。我需要编写集成测试，以验证无法路由的消息是否调用了返回通道。我设置了mandatory=true和解除绑定的队列和交换，但是调用的是nack通道(抛出NackedAmqpMessageException)而不是返回通道。从不调用返回通道。我使用Spring AMQP和Spring Boot + Spring Integration。如何在测试中产生返回通道用例？我使用以下版本： Qpid 7.1.4
Amqp client 5.4
浏览 11提问于2020-04-10得票数 0
1回答
我有一个基于Java的微服务，它使用Spring (从下面的RabbitMQ中提取)与pom.xml集成： <groupId>org.springframework.boot</groupId></dependency>
现在，我想将这个服务连接到使用Sleuth
浏览 3提问于2018-01-11得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
