1回答
注意并处理代理中的错误
、、、、
$Default”，并在RabbitMQ中自动创建相应的绑定。问题是，这种方法不会在启动时触发交换和队列的创建。我发现，使用这种配置，只要发送第一条消息，至少可以让RabbitMQ创建交换和队列：spring.cloud.stream.default.producer.requiredGroups我还尝试将生成器实现为，但在这
浏览 10提问于2022-01-19得票数 1
自从spring弃用org.springframework.cloud.stream.annotation.Output注解以来。我使用的是streamBridge新的api。我想知道在启动时自动创建队列的最佳方式是什么，就像注释的行为一样。我发现了一种使用spring.cloud.stream.function.definition=myChannel创建队列的解决方法 如下面的示例所示 @Bean
fun myCh
浏览 304提问于2021-02-04得票数 1
回答已采纳
1回答
我使用Spring将消息发布到RabbitMQ交换。使用本机RabbitMQ PerfTest，我可以使用单个生产者轻松地获得100 k msgs/s (1通道)。我的yml是这样的： rabbitmq: port: 5672
function: @Autowired
publ
浏览 9提问于2022-03-09得票数 0
回答已采纳
1回答
使用(3.2.1)和RabbitMQ将一个队列和exchange与该队列绑定时，我遇到了一个问题spring: functionstatic final String OUT_BINDING_NAME = "direct-xd-delivery-out-0"; @Autowired
浏览 7提问于2021-12-06得票数 0
1回答
我试图使用StreamBridge SpringBoot和RabbitMQ作为代理来创建动态的n个队列--我以前用这种方法创建了队列spring.cloud.stream.bindings.sender-in-0.destination=sampleQueuespring.
浏览 5提问于2022-11-10得票数 0
我在用RabbitMQ。我已经定义了一个具有优先级的队列，并且我可以使用RMQ向这个队列发送一些优先级值的消息，并且使用者也按排序顺序获得消息，但是当我尝试使用Stream从我的java代码发送消息时，我不知道如何用该消息指定优先级以下是我尝试过的：
I在创建队列时将x优先级: 10添加到队列中。GUI上，当我对队列执行get消息操作时，我得到了这个结果=>。最后，我试图弄清楚如何在使用StreamBridge发送消息时动态地设
浏览 11提问于2022-06-09得票数 0
回答已采纳
每当我的Spring应用程序启动时(如果队列还不存在的话)，我想创建rabbitmq队列。
在当前架构中，我们使用rabbitmq手动创建durabl队列。但是，我们希望我们的应用程序能够检测配置中的新队列，并在不存在队列时创建持久队列。
浏览 2提问于2017-01-26得票数 2
在我的spring boot rest控制器中，我使用StreamBridge向rabbitMQ服务器发送一条消息，如下所示
streamBridge.send("consumer-in-0", "hello
浏览 5提问于2020-11-04得票数 2
1回答
我试图在每次启动我的应用程序时完成，从RabbitMQ API中获取所有存在的队列和交换。=localhost
spring.rabbitmq.password=guestspring.rabbitmq.addresses=localhost:8080/api/
浏览 26提问于2022-11-29得票数 1
回答已采纳
实际上，在我的RabbitMQ配置中，我为每个队列声明了10个消费者。所以所有的使用者线程都是在我的Spring Boot应用程序完全启动之前创建的，所以它在应用程序启动时会花费一些时间。当我的项目结束时，我想延迟加载所有的Rabbitmq队列。我尝试在configuration类上使用@Lazy，但似乎不起作用。
有没有办法声明延迟加载队列？
浏览 2提问于2021-01-17得票数 2
我使用Spring应用程序和Spring-兔子(版本2.2.2)。由于我的应用程序的性质是非常动态的，所以队列和绑定是使用RabbitAdmin.declareXXX方法动态声明的，因此它们不被声明为Spring。根据我的理解(和测试)，RabbitAdmin用于在rabbitmq服务器重新启动时自动恢复拓扑的功能仅用于声明为Spring的交换/队列/绑定(我是正确的吗？)setAutomaticRecoveryE
浏览 4提问于2021-08-17得票数 0
我正在使用Spring 和RabbitMQ。使用RabbitMQ启动码头后：
sudo docker run -t -i --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management我在管理面板()中注意到的一件事是，在启动订阅服务器时创建的队列被配置为auto-delete: true。因此，当没有订阅服务器运行时，队列就不会创建</em
浏览 2提问于2018-02-15得票数 1
回答已采纳
我们正在使用新的spring云函数库创建一个rabbitMq消费者。 但是，我们发现在应用程序启动时，我们看不到在rabbitMq实例上创建的队列或交换。 这是我们的配置。spring: function: stream: rabbit@Bean
public Consumer<M
浏览 92提问于2021-04-19得票数 0
是否可以在手动删除队列后自动重新创建队列？我可以使用以下命令在启动时创建队列 @Bean
public Queue createRandomQueue(@Qualifier("exporterRabbitAdmin") RabbitAdmin中删除，我希望能够自动创建具有相同名称的队列。org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.at
浏览 667提问于2020-07-10得票数 1
回答已采纳
1回答
我正试图在我的spring云流项目中使用用于RabbitMQ的“新”流插件，使用“模型”。我把我的application.yaml设置成这样： rabbitmq: type: stream hostdestination: test destination: test
我有一个@PostConstruct方法，它使用这样的Str
浏览 17提问于2022-09-14得票数 0
回答已采纳
我正在设法以一种在应用程序启动时自动创建队列等的方式来声明队列。我知道这可以通过通过Java代码添加队列的创建来完成，但理想情况下，如果Spring将基于配置我的RabbitMQ环境，那就更好了。我尝试创建一个resources.xml文件，但到目前为止没有任何进展。所以我想知道这是否可能？
对于如何进行或如何处理，有什么提示吗？
浏览 5提问于2014-10-09得票数 1
回答已采纳
我正在为一些通过芹菜和Kombu配置的RabbitMQ队列和交换进行配置。Kombu提供的exchange对象可以接受两个在我理解中重叠的特定选项：如果我设置这些值，结果会是什么：
durable = True和delivery_mode
浏览 8提问于2021-11-16得票数 0
在我们的应用程序中，我们使用RabbitMQ和spring(1.4.3.RELEASE)。我们在那里有两条队伍。它们都配置了TTL(60000和100000)。org.springframework.amqp.rabbit.connection.CachingConnectionFactory -通道关闭:信道错误；协议方法：#方法(应答-代码=406，回复-文本=先决条件_FAILED不等效的arg‘x-消息-ttl’中的队列'queue1‘：接收'60000’但当前是'100000
浏览 8提问于2015-02-26得票数 4
回答已采纳
我有一个运行在服务器上的RabbitMQ消息代理，我正在尝试使用配置一个生产者和一个消费者。我的生产者每秒钟都在队列中创建消息，而我的使用者以相同的速度读取它们。但是，如果我停止了我的使用者，而生产者一直在推消息，当我再次重新启动我的使用者时，它将无法检索在它被关闭的那一段时间内创建的消息，只会收集从启动时产生的消息。当队列启动时，如何使我的使用者使用队列中的现有消息？这是我的消费者财产： st
浏览 0提问于2020-10-16得票数 0
回答已采纳
我希望有一个spring云流监听器处理有关在其中发送的所有消息的fulle事务。或者，在函数中使用StreamBridge手动发送的所有消息都会被执行，即使之后有异常。：或者我在test.other.request上只能收到两条消息。streamBridge;
this.streamBridge = streamB
浏览 2提问于2021-10-28得票数 1
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
