rabbitmq 相关问题

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

使用绑定键的Symfony messenger队列 - 重试策略

我在我工作的公司里实现了Messenger。我发现路由键有问题。我想把一条消息发送到两个队列中，另外两个应用程序将处理这个队列。另外两个应用程序将处理这个队列。一切都很好，...

php symfony rabbitmq amqp symfony-messenger

回答 1 投票 2

是否有任何设置，以返回到第一个集群CachingConnectionFactory setAddresses

我正在使用CachingConnectionFactory的setAddresses方法为多个集群。 connection = new CachingConnectionFactory(); connection.setAddresses("rabbit1:5672,rabbit2:5672"); 当我关闭...

spring spring-boot rabbitmq spring-rabbitmq

回答 1 投票 0

改变RabbitMQ的消费者权重

就我在rabbitmq文档中看到的，被查询的消息是以循环的方式发送到连接的消费者。然而，我想让我的一个消费者只接受，比如说1%......

java rabbitmq load-balancing

回答 1 投票 0

如何计算谁先接受订单？

有一些用户。他们可以执行订单。订单可以为所有用户发送。当用户收到订单时，他可以在1分钟内接受或拒绝订单。如果用户接受订单，我将信息存储在...

c# mysql algorithm rabbitmq

回答 1 投票 0

与RabbitMQ的Node.js连接

我有一个node.js应用程序使用amqlib与RabbitMQ连接。我试图重现RabbitMQ的连接错误，通过重复相同的流程，我得到了两个不同的错误。...

node.js docker rabbitmq amqp node-amqp

回答 1 投票 0

可以查询pubsub系统中已经消耗的旧消息吗？

我正在建立一个打牌的系统，我决定使用SSE的pubsub系统来保持客户端的更新。我面临的一个问题是把消息保留下来，以便以后查询。一个用例是...

apache-kafka redis rabbitmq publish-subscribe

回答 2 投票 0

是让RabbitMQ的连接保持开放还是只在必要时才开放？

我有一个应用程序，它循环进行一系列的测试。在失败的测试中，它将消息发布到 RabbitMQ 队列中，其他应用程序将监视并从中获取。有数百个测试...

python rabbitmq pika

回答 1 投票 0

当队列有效载荷中添加的值出现错误时，我想重新排入RabbitMQ。

我有一个奇特类型的问题声明要解决。将RabbitMQ配置为消息代理，其工作正常，但当消耗过程中出现故障时，我现在用nack确认，但它 ...

node.js typescript rabbitmq message-queue

回答 1 投票 0

我可以使用aws角色认证rabbitmq连接吗？

我在AWS EC2上托管了一个rabbitmq集群。我的远程应用程序是否可以使用AWS IAM角色或任何其他方式使用AWS服务来验证连接到rabbitmq服务器？...

amazon-web-services rabbitmq amazon-iam pika

回答 1 投票 0

消费者。无法连接到amqp:/user:**@rabbit1:5672/: 未能解析经纪人主机名。

我仔细阅读了非常类似的stackoverflow问题，并将我的代码改成了现在的样子。我仍然得到无法解析broker hostname的错误。如果我只是使用amqp:user:mypass@locahost:...。

python-3.x docker docker-compose rabbitmq celery

回答 1 投票 0

CachingConnectionFactory确认类型简单与相关。

CachingConnectionFactory确认类型简单与相关的区别是什么。

spring-boot rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

Masstransit RabbitMQ发布者未能发布 "正确 "的合同。

我一直在使用Masstransit和RabbitMQ创建消息合同以实现两个.NET核心Web API之间的通信，我已经玩了一段时间，我偶然发现了以下内容。...

asp.net-core properties rabbitmq asp.net-core-webapi masstransit

回答 1 投票 0

正运，返回消耗的信息。

我对Masstransit是个新手，我不太清楚如何配置这个。有没有办法将消耗的消息返回到我调用Consume方法的地方？Consume方法返回...

.net rabbitmq masstransit

回答 1 投票 0

使用Spring上下文进行的集成测试无法接收RabbitMQ消息。

RabbitMQ MessageConsumer没有收到发布的消息我正在编写一个集成测试，它应该从队列中接收消息并进行处理。但消费者根本没有......

rabbitmq testcontainers spring-context

回答 1 投票 0

无法在安装stablerabbitmq-ha时从发布清单中构建kubernetes对象。

当我试图安装 "rabbitmq-ha "时，出现了一个错误 $ helm install rabbitmq stablerabbitmq-ha Error: unable to build kubernetes objects from release manifest: unable to recognize "": no matches for ...

kubernetes rabbitmq kubernetes-helm

回答 1 投票 0

RabbitTemplate: 经纪人不支持通过'amq.rabbitmq.reply-to'快速回复。

为什么RabbitTemplate不能使用direct-reply？是否有任何与broker有关的配置？

rabbitmq spring-rabbitmq

回答 1 投票 0

Masstransit - Rabbit MQ虚拟主机。

string uri1 = @"rabbitmq:/myusername:mypassword@myipmyvirtualhostmyqueue"; 我一直得到一个ConfigurationException was unhandled. ...

c# rabbitmq masstransit

回答 1 投票 2

如何在 REST 客户端和 (Python) REST 服务器之间插入 RabbitMQ？

如果我开发了一个托管在Apache中的REST服务和一个Python插件，它的服务是GET、PUT、DELETE、PATCH；而这个服务是由Angular客户端（或其他REST交互浏览器技术）消费的......