RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。
Rabbitmq.conf 文件中的 SSL 配置未应用于我的rabbitmq-服务器
我使用以下命令在我的aws EC2机器上安装了rabbitmq: sudo apt-get 更新 sudo apt-get 安装rabbitmq-server sudorabbitmq-plugins启用rabbitmq_management 然后我创建了
在 Chrome Kiosk/扩展/应用程序和 Web 浏览器中实现 RabbitMQ
我正在开发需要推送通知的内部应用程序,但我们无法使用外部服务。我已经开始使用 RabbitMQ 并让它在 .NET Core 中完美运行。当
使用 Pika 的 RabbitMQ 队列中的“messages_ready”
我需要获取准备好的消息数量。队列具有三种类型的消息: 1. Total 2. Unack'd 3. Ready 就绪是那些在队列中但尚未被消耗的。 当前...
我在阅读 Manning 的《RabbitMQ in Action》一书时遇到了一个有趣的主题。显然,可以将消费者设置为能够在
已阅读文档(https://cdn.rawgit.com/rabbitmq/rabbitmq-management/v3.7.9/priv/www/api/index.html) 并且没有找到一种方法将消息发布到队列(不是交换器,a...
RabbitMQ中的PublisherConfirm模式和事务有什么区别?
我觉得publisher的confirm模式和transaction都需要broker确认消息的接收,那为什么publisher的confirm模式被认为是轻量级的操作,有更好的效果
我们在单个Linux机器上安装rabbitmq 3.6.9版本。作为客户端安全漏洞检查的一部分,rabbitmq 服务器出现以下问题。 任何人都可以指导我们吗
是否可以使用 RabbitMQ .NET 客户端查看队列中所有活动消费者的名称/标签?
我正在创建一个 .NET 应用程序,该应用程序将从我的应用程序未创建或维护的多个第三方队列中使用,我希望每个队列有一个消费者
假设我使用“confirm.select”将通道置于确认模式,并将确认模式设置为手动,然后我执行以下操作(伪代码): 函数 msg_handler(msg: TheDelivery, chan:
我尝试使用 SSL 从 .NET 应用程序连接到 RabbitMQ。 RabbitMQ 3.8.8、Erlang 22.2、操作系统 Windows RabbitMQ.Client.Exceptions.BrokerUnreachableException:“没有指定的端点
如何在rabbitMQ上向所有订阅主题队列的消费者推送消息,并在所有消费者都收到后确认消费
例如,现在有十个消费者订阅了主题交易所。我需要推送消息。所有十个消费者都收到并仅消费一次,然后销毁该消息。我怎样才能...
RabbitMQ 客户端 EventingBasicConsumer 停止接收消息
使用 RabbitMQ.Client v. 6.2.2 我面临这样的问题:如果集群中的代理发生故障,EventingBasicConsumer 有时会停止接收消息。 调查这个问题我正在记录
我正在使用 Go 编写一个服务,并使用 RabbitMQ 进行消息传递。我需要在标头中添加信息,该标头应包含消息流经的位置,它应添加交换名称或...
Windows 上的 RabbitMQ 似乎限制每个进程的连接创建
我想了解我在以下代码中看到的行为。使用 RabbitMQ.Client 库版本 6.2.2。 预期行为:连接快速创建并且过程不会变慢
如何获取pika中请求是否获得basic_ack或basic_nack
例如我有一个消费者和一个生产者。 在生产者中,我为消费者发布一些数据。 在消费者中,我做了一些事情,我可以确认或拒绝请求。 怎样才能在制作人那里找到...
我有一个 RabbitMQ 队列,我在其中发布了数千条消息。我需要一个后台服务来: 批量检索消息,每组消息 100 条 将这 100 条消息存储在数据库中 确认...
我想在一台 RHEL8 机器上创建一个三节点 RabbitMQ 集群以进行测试。我尝试了 RabbitMQ 官方指南中给出的说明,并尝试遵循该指南。 第一个...
我有两台机器窗口,每台机器都有一个 RabbitMQ 服务器。 我可以在同一 LAN 中的 Windows 节点中使用 RabbitMQ 实现高可用性方法吗?
我们正在开发一个项目,该项目使用rabbitMQ作为消息代理,并使用pika作为主干。我们使用在同一网络上的计算机上运行的发布者每 0.5 秒发布一条消息。一个合作...
我正在使用 Pika 与 Rabbit MQ 配合使用。我使用以下命令向经纪人发送消息: Channel.basic_publish('direct', 'samt_routing',json.dumps({'name':'reza','lastname':'rastgoo','id':i}))