rabbitmq 相关问题

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

RabbitMQ HTTP API返回401(未经授权)

使用RabbitMQ localhost并尝试使用他的API。当我从邮递员那里打电话时,它工作正常。但是我试图在我的应用程序代码中使用此API,但出现401错误:const test = {count:5,...

回答 1 投票 1

RabbitMQ:双向联合代理,如何使所有队列弹出消息?

我有两个配置有联合插件的代理[1]。两者都指向上游。我的测试是:在经纪人A上发布一条消息在经纪人B上消费。结果是:在...上消费...

回答 2 投票 1

基于SSL的RabbitMQ LDAP验证证书

[使用rabbitmq_auth_backend_ldap时,如果我们使用ssl,有必要提及SSL选项以确保我们与正确的服务器通信,请使用以下选项:{ssl_options,[{...

回答 1 投票 1

将两个docker映像合并为一个docker映像

我需要通过合并“ RabbitMQ-management”和“ MongoDB”图像来创建单个docker图像。有可能做到吗?我已经尝试使用下面的Dockerfile,并且可以访问...

回答 1 投票 0

时发生错误,从AMQP属性映射到MessageHeaders

虽然与RabbitMQ的消息通信被成功地消耗,但是,显示在日志以下警告。 **发生错误而映射从AMQP性质MessageHeaders ** ...

回答 1 投票 1

通过MassTransit发送到多个RabbitMQ主机

我正在RabbitMQ的.NET应用程序中使用MassTransit。它可以正常工作,我已经在ioc中配置并注册了MassTransit总线控件,现在我可以将消息发送到RabbitMQ实例,并且...

回答 1 投票 0

是否可以确保在Rabbitmq队列中存在唯一的消息?

[基本上,我的消费者也是生产者。我们得到一个初始数据集,并将其发送到队列。消费者拿走一件商品并进行处理,从那时开始,有3种可能性:数据是...

回答 3 投票 10

使用nginx-ingress从外部kubernetes集群发送消息到RabbitMQ

我正在尝试在kubernetes集群中设置RabbitMQ任务队列,并且需要能够从kubernetes集群外部填充任务队列。我正在尝试使用...

回答 1 投票 0

RabbitMQ无法启用管理插件

C:\ Program Files \ RabbitMQ Server \ rabbitmq_server-3.7.14 \ sbin> rabbitmq-plugins.bat enablerabbitmq-management目录名称无效。文件名,目录名称或卷标签语法为...

回答 1 投票 0

Rabbitmq和Python NameError:全局名称问题

我正在尝试将JSON发送到Rabbitmq。这是我的生产者,并且可以正常运行:import pika import json certificate = pika.PlainCredentials('admin','123')parameters = pika.ConnectionParameters('...

回答 1 投票 1

cloudampq中的MassTransit高内存使用率

[我们目前有大约100个队列在.NET Core 2.0、3.0和使用MassTransit的完整.NET服务中运行,所有队列都托管在IIS的2台服务器上,即2个IP地址/连接(因此每个服务器有2个使用者)] >>> < [

回答 1 投票 0

RabbitMQ无法以自定义配置文件启动

我在Ubuntu上安装了RabbitMQ,并且一切正常,但是当我尝试更改管理插件的侦听端口时,无法再启动RabbitMQ服务器。须藤/etc/init.d/rabbitmq-server ...

回答 1 投票 0

在端口5671上连接到AMPQ RabbitMQ

[我正在尝试连接到RabbitMQ远程计算机以读取队列消息,当前我正在使用端口5672,该端口通过纯文本发送身份验证消息,因此我需要使其在端口5671上正常工作...

回答 1 投票 1

RabbitMQ仲裁队列-数据仅由一个节点写入/传递吗?

在说有4个节点(N1-N4)的RabbitMQ仲裁队列(使用木筏)集群中,我可以有一个只能从N1 / N2读取的使用者吗?在这种情况下,将在N3中生成的消息通过...

回答 1 投票 0

Ruby Bunny交换wait_for_confirm或死亡

在利用Bunny gem进行发布确认时,结合类似于RabbitMQ channel.waitForConfirmsOrDie()方法的最佳方法是什么?现在我正在使用:if!...

回答 1 投票 1

rabbitmq Pika连接经常断开连接

我有以下代码:import pika import os从eventlet.green导入threadlet pika = eventlet.import_patched('pika')eventlet.monkey_patch()#更多代码,如果__name __ =='...

回答 2 投票 0

Django Celery RabbitMQ访问被拒绝(403)ACCESS_REFUSED

我有一个将heroku与芹菜集成在一起的django项目。我已经通过heroku获得了Rabbitmq插件,并在本地测试了我的任务是否成功。我遇到的问题是连接远程服务器...

回答 1 投票 0

在同一个Rabbitq队列中处理多个probbuff消息

我的问题是我正在使用单个队列(作为我的服务的入口点),并使用golang使用者处理传入的消息。我的消费者消息:= pb.GetRequest {}错误:= proto.Unmarshal(msg ....

回答 1 投票 0

重新发布NACK版本的消息-RabbitMQ .NET Core 3.0

我目前正在尝试使用发布者确认来实施更具弹性的RabbitMQ。我一直在使用他们教程中的代码,到目前为止,我已经能够触发NACK回调...

回答 1 投票 0

rabbitmq命令中断所有pip安装

MQTT和Linux世界的新手。我正在跟踪此链接来设置我的Mqtt经纪人。运行此命令后#import PackageCloud签名密钥wget -O-“ https://packagecloud.io/rabbitmq/rabbitmq -...

回答 1 投票 0

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