rabbitmq 相关问题

RabbitMQ是一个开源消息代理，最初实现AMQP协议，并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用，或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的，以及正在使用的OS和编程语言。

rabbitmq createConnection 抛出错误 [错误：连接结束：可能是由于身份验证失败。]

嗨，我尝试使用node.js 连接rabbitmq 但出现错误。 [错误：连接结束：可能是由于身份验证失败。] var MessageQueue = AMQP.createConnection({'host' =&g...

node.js rabbitmq amqp

回答 2 投票 0

什么时候使用rabbitmq.conf和rabbitmq-env.conf？

我正在阅读： RabbitMQ 配置不清楚的是何时使用rabbitmq.conf和rabbitmq-env.conf？特别是当强制使用一种而不是另一种时，无论在什么操作系统中（Windo...

rabbitmq

回答 2 投票 0

两个消费者使用基于 Pull 的方式检索消息时能否获得相同的消息集？

所以我有一个基于客户端-服务器的生态系统，我使用 RabbitMQ 作为持久中间件。现在单个消息的流程是这样的。步骤 1：客户端 A 向服务器发送消息...

java rabbitmq messaging

回答 1 投票 0

RabbitMQ - 多个消费者单个发布者

当使用RabbitMQ处理大量消息时，我需要为同一个发布者和任务添加多个消费者。 RabbitMQ 和网络上的大多数教程都建议注册多个

java rabbitmq message-queue

回答 1 投票 0

在可读队列python中关闭连接

当微服务从RabbitMQ获取消息并且处理数据很长时间，并且与窃听上的队列关闭连接时回溯（最近一次调用最后一次）：

python rabbitmq pika

回答 1 投票 0

创建的交换被拒绝访问

我是使用c# 的rabbitmq 新手。我们正在尝试为 epex 点创建一个 API，它在传输标签协议中使用 AMQP，并为此使用 Rabbitmq。我可以使用 epex 点的服务器连接...

c# rabbitmq

回答 2 投票 0

rabbitmq队列中消息过多，队列不会过期

我正在使用rabbitmq 3.7.0和nodejs，在打字稿中使用这个库。所有消费者都是{noAck: false, Exclusive: false}，所有队列都是{prefetch:1, expires: 14400000, Durable:false}（4小时...

node.js rabbitmq

回答 1 投票 0

使用 NTLM 进行 RabbitMQ 身份验证（无密码）

我已经配置了 RabbitMQ，但目前它使用简单的用户名/密码连接到队列。这并不理想，因为我必须将密码存储在应用程序配置中。理想情况下，我

c# .net rabbitmq amqp messagebroker

回答 1 投票 0

读取交换的所有标头而不传输有效负载

我想根据标头信息（主要是路由密钥，但最好还有其他标头）生成一个交换上的按摩流量的统计信息。由于涉及的带宽很大，我会

rabbitmq amqp

回答 1 投票 0

单连接、多通道的多线程 Kombu RPC 应用程序

我有一个 RPC 应用程序，每个线程有一个连接和多个通道。目前，如果程序仅在单个线程中使用，则该程序可以按预期工作。然而，当添加超过...

python multithreading rabbitmq rpc kombu

回答 1 投票 0

RabbitMQ 交替交换和交换到交换绑定

RabbitMQ v3.7.8 （AE = 交替交换）文档指出：每当与已配置 AE 的交换无法将消息路由到任何队列，它都会将消息发布到指定的AE

rabbitmq amqp

回答 1 投票 0

RabbitMQ.Client BasicPublish 在完成之前返回

我遇到了一个问题，我有一个控制台应用程序作为计划任务运行，并向兔子队列发送大约 350k 消息，处理队列并结束。我的问题是 model.BasicPubli...

c# rabbitmq

回答 1 投票 0

客户端的单独队列是仅向他们发送消息的好方法吗？

我有一个系统，客户端从队列中提取任务（通过 amqp，使用 RabbitMQ 作为消息服务器）。当一个新客户端产生时，他会拉取一个任务，告诉主服务器他是ch中的那个......

rabbitmq amqp

回答 1 投票 0

rabbitmq监控集群中master节点的配置

有没有办法了解集群高可用配置中谁是主节点？是否可以使用监控工具来做到这一点？

rabbitmq cluster-computing high-availability

回答 1 投票 0

rabbitmq如何同步消息？

我使用 pika 使用这个简单的代码： conn = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) 通道 = conn.channel() def on_message(ch, 方法, 属性, 消息): 打印（“

python rabbitmq message-queue pika python-pika

回答 1 投票 0

当消费者在 Rabbit mq 中生成时丢失从发布者发送的消息

我只是在探索rabbit mq主题https://www.rabbitmq.com/tutorials/tutorial- Five-javascript.html 当我连续运行 ./receive_logs_topic.js "#" （消费者）并发布消息时...

rabbitmq

回答 1 投票 0

使用路由键从 Rabbit MQ 获取消息

我创建了一个基本队列，消息根据路由键进行路由。现在我有不同的域，域是基本队列的路由键。例如领域 [email protected] 将拥有一套我...

rabbitmq

回答 1 投票 0

RabbitMQ DefaultConsumer 导致消费者标签过多

我有一个 RabbitMQ 客户端应用程序，用于侦听特定队列。客户端创建DefaultConsumer的实例并实现handleDelivery方法。这是代码受保护