rabbitmq 相关问题

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

如何使用Python将XML文件发送到RabbitMQ？

我有一个名为Test.xml的xml文件，我正在尝试使用python发送RabbitMQ。我知道以下有关Rabbit MQ主机名的详细信息：xxx.xxxx.xxx AMQP端口（SSL）：4589 ESB门户（...

python-3.x pandas rabbitmq send rabbitmq-exchange

回答 1 投票 4

[AttributeError：module'pika'在rabbitmq中没有属性'BlockingConnection'错误

最近我尝试使用pika库将队列作为rabitmq（rabbitmq_tutorials_partOne）的文档，我输入了以下代码：import pika connection = pika.BlockingConnection（pika ....

python python-3.x rabbitmq queue pika

回答 1 投票 2

如何在nodejs中运行长时间运行的同步操作

我正在为组织使用nodejs编写工资管理Web应用程序。在许多情况下，应用程序应涉及CPU密集型数学计算以计算数字，并且...

node.js rabbitmq pm2 event-loop worker-thread

回答 1 投票 1

谁是rabbitmq集群管理器？如何从群集中获取数据？

我创建了Rabbitmq集群。有三个节点，一个主站，两个从站。当主节点去世时，谁来决定哪个从节点是新的主节点。谁是集群管理员？以及如何从集群中获取数据。我可以...

java python rabbitmq bigdata cluster-computing

回答 1 投票 0

RabbitMQ微服务-并行处理

我正在使用rabbitmq作为消息传递系统来开发微服务架构中的应用程序。微服务之间的调用是异步http请求，并且每个服务都在特定的...上进行预订...

java rabbitmq microservices

回答 3 投票 1

SimpleMessageListenerContainer无法正确调用消息处理程序

我正在尝试在Spring Boot应用程序中监听RabbitMq队列。在我的RabbitConfig.java文件中，我有以下bean：// RabbitConfig.java // ...排队，交换，绑定bean等@Bean ...

java spring-boot rabbitmq amqp spring-rabbitmq

回答 1 投票 0

Spring boot RabbitMQ给异常，在类路径资源中创建名称为'connectionFactory'的bean时出错

我正在使用Jhipster消耗RabbitMQ的消息，当我使用IDE在本地运行代码时，它可以正常工作，但是当使用（mvn clean install）命令构建项目时，我得到了很多...

spring-boot rabbitmq jhipster

回答 1 投票 0

通过docker run暴露的端口，但没有docker-compose up的端口

我正在尝试通过docker-compose来运行Rabbitmq以及influxdb TICK堆栈。当我使用以下命令运行Rabbitmq时：docker run -d --rm -p 5672：5672 -p 15672：15672 rabbitmq：3-management，两个端口...

docker docker-compose rabbitmq influxdb

回答 1 投票 0

RabbitMQ是否支持像Kafka这样的哈希分区？

我有一个RabbitMQ，有多个使用者在单个队列上进行了订阅。我希望具有相同哈希键的消息每次都可以由同一使用者使用。我知道...

rabbitmq

回答 1 投票 0

我如何直接将消息发送到停车场队列，防止重新排队并退出程序流？

我目前有4个队列：测试队列测试队列短期死亡信测试队列长期死信测试队列停车位当消息进入测试队列时，我检查一下...

java rabbitmq message-queue spring-amqp

回答 1 投票 0

RabbitMQ未确认消息未在到期后从队列中删除

我有一个运行简单的交换扇出队列绑定的RabbitMQ服务器（v.3.8.2），有多个生产者和一个消费者。平均传送/确认速率非常低，约为6 msg / s。队列...

rabbitmq timeout

回答 1 投票 0

pika rabbitmq python 3.6

我正在尝试使用pika与Rabbitmq def get_connection（）：凭据= pika.PlainCredentials（MQ_USER，MQ_PASS）connection = pika.BlockingConnection（pika.ConnectionParameters（...

python rabbitmq pika

回答 1 投票 0

MassTransit / RabbitMQ中的消息持久性

我有2个应用程序，一个事件发布一个，事件消费者一个。发布者使用SimpleInjector：container.AddMassTransit（x => {x.AddBus（（）=> Bus.Factory ....

.net rabbitmq masstransit

回答 1 投票 0

在发布者端在SimpleInjector中为MassTransit建立队列

我有2个应用程序，一个事件发布一个，事件消费者一个。发布者使用SimpleInjector：container.AddMassTransit（x => {x.AddBus（（）=> Bus.Factory ....

.net rabbitmq simple-injector masstransit

回答 1 投票 1

何时在ActiveMQ中的队列侦听器上发送ACK和NACK

问题是何时将ACK或NACK消息发送到代理。文档说：ACK用于确认使用客户端或客户端-...