RabbitMq :有没有一种方法可以在集群环境中的所有虚拟主机上应用策略以进行队列镜像？
RabbitMQ是一种开源的消息队列中间件，它提供了可靠的消息传递机制，用于在分布式系统中进行异步通信。在RabbitMQ中，可以通过应用策略来实现队列镜像。
队列镜像是指将队列的消息副本存储在多个节点上，以提高消息的可靠性和可用性。在集群环境中，可以通过以下步骤在所有虚拟主机上应用策略以进行队列镜像：
- 创建策略：首先，需要创建一个策略来定义队列镜像的规则。可以使用RabbitMQ的管理界面或命令行工具来创建策略。策略可以指定镜像模式、镜像的节点数量、镜像的位置等。
- 应用策略：将创建的策略应用到虚拟主机上。可以通过RabbitMQ的管理界面或命令行工具来应用策略。应用策略后，策略将在虚拟主机上生效，所有符合策略规则的队列都将进行镜像。
- 验证镜像：可以通过RabbitMQ的管理界面或命令行工具来验证队列是否成功进行了镜像。可以查看队列的镜像状态、镜像节点的数量等信息。
队列镜像的优势是增加了消息的可靠性和可用性。当某个节点发生故障时，其他节点上的镜像队列可以继续提供服务，确保消息的不丢失和高可用性。
在腾讯云的云产品中，可以使用腾讯云的消息队列 CMQ（Cloud Message Queue）来实现类似的功能。CMQ提供了高可靠、高可用的消息队列服务，支持队列镜像、消息持久化、消息重试等特性，可以满足分布式系统中的消息通信需求。
更多关于腾讯云消息队列 CMQ的信息，可以访问以下链接：
请注意，以上答案仅供参考，具体的实现方法和产品选择应根据实际需求和情况进行评估和决策。
相关·内容
根据公共存储库：，我在Kubernetes中用3个Pods创建了Rabbitmq自动集群
队列中的消息无法存活，Pod在以下基本场景中重新启动：
创建持久队列“测试”
发送消息到队列“测试”
等待10分钟，删除一号吊舱。
等10分钟，删除2号吊舱。
等10分钟，删除3号吊舱。
列表队列。
在删除所有3个豆荚后，队列"test“始终不存在。每次删除pod后，集群正常工作，我可以发送和接收新消息。
看起来Rabbitmq并没有将现有的消息复制到新的荚中。我如何强迫Rabbitmq与新的荚共享所有消息？
非常感谢，
RabbitMq启动日志：
浏览 3提问于2017-10-23得票数 0
回答已采纳
在RabbitMQ集群中，我知道可以使用"queue_master_locator“策略的”masters“策略在不同的节点上使用它们的主服务器创建队列。这意味着队列不再被镜像(不能应用ha模式策略)，因为一次只能应用一个策略。有办法做到这两点吗？我基本上希望队列分布在集群节点上，因此减少了单个节点上的内存占用。
浏览 0提问于2018-11-19得票数 0
回答已采纳
我们最近通过滚动升级将我们的RabbitMQ集群升级到了最新版本(一个接一个地移除节点，对其进行升级，然后使用新版本将其添加回集群)。 粗略地说，我们是这样做的： # Put host into maintenance mode
rabbitmq-upgrade drain
# Install new rabbitmq version
# Re-join cluster
rabbitmqctl join_cluster rabbit@rabbit01 关于滚动升级，我们故意不在这里包含所有细节，因为这个过程不是问题。问题更确切地说是:我们希望确保队列领导者副本在之后再次均匀分布。所以我们
浏览 51提问于2021-09-20得票数 0
回答已采纳
我正在开发具有1个磁盘和2个ram节点的集群环境。谁能解释一下如何在RabbitMQ broker中使用Spring AMQP注解来配置策略来创建镜像队列。
提前谢谢。
浏览 4提问于2013-10-03得票数 1
我用集群和镜像队列建立了关于兔子的ha的实验室。我正在使用centos 7和rabbitmq-服务器3.3.5。有三台服务器(ha1、ha2、ha3)。
我刚刚加入了ha1和ha2到ha3，但是不要为镜像队列设置策略。当我在ha1服务器上测试名为" hello“的创建队列时，在我检查ha2和使用rabbitmqctl列表队列检查ha3之后，在集群上的所有节点上都存在hello队列。
我有一个问题，为什么我不设置策略来镜像集群上的队列，但是它已经在集群上的任何节点上创建了自动镜像队列？
请给我建议，我有错误或只加入到集群上的节点，队列将是镜像的所有节点的集群。谢谢
浏览 1提问于2016-03-31得票数 0
回答已采纳
5回答
我已经使用HA策略在单个windows机器上创建了RabbitMQ集群，并创建了两个磁盘、两个内存节点和一个统计节点。然后我运行了PerfTest (rabbitmq客户端测试实用程序)，结果令人失望，它大约是5000m/s。但是，当我在单个RabbitMQ节点上运行相同的测试时，它给出了很好的结果，即25000m/sec。我不知道发生了什么错误，如果在集群中运行，它的结果应该是令人印象深刻的，但事实恰恰相反。任何人都遇到过同样的情况，或者知道背后的原因。谢谢
浏览 12提问于2015-03-17得票数 2
2回答
您好，我创建了三个在EC2集群中运行的RabbitMQ服务器
我想要基于CPU利用率向外扩展RabbitMQ集群，但是当我发布消息时，只有一台服务器使用CPU，而其他RabbitMQ-server没有使用CPU。
那么，如何跨RabbitMQ群集分配负载呢
浏览 3提问于2012-05-05得票数 7
回答已采纳
我是RabbitMQ的新手，所以请原谅我提出一些琐碎的问题：
1)在RabbitMQ集群的情况下，如果一个节点出现故障，负载转移到另一个节点(不停止其他节点)。类似地，我们还可以向现有集群添加新节点，而无需停止集群中的现有节点。对吗？
2)假设我们从单个rabbitMQ节点开始，并在其上创建100个队列。现在制片人开始以更快的速度发送信息。为了处理此负载，我们添加了更多节点并创建了一个集群。但是队列只存在于第一个节点上。现在节点之间的负载均衡是如何实现的？如果我们需要添加更多的队列，我们应该在哪个节点上添加它们？或者我们可以使用负载均衡器来添加它们。
提前感谢
浏览 0提问于2015-01-29得票数 24
回答已采纳
2回答
我需要在Kubernetes中的所有队列上设置一个启用了队列镜像的RabbitMQ集群。正如插件名称所示，kubernetes peer discovery的RabbitMQ插件只提供了基于peer discovery的集群机制。但我如何启用队列镜像并实现HA，以便在pods因任何原因重启或需要扩展Rabbitmq节点时，我可以在不丢失任何消息的情况下执行此操作。
浏览 4提问于2018-08-05得票数 1
我有一个spring boot应用程序，它连接到一个RabbitMQ集群(作为cloud foundry中的一个服务)。当集群中的主节点发生故障，并且由于某种原因，该节点没有出现，但应用程序(消息使用者)正在尝试连接到出现故障的节点，而不尝试连接到其他可用节点时。有人能建议一些弹簧配置来解决这个问题吗？ 17:36:23.829: [APP/PROC/WEB.0] Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>
浏览 89提问于2020-10-01得票数 0
回答已采纳
1回答
Docker虚拟主机缓存
、、、
我用的是Docker和VirtualBox，dinghy和docker-compose。我正在通过docker-compose创建一个容器。下面是docker-compose.yml配置。
rabbitmq:
image: rabbitmq:3-management
ports:
- "15672:15672"
- "5672:5672"
environment:
VIRTUAL_HOST: 'rabbitmq.docker'
VIRTUAL_PORT: 15672
RABBITMQ_DEFAU
浏览 1提问于2015-12-29得票数 0
回答已采纳
我想知道:是否有任何方法只使用Java代码来设置RabbitMQ镜像(HA队列)。对于此类配置问题，AFAIK有一个特殊的类RabbitAdmin，但无法确切了解如何使用它设置镜像队列。是否可以在Java中配置HA队列？
提前鸣谢。
浏览 0提问于2018-08-22得票数 1
回答已采纳
是否可以从RabbitMq管理控制台更改特定队列的节点名称？我试过了，但我认为这是我启动应用程序时创建的。我可以过后再换吗？我的队列在节点RabbitMQ1上，而我的连接在节点RabbitMQ2上，所以我不能从该队列读取消息。也许我可以改变我的连接节点？
浏览 19提问于2018-01-09得票数 0
回答已采纳
2回答
是否有可能使用联邦或铲子来镜像一个服务器和另一个服务器上的交换和队列的创建？
我看到的使用铲子和联邦的所有示例都使用服务器上已经存在的交换和队列。我想做的是在服务器A上创建一个交换，并在服务器B上重新创建一个联邦或铲子，然后开始向它发送消息。
如果在不使用集群的情况下，联合或铲子无法实现这一点，那么这两个服务器之间的连接是不一致的，所以集群是不可能的。
我正在windows上运行RabbitMQ。
浏览 1提问于2014-04-08得票数 8
回答已采纳
我有一个由2个RabbitMQ节点组成的集群(每个节点都运行3.6.10版的RabbitMQ，启用了MQTT插件)，前面还有一个AWS经典负载均衡器。服务器和客户端交换MQTT消息。
客户端(运行在移动设备上并使用Eclipse客户端库的应用程序)连接到负载平衡器，它以循环方式分发连接。
当我取下一个节点(比如Node1 )时，所有连接到Node1的客户端都会得到一个回调，指示与代理的连接丢失。这些客户端尝试重新连接，但连接尝试失败，指示无法访问代理。在AWS控制台上，我可以看到AWS检测到Node1已关闭，并将其标记为"OutOfService“。来自新客户端的连接请求被路由到
浏览 1提问于2017-06-02得票数 0
我们有了一个网络分区，RabbitMQ最终变成了“分裂的大脑”。
集群恢复后，我有一个无法删除的队列。在管理中。接口队列只用"?“列出，我无法使用mgmt将其删除。界面或来自命令行。
我尝试从集群中删除节点"sh-mq-cl1a-04“，但队列仍然留在集群中。
浏览 0提问于2015-05-27得票数 10
2回答
我想要构建一个能够为了性能而扩展的RabbitMQ系统。
我已经浏览了RabbitMQ集群的正式文档。但是，它的集群似乎不支持可伸缩性。这是因为只有通过主队列，我们才能发布/使用，即使主队列可以从集群的任何节点访问。除了主队列所在的节点之外，我们不能处理任何发布/消费。
那我们为什么要聚在一起？
浏览 5提问于2016-04-21得票数 0
回答已采纳
1回答
在RabbitMQ文档中，表示：
在所有节点上复制RabbitMQ代理操作所需的所有数据/状态。这方面的一个例外是消息队列，默认情况下，消息队列驻留在一个节点上，尽管它们从所有节点都是可见的和可访问的。若要在群集中的节点之间复制队列，请使用支持复制的队列类型。本主题将在仲裁队列指南中讨论。
如果我们使用的是springboot amqp经典队列，并且需要开始使用一个RabbitMQ集群，其中数据被复制到节点之间以降低数据丢失的风险，那么需要对代码进行哪些更改才能开始使用仲裁队列？
浏览 10提问于2021-10-20得票数 2
我是RabbitMQ的新手。我想知道在HA的情况下内存是如何使用的。例如，在Kafka中，如果数据存在或不存在，分区将使用特定数量的内存，复制.In RabbitMQ也是如此，队列是如何分配内存的？HA是如何工作的?镜像队列是否占用每个复制节点相同大小的内存？
浏览 0提问于2017-06-11得票数 1
我们在一个集群中有几台运行RabbitMQ实现的僵硬的AWS主机。我们需要升级硬件，因此我们开发了一本厨师食谱来产生替换服务器。
有一件事我们不愿意手动重新创建，那就是管理员用户、队列等。
将这些东西从旧主机转移到新主机的最好方法是什么？我相信它是/var/lib/rabbitmq/mnesia目录中的所有内容。
将文件从一台主机复制到另一台主机是否明智？
有没有一种程序化的方法来做到这一点？
它可以被编码到我们的厨师食谱中吗？
浏览 1提问于2016-03-26得票数 0
我让rabbitMQ broker作为集群在两个节点上运行。我观察到，如果已创建队列的节点关闭，则队列在其他节点上将不可用。如果我尝试发布来自其他节点的消息，它将失败。即使我从集群中删除故障节点(使用forget cluster命令)并尝试从其他节点发布消息，行为也是相同的。
在rabbitMQ中有什么方法可以实现这一点吗？
浏览 0提问于2017-06-29得票数 2
我想在两个节点之间配置一个RabbitMQ集群，我的目标是采用主动/被动方法，如果主RabbitMQ由于某种原因而停机，我将将所有流量路由到被动RabbitMQ (通过RabbitMQ或其他方式)。
基本上，我不希望将消息复制到被动brocker，我只需要元数据(队列/交换/绑定)，是否有人知道是否有一种方法只同步这两只兔子之间的元数据(消息)？
谢谢
浏览 1提问于2014-03-09得票数 0
我有一个spring应用程序，它使用来自rabbitmq的消息。但是，当RabbitMQ服务器关闭时，spring服务器无法启动。
下面是一个例外，
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; protocol method: #method<connection.close>(reply-code=530, reply-text=NOT_ALLOWED - vhost test_queue not found, class-id=10, method-id=40)
浏览 0提问于2019-02-11得票数 4
概述
RabbitMQ代理是一个或多个Erlang节点的逻辑分组，每个节点运行RabbitMQ应用程序并共享用户、虚拟主机、队列、交换、绑定和运行时参数。有时，我们将节点集合称为集群。
你为什么要这么做？我理解如何提高消息的持久性(如果节点下降，其他队列仍然会收到消息)。但是表演呢？集群如何提高性能。难道所有的使用者/生产者都不会连接到主节点的队列吗？如果是这样的话，我们不是仍然在一个节点上获得通信量吗？我们是否设置了一个负载均衡器，以便每次流量都指向不同的节点？
RabbitMQ集群如何提高性能？
浏览 0提问于2018-03-06得票数 0
1-有人能详细说明这两种办法之间的区别吗？
详细地说，如果一个节点在每种方法中失败，队列和消息会发生什么？
我在医生里看到了
虽然RabbitMQ也支持集群，但是集群的目的是促进可伸缩性，而不是可用性。因此，在集群中，如果节点失败，失败节点上的队列就会丢失。使用本指南中描述的高可用性设置，当节点失败时，持久队列及其内的持久消息可以由不同的节点恢复。
这是否适用于镜像队列？
浏览 5提问于2016-03-27得票数 1
我想使用一个镜像了所有队列的RabbitMQ集群，以实现数据的高可用性。但我担心每秒推送大量数据时可能出现的性能不佳。
在这种情况下，是否有可能以某种方式进行负载平衡？
浏览 1提问于2017-04-11得票数 1
3回答
我们已经创建了一个包含两个节点(rabbit和rabbit1)的RabbitMQ集群。我们有4个队列，它们通过以下和配置为高可用队列
在集群之前，我们使用下面的代码片段连接到节点。
var factory = new ConnectionFactory(){ HostName = _rabbitMQ_Hostname, UserName = _rabbitMQ_Username, Password = _rabbitMQ_Password};
using (var connection = factory.CreateConnection())
using (var
浏览 2提问于2016-09-29得票数 1
3回答
默认情况下，RabbitMQ支持集群，但是队列不会被复制，并且绑定到创建队列的节点。我现在正在寻找使RabbitMQ高可用性的方法，而不是他们已经记录的DRBD解决方案，因为预留整个服务器除了等待活动服务器宕机之外，似乎是浪费资源。
我在考虑有两个队列的设置。发布消息时，我希望RabbitMQ集群将消息发送到两个队列中的任何一个队列。我知道，如果发布者尝试发布到一个关闭的队列，它会得到一个错误，并且发布者可以再次尝试另一个队列，但我想知道这是否可以在集群级别自动完成，这样我就不必编写客户端代码来处理它。这可以做到吗？
浏览 2提问于2010-08-05得票数 13
我正在学习RabbitMQ，它是如何工作的。
根据内部文档，消息存储保存消息内容，队列只保存消息的索引。
因此，当同一条消息被路由到多个队列时，它不会复制消息内容，而是只存储一次，在这些队列中保留对消息的引用(消息id)。
那么，如果一条消息被排队到属于不同机器的多个队列中呢？信息会只存储在其中一台机器上吗？
这个问题可以重新表述如下:支持存储的消息是全局的、跨集群的还是针对每台机器的本地的？
谢谢,
浏览 4提问于2016-08-11得票数 1
回答已采纳
我是RabbitMQ新手，我需要一些帮助。如何备份和恢复到RabbitMQ，需要保存的重要数据是什么？
谢谢!
浏览 1提问于2013-10-28得票数 18
我正在尝试扩展我的Rabbitmq服务，以提高服务的性能和吞吐量。 我找到了一个docker-compose文件，它运行了Rabbitmq的3个实例，并将它们连接到一个集群中。 version: '3'
services:
rabbitmq1:
image: rabbitmq:3-management
hostname: rabbitmq1
environment:
- RABBITMQ_ERLANG_COOKIE=${RABBITMQ_ERLANG_COOKIE}
- RABBITMQ_DEFAULT_USER=${R
浏览 41提问于2020-07-01得票数 0
回答已采纳
1回答
我们有一个配置了三个节点的RabbitMQ集群。每个节点都有两个虚拟主机(Vhost-A和Vhost-B)。我们需要一种将消息从Vhost-A移动到Vhost-B的可能性。为此，我们设置了一个工具，将消息从Vhost-A上的Exchange-1定向到Vhost-B上的Exchange-2。 rabbitmqctl -p Vhost-A set_parameter shovel shovel-exchange-1-to-vhost-b /
'{"src-uri": "amqp://user@/Vhost-A", "src-exchange&#
浏览 23提问于2019-02-05得票数 2
回答已采纳
因此，我在多个服务器上使用集群rabbitmq后端运行celery。最近，我对芹菜做的任何事情都开始无限期地挂起，检查rabbitmq的日志给我提供了一个模糊的错误消息：
=ERROR REPORT==== 20-Mar-2013::23:52:25 ===
connection <0.15823.3>, channel 1 - soft error:
{amqp_error,not_found,
"no binding i-69995906 between exchange 'i-69995906' in vhost 'celery
浏览 2提问于2013-03-21得票数 3
1回答
我需要在kubernetes集群中设置rabbitmq部署。
rabbitmq不能从外部访问，所以我只需要一个clusterIP服务，而不是负载均衡器。
我浏览了Statefulset的文档。但它谈到了设置rabbitmq集群，即一个主节点和两个工作节点。
为什么我不能只有一个包含两个副本和持久卷的rabbitmq部署？
这是我当前用于部署的配置文件。
apiVersion: apps/v1
kind: Deployment
metadata:
name: rabbitmq-depl
spec:
replicas: 2
selector:
matchLabels:
浏览 28提问于2021-03-08得票数 0
我有spring引导 rabbitmq应用程序，其中我必须发送一个Employee对象来排队。然后，我设置了一个侦听器应用程序。对employee对象执行一些处理，并将该对象放入回叫队列中。
为此，我在我的应用程序中创建了下面的对象。
创建了ConnectionFactory。
使用RabbitAdmin创建ConnectionFactory对象。
请求队列。
回调队列。
直接交换。
请求队列绑定。
回调队列绑定。
MessageConverter。
RabbitTemplate对象
最后是SimpleMessageListenerContainer的对
浏览 0提问于2018-03-17得票数 6
回答已采纳
我们有一个用于RabbitMQ的集群设置，我们正在使用MassTransit来管理消息类型、配置等。当我们关闭集群中的一个节点时，我们会直接在运行应用程序时得到如下所示的异常，这意味着整个应用程序都关闭了。 {
"Depth": 0,
"ClassName": "RabbitMQ.Client.Exceptions.BrokerUnreachableException",
"Message": "None of the specified endpoints were reachable"
浏览 37提问于2021-08-12得票数 0
回答已采纳
我刚刚创建了一个API，其中来自API的请求将使用请求/响应模式通过MassTransit/RabbitMQ转发到后端服务。我们现在正在考虑将其推向生产，并希望在不同的服务上运行应用程序的多个实例(包括API和服务)，并使用负载均衡器在它们之间分发请求。
这使我们处于这样一个位置，如果由于任何原因其中一台服务器被移出池，我们可能会丢失所有消息。我正在考虑在服务器之间创建一个RabbitMQ集群(每个服务器都有一个本地安装)，并且想知道如何在这个实例中设置竞争的消费者。
RabbitMQ或MassTransit是否会处理此问题，以便只有一个消费者会收到请求，还是所有消费者都会收到请求并尝试响应？
浏览 0提问于2012-06-17得票数 1
回答已采纳
RabbitMQ集群中有三个节点，如下所示。
在RabbitMQ中，有两个队列，q1和q2。
q1和q2的主副本分布在不同的节点上。两个队列都由其他节点镜像。
在三个节点前面有一个负载均衡器。
通过负载均衡器公开了AMQP(节点端口5672)和Management (节点端口15672)。
当应用程序通过负载均衡器建立连接时，它可以到达后面的随机RabbitMQ节点。这对于应用程序来说是看不见的。
问题：
无论到达哪个节点，应用程序都可以在单个连接上使用两个RabbitMQ通道吗？
应用程序可以调用management，而不管请求访问哪个Rabbi
浏览 1提问于2019-08-02得票数 3
回答已采纳
3回答
如何使RabbitMQ可伸缩？
、、、、
我试着测试RabbitMQ，但是我发现rabbitmq存在一些问题:如果我创建了一个由3个节点组成的集群，那么我不能发布/交付超过6000/s的节点；如果我只使用一个节点，我可以发布/传递到25000/s。这意味着，我添加的节点越多，性能就越差。
但是从本文中：
他们可以出版100多万份，那么他们如何才能做到呢？我想让RabbitMQ每秒处理100多万条消息
浏览 4提问于2016-04-15得票数 5
回答已采纳
我想实现Rabbitmq服务器的高可用性。我已经阅读了Rabbitmq提供的文档，文档上使用的是DRBD，我不想使用DRBD进行共享存储，从我这方面，我已经做了两个节点的集群和准备镜像队列。rest需要实现高可用性帮助我。
谢谢
浏览 1提问于2012-05-17得票数 1
回答已采纳
据我所知，RabbitMQ集群是为了可伸缩性而不是可用性，但使用镜像队列也允许可用性，因为如果主服务器失败，可以将最新的从站提升为主服务器。
从文件中：
发布到队列的消息将复制到所有从站。无论连接到哪个节点，使用者都连接到主节点，从节点删除在主节点上已被确认的消息。因此，队列镜像提高了可用性，但不会跨节点分配负载(所有参与的节点都完成所有工作)。
因此，为给定队列跨节点进行负载平衡是没有意义的，因为这总是会增加从连接到队列主节点的节点的额外行程(除非我误解了什么)。因此，我们希望始终能够知道哪个节点是给定队列的主节点。
我并没有很好地使用RabbitMQ，所以我可能只是在文档中遗漏了它
浏览 2提问于2016-05-09得票数 3
回答已采纳
背景
我有一个运行了一年多的RabbitMQ集群，没有任何问题。最后，我发现，有时，机器的CPU是接触100% CPU。我正在研究如何提高集群的吞吐量以服务更多的客户。
集群体系结构是我们启用了HA (准确地说是一个副本)和持久消息(用于所有队列)。据我所知，durable特性在性能上是最昂贵的。所以，我试着去了解我是否需要它。
问题
根据我的经验，集群运行了一年多，没有问题。所以我假设问题发生的可能性很小。即使在这之后，我也想创造另一层保护，以防万一.
如果我有两个服务器保存相同的数据，但没有将其存储到磁盘中(持久关闭)，那么99.99%的情况下是否足够安全？这两台服务器位于不同的区域，因此
浏览 2提问于2020-12-16得票数 0
回答已采纳
2回答
为了在我们的猫集群中通信事件，我们使用了rabbitmq和交换扇出架构。订阅每个服务器，通过临时队列进行交换。一切看起来都很好，但有时一个或多个使用者会失去连接，在日志中不留下一些有用的信息就不会处理消息--这是一些坏掉的管道消息的一部分。
另外，我们在兔子集群和我们的服务器之间使用负载均衡器。
如果有任何建议，问题在哪里，或者我们应该审查什么配置？
浏览 1提问于2016-05-06得票数 1
回答已采纳
3回答
我有一个带有3个节点的RabbitMQ集群(3.0.1版)。我希望，我的队列每次都在所有3个节点上可用。
我创建这样的集群：
node1：
node2:兔join_cluster @node1 1
node3:兔join_cluster @node1 1
在此之后，我设置了以下策略：
图案：^(?!amq.).*
定义：ha模式: all
如果我现在开始我的3个节点并在我的一个节点中写一些想法，那么我在所有3个节点上都有它，它可以工作。但是，如果连接到其中一个节点死亡，节点在一段时间后开始工作，则该节点将不再与其他节点同步。
我怎么解决这个问题？我希望，所有节点每次都是同步的，即使在停机后也是
浏览 7提问于2012-12-19得票数 2
回答已采纳
我正在尝试设置代理集群，它应该具有与rabbitMQ集群相同的功能，但通过广域网(我的机器位于不同的位置)，因此rabbitMQ集群无法工作。
我正在寻找替代方案，rabbitMQ联合只是备份下游的消息，不能确保它们在任何时候都有完全相同的消息可用(下游仍然保留上游已经使用的旧消息)
我找到的ActiveMQ主/从版怎么样：
队列和主题都在群集中的每个代理之间复制(因此经常复制到主代理，也可能复制到单个从代理)。因此，群集中的每个代理在任何时候都有完全相同的消息可用，因此，如果主代理发生故障，客户端将故障转移到从代理，而您不会丢失消息。
我担心的是，如果它可以自动更新，以确保Master/Sl
浏览 0提问于2014-05-24得票数 1
2回答
背景
我们车上有很多GPS设备。这些设备需要与我们的系统通信。为了实现这一点，我们需要在继续之前解析设备的消息。
下面描述了我的可伸缩和抗失败的体系结构思想。
体系结构
这些设备是黑匣子，每隔X秒就会通过TCP发送数据缓冲区。一条典型的信息遵循这一轨迹：
每个设备都与具有持久队列的RabbitMQ服务器(R1)通信。这样，如果某些东西失败了，就不会丢失任何消息。
R1将消息发送到消息解析器群集(仓鼠集群)。将接收数据缓冲区作为输入并输出JSON对象的仓鼠命名为我们可以理解的。
仓鼠集群然后将解析的消息发送到另一个持久队列(R2)，该队列具有与R1相同的属性。
然后，R2将这些消息发送给数据处理
浏览 0提问于2018-04-23得票数 3
1回答
现在我正在研究如何提高兔子的效率。
例如：
组件：
TCP负载均衡器
生产者
RabbitMQ簇
消费者
生产者：
2-5台EC2服务器.每个服务器都安装了一个logstash，并将其配置为向兔子发送消息。这没什么特别的。只有一个需求，消息需要持久化。(以防万一I/O不是问题)
RabbitMQ集群：
2台EC2服务器。内存，cpu，好的磁盘，很好的带宽。
消费者：
不同的消费者数量可能在2-15岁之间。使用者连接到负载均衡器(ELB)。其中一些使用basic.get，另一些使用basic.consume。要求：no_ack = False，意味着所有消息都需要被确认。
浏览 2提问于2013-09-13得票数 1
1回答
在我们的RabbitMQ集群中，我们正面临着糟糕的性能。即使在空闲的时候。
一旦安装了reductions/sec.，我们就会看到许多进程具有非常高的。100,000甚至更多！
问题：
什么意思？
如何控制它？
是什么原因导致如此缓慢，没有任何错误？
备注：
我们的集群运行在Kubernetes 1.15.11上
我们分配了3个节点，每个节点有8个CPU和8GB限制。将vm_watermark设置为7G。实际使用是~1.5CPU和1GB内存
RabbitMQ 3.8.2.二郎22.1
我们没有太多的消费者和生产者。慢度也处于相当空闲的环境中。
rabbi
浏览 3提问于2020-06-12得票数 3
回答已采纳
1回答
我使用logstash和elasticsearch来构建日志系统。RabbitMQ用于在两个日志堆栈之间对日志消息进行排队。
消息路径如下所示：
source log -> logstash -> rabbitMQ -> logstash(parse) -> elasticsearch
但是我发现，不管我向rabbitMQ添加了多少机器，它只是使用一个机器资源来处理消息。
我发现一些文章说集群只是增加了可靠性和冗余，以防止消息丢失。
但是我想要的是通过添加更多的机器来增加整个RabbitMQ集群的吞吐量。
如何配置我的RabbitMQ集群以提高其吞吐量？
如有任何意见，
浏览 6提问于2014-07-29得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
