在Spring Cloud Stream中将多个RabbitMQ交换绑定到单个队列抛出错误
在Spring Cloud Stream中，将多个RabbitMQ交换绑定到单个队列抛出错误的原因是不允许将多个交换机绑定到同一个队列。这是因为RabbitMQ的交换机和队列之间的绑定是一对一的关系，一个交换机只能绑定一个队列，而一个队列也只能被一个交换机绑定。
如果需要实现将多个交换机的消息发送到同一个队列的功能，可以通过创建一个新的交换机，然后将多个交换机都绑定到这个新交换机上，再将这个新交换机与目标队列进行绑定。
具体的解决方案可以参考以下步骤：
- 创建一个新的交换机，例如命名为"multi-exchange"。
- 将需要绑定的多个交换机分别与新的交换机"multi-exchange"进行绑定。可以通过在配置文件中配置多个binding来实现，例如：
spring:
cloud:
stream:
bindings:
input1:
destination: queue
binder: rabbit
group: group1
consumer:
bindingRoutingKey: key1
bindingExchange: multi-exchange
input2:
destination: queue
binder: rabbit
group: group2
consumer:
bindingRoutingKey: key2
bindingExchange: multi-exchange- 最后，将新的交换机"multi-exchange"与目标队列进行绑定。可以通过在配置文件中配置output来实现，例如：
spring:
cloud:
stream:
bindings:
output:
destination: queue
binder: rabbit
producer:
bindingRoutingKey: key
bindingExchange: multi-exchange这样就可以实现将多个交换机的消息发送到同一个队列的功能。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ。CMQ 是腾讯云提供的高可靠、高可用的分布式消息队列服务，适用于分布式系统之间的异步通信、流量消峰、解耦、削峰填谷等场景。
更多关于腾讯云消息队列 CMQ 的介绍和文档可以参考：腾讯云消息队列 CMQ。
相关·内容
我想使用一个非常简单的spring启动应用程序向rabbitmq队列demo-queue发送消息： package com.example.demo;
import java.time.LocalDateTime但是，我没有看到rabbitmq中的队列被创建并填充了生成的消息。 pom.xml为： <?xml version="1.0" encoding="UTF-8"?<artifactId>spring-cloud<
浏览 32提问于2020-11-24得票数 1
回答已采纳
我正在寻找一种通过Spring cloud stream将一个RabbitMQ交换绑定到另一个交换的方法。我知道可以通过设置producer.requiredGroups属性将队列绑定到交换： spring.cloud.stream.bindings.foo.producer.requiredGroups=queueA queu
浏览 32提问于2019-04-11得票数 1
回答已采纳
我在一个Spring Cloud Stream应用程序中使用RabbitMQ作为输入。我正在尝试将多个交换绑定到单个队列输出，并通过列出以逗号分隔的交换来实现此目的(如documentation中所述)。allow-bean-definition-overriding: true # username, password, addr
浏览 845提问于2020-11-06得票数 1
回答已采纳
我正在尝试用不同的主题发送消息，然后在它想要听的主题上配置使用者。spring.cloud.stream.bindings.output.destination=domainMessages
spring.cloud.stream.bindings.output.producer.partition-key-extract
浏览 1提问于2016-09-13得票数 0
回答已采纳
我有一个应用程序，它使用RabbitMQ绑定器来使用消息(它不会产生任何消息)。application.yaml文件如下所示： cloud: rabbit: x:中创建两个队列：
q2，它绑定到将y与路由密钥y.z.#交换</e
浏览 0提问于2018-06-15得票数 0
回答已采纳
是否可以通过从某个隐式绑定到默认RabbitMQ交换的特定队列消费？正如我在BindingService.bindConsumer(...)中的调试中所看到的，如果我将bindingTargets字符串数组指定为空字符串(yaml中的‘)，则destination字符串数组是空的，因此不会发生绑定使用者(binder.bindConsumer(...))。
浏览 1提问于2018-05-15得票数 3
回答已采纳
不过，我注意到该源代码创建了RabbitMQ绑定：
队列testchannel.anonymous.RANDOM_ID (执行)。首先将消息发送到testchannel exchange，然后将消息路由<em
浏览 3提问于2016-02-05得票数 3
回答已采纳
我有一个rabbitmq exchange test-exchange，它是使用路由关键字test- routing -key绑定到队列test-queue的直接交换。我正尝试使用spring云流将消息发布到此交换，但消息未到达队列<dependency>
<groupId>org.springframework.cloud</groupI
浏览 13提问于2019-08-16得票数 1
使用主题交换配置多个队列，并使用路由键使用spring云流引导消息特定队列spring.cloud.stream.bindings.inputA.destination=Common-Exchange
spring.cloud.stream.bindings.inputA.group=A-Qu
浏览 0提问于2019-05-11得票数 0
回答已采纳
我很难掌握RabbitMQ和Spring Cloud Stream如何协同工作的知识。我似乎不能用Spring Cloud Stream来配置它。我可以将单个事件从一个生产者发送和接收到一个接收者，也可以从一个生产者发送和接收到多个订阅者(一个主题，多个队列，但没有通配符)。spring: host: localhost
u
浏览 1提问于2018-10-11得票数 2
1回答
是否可以将多个主题从exchange绑定到单个队列？例如，我有一个生产者，它声明一个交换，并发送三个主题：log.verbose，log.info，log.errorspring.cloud</e
浏览 0提问于2017-10-05得票数 2
回答已采纳
4回答
我使用RabbitMQ web-UI创建了一个主题交换TX，并将其绑定到交换的两个队列TX.Q1和TX.Q2，每个队列都绑定了路由密钥rk1和rk1 2，并相应地生成了很少的消息。我尝试使用配置：spring.cloud.stream.bindi
浏览 5提问于2016-12-13得票数 6
回答已采纳
我有一个可以侦听单个RabbitMQ队列的工作应用程序。但是，当我添加另一个消耗消息的bean并试图将其绑定到另一个队列时，这两个队列都不是在RabbitMQ中创建的，手动创建时也不会从这些队列中使用任何消息。=localhostspring.rabbitmq.username=guest
<
浏览 1提问于2021-03-09得票数 0
回答已采纳
在我的制作人application.properties中，我有spring.cloud.stream.bindings.input.group=group01
浏览 0提问于2016-08-18得票数 0
1回答
我正在尝试spring数据流，看看它是否适合我的需求。我想知道如何将我的spring cloud stream应用绑定到多个指定的目的地(在我的例子中是RabbitMQ交换)。据我所知，你可以将多个应用绑定到一个指定的目的地(扇入/扇出)，但不能将一个应用绑定到多个目的地……
有什么想法吗？
浏览 0提问于2018-05-21得票数 0
例如，如果有两个通道绑定到同一个目的地/交换，则可以：spring.cloud.stream.bindings.myChannel2.group=queue2
q
浏览 0提问于2018-04-12得票数 1
1回答
我要寻找的拓扑是到目前为止，我还没有看到在Cloud中定义每个消息的主题的方法。我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每个消息的主题？=guest
spring.cloud.stream.b
浏览 0提问于2018-05-05得票数 2
回答已采纳
1回答
注意并处理代理中的错误
、、、、
这些配置如下所示：spring.cloud.stream.bindings.consumeA-in-0.group=$Defaultspring.cloud</
浏览 10提问于2022-01-19得票数 1
1回答
使用Spring的现有队列
、、、、
我正在尝试使用AMQP编写一个Java应用程序来与RabbitMQ服务器对话。我必须使用现有的队列和交换，并且没有权利自己声明它们(我也不想)。问题是，我无法阻止Spring集成试图在RabbitMQ中声明队列，这将返回一个错误。spring.cloud.stream.rabbit.bindings.input.consumer.bind-queue=false spring.<e
浏览 0提问于2018-10-16得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
