rabbitmq 相关问题

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

我如何将html表单帖子保存到两个数据库? Rabbitmq vs Redis发布/订阅?

我有一个Flask微服务,需要将一个表单发布保存到AWS DynamoDB(通过boto3)和Elastic Search DB(在EC2上运行)。我首先考虑编写一个Python AsyncIO服务器来实现...

回答 1 投票 0

rabbitmq事件驱动的微服务

微服务架构和共享通用应用程序数据。场景为:今天有17种微服务用于一些在线社交媒体服务,其中9种需要知道谁连接到...

回答 1 投票 0

在Azure中的VM上设置RabbitMq

我在Azure虚拟机中设置RabbitMq时遇到问题。我浏览了Market Place并安装了RabbitMQ集群。 Azure为我安装了3个VM。因此,当我登录到...之一时...

回答 1 投票 0

通过发布者RabbitMQ(红宝石兔子)保持发布数据

我有一个RabbitMQ,其中的bunny使用Consumer.rb和Publisher.rb。如果我先运行ruby Consumer.rb,然后再运行Publisher.rb,则会得到正在发布的数据(数据来自另一个类)。数据...

回答 1 投票 0

从Python发送XML文件到RabbitMQ时获取'位置参数'错误

[我正在尝试从python发送XML文件到RabbitMQ,但是出现以下错误错误文件“ ”,第3行channel.basic_publish(exchange ='',queue ='abc',...

回答 1 投票 5

RabbitMQ如何实现优先级

在后台,FIFO队列如何以分布式方式转变为优先级队列?他们实际上是在交换基础数据结构,还是“被黑客入侵”的修复方法

回答 1 投票 0

[使用Django在Docker上设置RabbitMQ

我正在尝试使用Django建立Docker容器。我的Docker文件是:FROM python:3.7-alpine MAINTAINER Freshness Productions ENV PYTHONUNBUFFERED 1 COPY ./requirements.txt /requirements.txt RUN ...

回答 1 投票 0

我如何在RabbitMQ中将UnAck消息移至就绪状态

[有些消息在RabbitMQ中卡在UnAck状态。是否有任何方法可以将它们移至就绪状态而无需重新启动使用者应用程序或不重新启动RabbitMQ服务器?

回答 1 投票 0

EasyNetQ处理手动确认

我正在运行服务(多个实例)以使用easynetQ在RabbitMQ中使用消息。我想检查消息是否已经被接收到实例1,以及是否无法在...

回答 1 投票 0

了解为什么以后要处理消息队列

因此,我试图了解Queue解决了哪些实际问题。通过阅读Google的所有信息,我获得了高级知识。将消息推送到Queue以便以后处理,所以我...

回答 2 投票 0

Windows Server 2016上的RabbitMQ无法识别rabbitmq.conf

我在Windows服务器(otp_win64_22.2.exe和Rabbitmq-server-3.8.2.exe)上安装了RabbitMQ。我还安装了管理控制台。如果我查看位于%AppData%\ ...中的enabled_plugins文件,

回答 1 投票 0

调用多个功能作为RABBITMQ消息

我刚开始一般使用RabbitMQ和Python。我一直在阅读Rabbit官方页面上的Tut,但是我不知道如何使用Rabbitmq做其他事情。我一直在尝试...

回答 1 投票 0

[使用端口转发从一个泊坞站连接到另一个泊坞站,并且network = host失败

[我在python3.7.5中编写了一个连接RabbitMQ的应用程序:使用Ubuntu作为docker-machine,我在docker上运行Rabbitmq:docker run --name Rabbitmq -p 5671:5671 -p 5672:5672 -p 15672:15672 --...

回答 2 投票 0

如何在Qpid JMS中为ActiveMQ(如RabbitMQ)创建主题交换?

我有一个使用RabbitMQ的Java应用程序。该应用程序创建一个TOPIC交换,并使用其自己的路由密钥将消息推送到TOPIC。通过这种方式,如果我想要来自任何...的数据...

回答 1 投票 0

RabbitMQ的更好的设计方法是什么?

最近几周我一直在与RabbitMQ玩耍,并开发了以下设计模式生产者消息代理(rabbitmq)排队给消费者。我...

回答 1 投票 0

MassTransit Publisher没有引发异常

我有一个用Asp.Net Web API开发的MassTransit生产者/发布者。生产者只需将消息发送到Exchange->队列。公共异步任务 AddToQueue(int msgId,Message ...

回答 1 投票 0

Kubernetes负载均衡器外部IP待处理

我在Kubernetes中创建RabbitMQ集群。我正在尝试添加负载均衡器。但是我无法获得负载均衡器External-IP,它仍然处于挂起状态。 apiVersion:v1类型:服务元数据:名称:Rabbitmq ...

回答 2 投票 0

composer需要依赖项注入,但是已经存在

“ name”:“ symfony / dependency-injection”,“ version”:“ v5.0.4”,“ source”:{“ type”:“ git”,“ url”:“ https://github.com/ symfony / dependency-injection.git“,”参考“:” ...

回答 1 投票 -2

MassTransit RabbitMq发送消息

发送/发布消息时,我无法弄清楚如何在我的GetSendEndpoint())任务中指定Exchange和队列?根据MassTransit文档https:// masstransit-project ....

回答 2 投票 1

基于RabbitMQ消息消费ID(c#API)

我想发布/产生带有某个消息ID的消息,就像每个消息都有一个特定的ID。在消费者端,我想通过占用ID来检索消息。假设我们...

回答 2 投票 0

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