rabbitmq 相关问题

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

即使状态正在运行,也无法访问docker中配置的rabbitmq管理

我是新的docker世界,我正在尝试访问我的Windows 10上的RabbitMQ管理插件。我正在关注此事。但是当我尝试“http:// container-ip:15672”时,我无法访问管理层。 ...

回答 1 投票 0

在初始化Spring Boot Application之前,寻找一种解析spring boot application.yml文件中的值的方法

所以我的问题如下:我使用spring AMQP连接到使用SSL的rabbitMQ实例。不幸的是,spring AMQP目前不支持全长amqps URI并添加支持...

回答 2 投票 1

RabbitMQ通过Spring的RabbitAdmin调整HA队列

我想知道:有没有办法只使用Java Spring代码设置RabbitMQ镜像(HA队列)。 AFAIK有一个特殊的类RabbitAdmin用于这样的配置问题,但不能......

回答 1 投票 1

Celery task.delay在docker容器中被阻止

我在django项目中使用芹菜。它适用于我的MacBook和CentOS VM。当我在docker容器中运行它时,始终阻止包含add.delay(add是任务)方法的请求。一世 ...

回答 1 投票 0

Ramdom com.rabbitmq.client.ShutdownSignalException:连接错误

我们有一个应用程序,我们使用Spring-AMQP通过AMQP连接到远程服务器。最近,随机,我们收到连接错误。这些错误每天发生一次或两次......

回答 1 投票 0

一个RabbitMQ队列上有多个使用者

我正在关注RabbitMQ的这个指南:https://www.rabbitmq.com/tutorials/tutorial-two-java.html。我想在一个队列上使用多个线程来模拟此功能。如果我启动接收器......

回答 2 投票 2

如何用pika和rabbitmq禁用心跳

我正在使用rabbitmq来帮助从我的兔子服务器到我各自的消费者的一些任务。我注意到,当我进行一些相当冗长的测试,20多分钟时,我的消费者将失去与...的联系。

回答 2 投票 0

保持pika BlockingConnection不会禁用心跳

我正在开发一个带有pika 0.10.0和python 2.7版本的RabbitMQ使用者。在我的消费者客户端中,我有一个根据输入消息运行一段时间的进程。它可以从3到40 ......

回答 2 投票 2

Pika BlockingConnection和RabbitMQ:连接已关闭

我有2个rabbitmq在群集负载平衡Azure内部负载均衡器。客户端使用BlockingConnection连接到LB.当客户交换消息时,一切......

回答 1 投票 1

RabbitMQ Pika连接重置,( - 1,ConnectionResetError(104,'通过peer重置连接'))

通过stackoverflow搜索并发布此问题,因为没有解决方案适用于我,我的问题可能与其他问题不同。我正在写一个脚本,从...获取一篇文章

回答 1 投票 1

RabbitMQ pika.exceptions.ConnectionClosed(-1,“error(104,'peer reset by peer')”)

我在RabbitMQ中有一个任务队列,其中包含多个生产者(12)和一个用于Web应用程序中繁重任务的消费者。当我运行消费者时,它开始出现一些消息,然后崩溃...

回答 1 投票 1

RabbitMQ破坏了管道错误或丢失了消息

使用pika库的BlockingConnection连接到RabbitMQ,我偶尔会在发布消息时出错:致命套接字错误:错误(32,'破管')这是一个非常简单的...

回答 2 投票 5

使用鼠兔在RabbitMQ中同步和阻塞消耗

我想与阻塞同步使用队列(RabbitMQ)。注意:下面是准备好运行的完整代码。系统设置使用RabbitMQ作为排队系统,但异步消耗......

回答 1 投票 9

RabbitMQ在处理长时间运行的任务时关闭连接,超时设置产生错误

我正在使用RabbitMQ生产者向消费者发送长时间运行的任务(30分钟+)。问题是当与服务器的连接关闭并且...时,消费者仍在处理任务。

回答 2 投票 11

如何重新连接RabbitMQ?

我的python脚本一旦从另一个数据源收到消息,就不得不向RabbitMQ发送消息。 python脚本发送它们的频率可以变化,例如1分钟到30分钟。 ...

回答 2 投票 12

如何在RabbitMQ中更改“disk_free_limit”

我正在使用Ubuntu。我已经通过下载.deb文件rabbitmq-server_3.3.4-1_all.deb安装了RabbitMQ我无法在这个位置找到我的rabbitmq.config / etc / rabbitmq怎么找到它?我有......

回答 3 投票 0

如何使用Spring Boot从RabbitMQ队列中获取多个线程?

我们的应用程序使用RabbitMQ提供的几个队列中的数据。为了提高吞吐量,我们为每个队列启动多个线程,这些线程从这些队列中执行阻塞对于新服务......

回答 2 投票 0

在pika / RabbitMQ中处理长时间运行的任务

我们正在尝试建立一个基本的有向队列系统,其中生产者将生成多个任务,一个或多个消费者将一次获取任务,处理它并确认该消息。 ......

回答 6 投票 43

RabbitMQ,在节点中编写的pub子模型中重新排除被拒绝的消息

我正在创建一个简单的聊天应用程序,其中可以有多个用户和多个聊天室。每个聊天室可以容纳多个用户。服务器启动时建立rabbitMQ连接。当一个 ...

回答 2 投票 0

RabbitMQ - 如何检查队列是否为空?

我有一个Web服务接口抽象RabbitMQ服务器(不要问我为什么,我知道这是一个不必要的步骤,但我必须)。也就是说,我通过Web服务调用从队列中轮询消息,...

回答 2 投票 1

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