rabbitmq 相关问题

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

为Rabbitmq管理插件启用TLS

我正在尝试配置管理插件以使用TLS,但每次我收到以下错误:= ERROR REPORT ==== 2016年6月8日:: 15:52:19 === SSL:certify:tls_connection .erl:375:致命错误:......

回答 1 投票 3

识别rabbitmq消息的来源

我正在使用kombu来消耗来自多个队列的rabbitmq消息。对于任何给定的消息,是否可以确定传递哪个队列?

回答 2 投票 0

使用RabbitMQ(或pub / sub)作为变量

我有一个事件(比如活动),可能在给定时间有效或无效。我正在寻找一种方法来使用RabbitMQ来判断事件是否有效。我知道RabbitMQ的用例是pub / sub。 ...

回答 2 投票 6

如何解析Spring AMQP中的JSON对象?

有一个远程RabbitMQ服务器,它只允许我发送和接收消息。这意味着我无法创造任何东西。我发送了一个请求,并以JSON格式得到答案。在我的申请中我......

回答 2 投票 3

是否可以对rabbitmq-management插件使用基于证书的身份验证?

我们使用rabbitmq-management REST API对rabbitmq的实体(队列/交换)进行不同的操作。登录/密码的标准认证工作正常,但由于某些原因,我们......

回答 1 投票 1

什么是消息缓冲区?

我正在阅读关于RabbitMQ的本教程。在描述RabbitMQ中队列的内容时,它说明如下:队列仅受主机内存和磁盘限制的约束,它是......

回答 1 投票 0

MassTransit RabbitMq调度消息未发送给消费者

我想使用MassTransit + RabbitMq总线来调度来自总线的消息。我写了两个C#控制台应用程序,一个用于消息创建者并向调度程序发送消息,另一个用于消息...

回答 2 投票 0

Spring AMQP优先级消息

RabbitMQ中队列中的消息优先级。它正在与rabbitmq一起提供java客户端。但它不适用于春兔依赖。请看一看。 RabbitMQ服务器版 - 3.6.5 ...

回答 2 投票 1

rabbitmq镜像队列如何工作?

如果我要在群集中的节点中创建镜像队列,并在同一群集中的某些其他节点中创建镜像。假设我点击了那个主人的ip地址(或使用队列名称)......

回答 1 投票 0

当存在未确认的未确认消息时,RabbitMQ消费者会变慢

我有一个.NET Core控制台应用程序,它从RabbitMQ读取消息并将数据保存到数据库。它使用RabbitMQ.Client程序集5.1.0并设置一个这样的EventingConsumer:var factory ...

回答 1 投票 1

RabbitMQ与sidekiq

我在heroku中有两个rails应用程序,App1和App2(添加了cloudAMQP gem),App1在点击按钮时产生一些消息App1 class Publisher def publish#开始通信...

回答 1 投票 1

AMQP-CPP,libev>从另一个线程停止ev_loop

我使用带有libev后端的AMQP-CPP lib。我尝试创建一个将打开连接并进行消费的类。我想在工作线程中运行连接循环,以便不阻塞主线程。 ...

回答 1 投票 0

芹菜工人闲置几个小时后停下来

我有一个使用WSGI的Flask应用程序。对于一些任务,我打算将Celery与RabbitMQ一起使用。但正如标题所说,我面临的问题是Celery任务运行几分钟然后......

回答 1 投票 0

在将AsyncRabbitTemplate与请求/回复模式一起使用时,如何构建非阻塞使用者

我是rabbitmq的新手,目前正在尝试使用非阻塞消费者来实现非阻塞生成器。我已经构建了一些测试生产者,我在其中使用了typereference:@Service public class ...

回答 1 投票 3

Heroku,RabbitMQ和许多工人。什么是最好的架构?

我正在寻找处理以下场景的最佳方法:我有多个边缘设备将传感器数据发布到RabbitMq代理。经纪人将经历约500的整体工作量......

回答 2 投票 0

AMQP-CPP>处理程序中的错误文件描述符

我正在尝试使用AMQP-CPP库进行消息传递,但是我无法使其工作。我想使用库中已经构建的类来实现通道,连接和处理程序。我从他们的例子开始......

回答 1 投票 1

RabbitMQ Consumer不接收带有.net核心的Api发送的消息

我使用.net core 2.1.0和Masstransit和Rabbitmq。我的问题是当从控制器发送消息时,消费者无法接收消息public static void ConfigureServices(IServiceCollection ...

回答 1 投票 0

RabbitMQ DirectMessageListenerContainer中的消费者 - Cloud Foundry中的内存影响

我有一个场景,我在DirectMessageListenerContainer bean中为队列创建预定义的使用者,如下所示:@Bean public DirectMessageListenerContainer ...

回答 1 投票 0

如何绑定Spring集成错误处理和RabbitMQ错误处理以重新排队消息失败并出现一些跳过的异常?

如何绑定Spring集成errorChannel(错误处理)和RabbitMQ错误处理(listenerContainer的errorChannel)以重新排队消息失败并带有一些跳过的异常?我有一个春天-...

回答 1 投票 0

有没有办法使用RabbitMQ以100%的交付保证传输数据?

我正在构建一个系统,我希望将RabbitMQ用作主要的消息传递机制。我的系统需要非常强大的信息传递保证,因为消息必须到达他们的...

回答 1 投票 3

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