rabbitmq 相关问题

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

如何在Spring引导API中实现RabbitMQ使用者部分(接收者)

我将把我的DATA发送到RabbitMq生产者(消息发送者)并从RabbitMq消费者(消息接收者)获取负责任的数据。生产者部分工作正常。现在我的问题是如何实现...

回答 1 投票 0

Logstash Rabbitmq连接被拒绝

已经在Windows核心2016 Server中安装了Elasticsearch-6.6.0和kibana-6.6.0,它已经启动并运行,我不得不从Rabbitmq索引数据,所以下载并解压缩了logstash-6.0.0并进行了配置...

回答 1 投票 0

使用Flower时如何查看经纪人信息?

我正在通过命令运行花:芹菜花--broker = amqp:// : @localhost:5672 / --broker_api = HTTP:// : @ ...

回答 2 投票 0

如何使用芹菜节拍芹菜

我正在使用node-celery github链接来实现芹菜芹菜和rabbitmq的第一步。就像在芹菜中我们定义任务然后我们推动它们。我在tasks.py中定义的任务是......

回答 1 投票 1

amqplib:在打开握手期间,套接字突然关闭

我想做什么我尝试创建rabbit-mq发布者和订阅者。它按预期工作,直到我尝试重新启动我的rabbit-mq服务器。什么有效我使用rabbitmq:3管理码头图像,...

回答 1 投票 0

Quartz Scheduler和RabbitMQ

有没有办法根据来自RabbitMQ的消息启动Quartz中的工作并使该消息的内容可用于该作业?

回答 2 投票 0

失败的K8s rabbitmq-peer-discovery-k8s群集

我正在尝试使用Rabbitmq-peer-discovery-k8s插件在Kubernetes上建立一个RabbitMQ集群,我总是只在pod上运行并准备就绪,但下一个总是失败。我尝试了多个......

回答 4 投票 2

Spring启动时Rabbitmq并发消费者

我正在使用@RabbitListener注释和SimpleRabbitListenerContainerFactory bean来并行执行rabbitmq消息,并按以下方式设置最小和最大并发消费者:...

回答 1 投票 1

rabbitmq在一台服务器上有多个symfony2应用程序

我用RabbitMqBundle开发了一个Symfony2 Web应用程序,它工作正常。现在我正在尝试为其他开发人员设置更多相同应用程序的实例。那么,现在我有9个实例(...

回答 2 投票 0

在TomCat上没有配置的Task Executor的DirectMessageListenerContainer?

我正在为我的消息传递应用程序设置DirectMessageListenerContainer。我正在与Tomcat,Spring,AMQP合作。文档有这个警告https://docs.spring.io/spring-amqp/reference/#threading ...

回答 1 投票 0

cluster_formation.classic_config.nodes对rabbitmq不起作用

我有2个rabbitmq节点。他们的节点名是:rabbit @ testhost1和rabbit @ testhost2我想他们可以自动集群。在testhost1#cat /etc/rabbitmq/rabbitmq.conf cluster_formation ....

回答 1 投票 1

已建立的连接已由主机中的软件中止

我正在使用MassTransit对抗RabbitMQ。在大多数情况下它运作良好,但一段时间后,消费者开始抛出一个S-FAULT警告:MassTransit.Messages警告:0:S-FAULT rabbitmq:// ...

回答 2 投票 0

从另一个容器连接RabbitMQ容器

我通过运行以下命令来创建rabbitmq容器docker run -d --hostname My-rabbit --name test-rabbit -p 15672:15672 rabbitmq:3-management创建了一个名为userrabbit的用户并给出了...

回答 3 投票 2

如何限制RabbitMQ的消息大小?

我正在寻找类似于https://www.rabbitmq.com/maxlength.html的内容,以获取队列中每条消息的消息大小。

回答 1 投票 0

Celery在远程任务上使用Django Result Backend

我有一个使用Celery创建异步任务的Django应用程序。其中一些任务存在于Django项目中,而其他任务存在于具有自己的代码库的远程工作者身上。我目前用的是......

回答 2 投票 2

从RabbitMQ获取消息而不消费

我想获得Rabbitmq队列中存在的消息的副本而不消耗它们。可能吗 ?提前致谢,

回答 2 投票 0

celery:如何重命名任务并将其路由到队列

您能否就如何在芹菜任务上分配自定义名称提出建议?默认情况下,它获取模块名称,但我想知道以防我想将任务发送到特定队列,我怎么能......

回答 1 投票 1

内存监视包含RabbitMQ侦听器的应用程序的Java堆大小用法

使用RabbitMQ和Spring AMQP我有一个包含一些@RabbitListeners的Java应用程序。这些消费者非常快速地收听队列并处理消息。我有兴趣知道记忆......

回答 1 投票 0

是否可以直接从命令行查看RabbitMQ消息内容?

是否可以直接从命令行查看RabbitMQ消息内容? sudo rabbitmqctl list_queues列出了队列。有没有像sudo rabbitmqctl这样的命令命令...

回答 5 投票 82

Rabbitmq错误:[Errno 10054]远程主机强行关闭现有连接

我在Python中使用Kombu来使用持久的RabbitMQ队列。在Windows中只有一个消费者使用队列。此消费者产生以下错误:Traceback(最近一次调用最后一次):...

回答 1 投票 8

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