rabbitmq 相关问题

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

我无法在RabbitMQ上使用MQTT协议

我想在RabbitMQ代理上使用MQTT协议,但是在尝试运行Producer时出现错误。这是我的代码。我只想测试先发送一些消息,然后导入pika ip ='192.168.43.101'user = ...

回答 1 投票 0

如何将RabbitMQ库添加到项目? '无法解析导入的“ com.rabbitmq”'

我正在研究RabbitMQ Java教程,网址为:https://www.rabbitmq.com/tutorials/tutorial-one-java.html我已经下载了Java客户端库软件包,并将JAR文件复制到了我的.. 。

回答 2 投票 4

3个Pod中有2个无法在K8s设置中连接RabbitMQ

我使用头盔图表(bitnami / rabbitmq)进行部署。当所有3个Pod尝试同时连接到Rabbitmq时,我只有3个Pod,然后只有一个Pod可以连接到RabbitMQ,其他2个处于挂起状态。 ...

回答 1 投票 -1

RabbitMQ消耗内存并关闭

我刚刚使用devstack安装了OpenStack Juno,并观察到RabbitMQ(yum安装的软件包Rabbitmq-server-3.1.5-10)不稳定,即它很快就耗尽了内存并关闭了内存;那里...

回答 1 投票 1


动态队列和侦听器,消息未发送?

兔子配置:包com.rabbitMQ;导入org.slf4j.Logger;导入org.slf4j.LoggerFactory;导入org.springframework.amqp.core.AmqpAdmin;导入org.springframework.amqp.core.AmqpTemplate; ...

回答 1 投票 0

如何在Flask微框架中创建单例对象

我正在为Producer创建一个类,该类将消息推送到RabbitMQ。它利用了pika模块。我想创建一个处理程序,以便可以控制交互的连接数...

回答 1 投票 0

Spring cloud stream RabbitMq-从源代码设置属性

我正在使用RabbitMQ使用Spring云流。我希望能够从源代码设置消息和查询属性。例如,对于经典的RabbitMq Java客户端,我可以执行类似...

回答 1 投票 0

Spring AMQP Rabbit监听器在“ ApplicationReadyEvent”之前触发

在Spring应用程序启动时,我想在Redis中查找一个值,根据该值,我想关闭或保留我拥有的消息侦听器。也可以不...

回答 1 投票 0

Celery守护程序-如何配置它以从多个Flask应用程序运行多个任务?

我有一个烧瓶应用程序myapp_A,它使用celery运行一些异步任务。而且我已经将celery配置为作为守护进程运行。这是服务脚本。 / etc / default / celery:#节点名称...

回答 1 投票 0

RabbitMQ客户端:指定的端点均不可访问

我正在研究ASP.NET Core WebApi微服务。我将项目部署在Azure Dev Space上,并且除非我开始使用RabbitMQ,否则它运行良好。使用RabbitMQ ...

回答 1 投票 0

如何使用RabbitMQ管理插件将字节数组发布到队列?

如下所示,RabbitMQ管理GUI可以直接将消息发布到特定队列。此队列的使用者使用protobuf格式的消息,这意味着我应该发布...

回答 1 投票 0

我如何使用amqplib在没有IP地址的情况下直接访问RabbitMQ?

在我工作的地方,我们有一台cloudfoundry服务器,提供RabbitMQ作为服务。当我配置此服务并尝试使用amqplib通过(本地主机,127.0.0.1等)进行连接时,它无法连接。当...

回答 1 投票 0

Rabbitmq:如何创建RABBITMQ_ERLANG_COOKIE

我正在尝试在我的kubernetes中部署一个Rabbitmq Pod。因此,我使用了Google托管的Rabbitmq:https://github.com/GoogleCloudPlatform/rabbitmq-docker/blob/master/3/README.md#connecting-to-a-running -...

回答 1 投票 1

RabbitMQ-如何在过期队列中进行死信/处理消息?

我有一个设置了x过期时间的队列。我遇到的问题是,如果队列过期,我需要对队列中的消息进行进一步处理。我最初的想法是设置x-dead -...

回答 1 投票 0

在RabbitMQ中给定日期后从特定队列退订

我有一个Java类,它通过GUI上的某个动作,启动与RabbitMQ服务器的连接(使用发布/订阅模式)并侦听新事件。我想添加一个新功能,其中...

回答 1 投票 1

RABBITMQ C#在控制台上运行良好,但不适用于服务

我了解如何通过https://www.rabbitmq.com/dotnet-api-guide.html或同一网站上的教程使用RabbitMQ的消息。它在控制台应用程序上很好用!我在做什么?我...

回答 1 投票 0

从C#的RabbitMQ中的队列中获取所有消息

给出队列名称,我需要RabbitMQ中该队列中的所有消息。我在msgCount变量中有队列中的消息数,在strBody变量中有第一条消息。但是我需要所有...

回答 2 投票 0

如何更改RabbitMq的默认设置以持久保存所有消息和队列(全局)[关闭]

我知道我可以为每个队列指定持久性设置,并为每个消息手动指定持久性设置。但我正在寻找一种更改默认行为的方法,以便所有内容(队列,消息等)...

回答 1 投票 0

Rabbitmq的丢失队列

[今天早上,我发现Rabbitmq实例通常没有几个队列。我注意到的是一种模式,其余的队列是将消费者附加到...

回答 1 投票 0

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