代码之家 › 专栏 › 技术社区 › Roman Lebedev

Spring云流:如果当前连接引发异常,则重新发布到其他amqp连接[关闭]

spring-cloud-stream spring-amqp spring-integration rabbitmq java

Roman Lebedev · 技术社区 · 7 年前

我有两个完全相同的RabbitMQ服务器,我想将事件发布到其中一个服务器(只处理一次),在发布失败时故障切换到另一个服务器。

问题是:

实现这一点的最佳设计是什么?最好是通过更改高级云流配置,而不是跳入Spring AMQP。
如何连接到异步发布及其结果?最好不要使其同步。覆盖一些bean?
RabbitMQ HA有什么帮助吗?据我所知,整个持久队列只存在于单个节点上,以保持消息的顺序(实际上我不需要顺序)。因此,如果配置HA,并且具有持久HA队列的节点失败/停止,处理和发布将崩溃?

1 回复 | 直到 7 年前

Gary Russell 7 年前

请参阅引导文档: spring.rabbitmq.addresses= # Comma-separated list of addresses to which the client should connect. 连接工厂将自动故障切换。
如果设置生产者 errorChannelEnabled 您将在错误通道中收到返回的消息;这需要为返回配置连接工厂。除非您直接使用Spring AMQP发布消息,否则当前没有获取异步肯定ACK的机制。
使用HA,将为故障节点承载的队列选择一个新的主节点。当队列位于一个节点上时,它会复制到其他节点。

推荐文章

Red Riding Hood · 如何在docker compose中使用主机名连接到RabbitMQ流插件

1 年前

J. Maciel · 无法读取未定义的属性(读取“voto”)和其他属性

1 年前

moumout · AMQPCPP消费者和发布者不创建交换和队列

1 年前

trung · 如何用python测试消费者rabbitmq的基准测试

1 年前

nkalfov · .NET客户端无法通过TLS连接到端口5671上的AMQP Windows Server 2019标准版1809

1 年前

mthgh0818 · rabbitmq-mqt如何获取设备的联机状态

1 年前

jeril · Rabbit mq-等待Mnesia表时出错

5 年前

Danish · 确认RabbitMQ中消费者的剩余消息

7 年前

iam.Carrot · RabbitMQ队列Pika的多处理

7 年前

Raja Anbazhagan · RabbitMq监听器的ServletFilter等价物是什么?

7 年前