rabbitmq 相关问题

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

如何正确配置LogStash以从RabbitMQ读取并将输出写入文件?

我想使用LogStash读取RabbitMQ发布的消息,并将响应作为每个文件的一条JSON行写入本地文件夹。我已经安装了Docker桌面并提取了LogStash Docker映像。 ...

回答 2 投票 0

骆驼RabbitMQ并发消费者和threadPoolsize用于必须按顺序处理的消息

我有一个骆驼路由处理来自RabbitMQ端点的消息。我保持并发(1)和threadPoolSize(10)的默认值。我对RabbitMQ相对较新,但仍然不太了解...

回答 1 投票 1

如何从在同一台计算机上运行的Spring boot docker容器访问RabbitMQ服务(在主机上)

环境详细信息Windows 10 Docker桌面Spring Boot(在容器中使用它)RabbitMQ(作为服务安装在我的Windows机器上)我想访问RabbitMQ ...

回答 1 投票 0

RabbitMQ连接被拒绝

我无法表示同意RabbitMQ。RabbitMQ不在本地计算机上。导入org.springframework.amqp.core.Binding;导入org.springframework.amqp.core.BindingBuilder;导入org.springframework ....

回答 1 投票 0


Nodejs:在主题交换中使用Rabbitmq消息

我正在尝试使用Rabbitmq主题交换。在Rabbitmq Web管理中,我使用以下详细信息创建了一个名为queue1的队列:创建队列后,我使用了默认交换amq.topic并绑定了queue1 ...

回答 1 投票 0

JMS(Tibco / IBMMQ / ActiveMQ)与Apache Kafka [关闭]

[何时选择通过Apache Kafka以及其他方式选择JMS(Tibco / IBMMQ / ActiveMQ)

回答 1 投票 -1

RabbitMQ连接失败:代理无法访问-Docker映像

我已经安装了这个Rabbitmq映像(标签:rabbitmq:3-management),用于在我的机器上设置容器的以下命令docker run --hostname my-rabbit --name some-rabbit -p 8080:15672 rabbitmq:3-。 ..

回答 1 投票 0

获取MassTransit消息重试次数

我正在使用Masstransit + RabbitMQ。我的使用者之一实施重试策略,我想知道一旦消息进入错误队列,是否有任何方法可以使消息重试?我也想...

回答 1 投票 1

将流量阻止到一个docker服务任务(容器)

有3个不同的vm,其中RabbitMQ服务以全局模式部署。我的目标是阻止对RabbitMQ服务容器之一的访问。尝试使用iptables重现RabbitMQ网络...

回答 1 投票 3

Spring Actuator RabbitMQ-Prometheus未显示消息计数

使用Spring执行器并启用Prometheus配置以监视RabbitMQ消息统计信息,但即使队列中有消息或已使用消息,也始终将消息计数显示为零。是否有任何...

回答 1 投票 0


如何使用pika 1.1.0添加超时?

我已经使用pika 0.12。*一段时间了,我习惯于使用以下代码添加超时。 connection = pika.BlockingConnection()... connection.add_timeout(30,error)...现在我是...

回答 1 投票 0

Rabbitmq消息到达和响应时间戳

是否有一种方法可以从使用者那里获取将消息放入队列时的时间戳。不是发布它的时间,而是它实际进入队列的时间。

回答 1 投票 0

在RabbitMQ中反序列化对象

我有一个要在队列中发送的对象,它是一个对象。我还有另一个读取该队列的队列。我可以以字符串的形式从该队列中读取数据,但是我想将其反序列化为...

回答 1 投票 -1

在等待客户端的channel.basicAck时,频道可以保持多长时间

我很好奇,如果没有意外错误,在等待客户端确认消息时(使用channel.basicAck()),通道会保持活动状态吗?通道是否有超时参数? ...

回答 1 投票 2

如何设计实时数据库更新系统?

我正在使用WPF和.Net在桌面上设计类似Messenger应用程序的whatsapp。现在,当用户创建一个网上论坛时,我希望该网上论坛的其他成员收到有关他们是...

回答 1 投票 4

Spring-Rabbitmq侦听器需要在数据库更改期间暂停和恢复

嘿,要求是在更改后端表期间暂停Rabbitmq侦听器处理消息。此更改仅限于我的应用程序,因此不想降低...

回答 1 投票 0

Spring Cloud Stream RabbitMQ-使用标头而不是路由键进行分区

我正在浏览文档,但找不到与此相关的任何内容,因此我在这里只是为了与您确认。我们想使用Spring Cloud Stream对Rabbit队列进行分区,但是希望...

回答 1 投票 0

如何设置连接友好名称RabbitMQ --Python

你好,我在玩RabbitMq,我有一个问题。我有许多并行节点在运行,并连接在rabbitmq-server上。关键是要像ip:port这样声明:...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.