rabbitmq 相关问题

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

AMQP-CPP RabbitMQ接收额外的标志,message.body()比message.size()更大

当我收到消息时,我通过message.body()获取消息内容,但最后总是添加一个字符。 message.body()的内容总是比message.size()大一个。 ......

回答 1 投票 1

RabbitMQ点对点或pub-sub

RabbitMQ是点对点还是pub-sub?或两者都取决于配置选项?我一直在研究配置,他们似乎都支持点对点模型而不是pub-sub。一世....

回答 2 投票 0

如何使用mocha和chi检查节点js中的兔子连接以进行单元测试

我正在使用amqplib-package连接到nodeJS中的RabbitMQ,并想知道如何在nodeJS中使用Mocha和Chai检查/验证我的RabbitMQ连接?

回答 1 投票 1

从RabbitMQ队列读取时如何检测错误

我正在从RabbitMQ队列中读取消息,如下所示:messages,err:= channel.Consume(queue,// queue queue,// consumer - 与queue false相同,// auto-ack false,// exclusive ...

回答 1 投票 2

在RabbitMQ上运行时Masstransit的开销是多少?

当使用Masstransit和RabbitMQ时,我看到了令人失望的表现。交付/下降到0.20 /秒。我开始用一个简单的测试应用程序来研究这个问题。此应用程序运行在......

回答 1 投票 0

来自一个Queue RabbitMQ Spring的多个监听器

我正在研究一个示例例子,从这个队列中有一个队列和2个侦听器,小问题和问题......当有很多消息时,sutric线程正在自杀,当有低...

回答 1 投票 0

从静态工厂类访问ASP.NET Core DI容器

我创建了一个ASP.NET Core MVC / WebApi站点,该站点有一个RabbitMQ订阅者,基于James Still的博客文章Real-World PubSub Messaging with RabbitMQ。在他的文章中,他使用静态类来......

回答 4 投票 21

使用Axon 4接收AMQP的活动

我试图通过rabbitmq发送消息到基于axon4 spring boot的系统。收到消息但未触发任何事件。我很确定我错过了一个必不可少的部分,但到目前为止我还没有......

回答 1 投票 1

在直接交换RabbitMQ时,它是否将消息传递给连接到该特定队列的所有消费者?

在直接交换RabbitMQ时,它是否将消息传递给连接到该特定队列的所有消费者?或者只有一个消费者,尽管有很多消费者?我跟着 [...

回答 1 投票 0

静默地将作业返回队列

我有一个定义了作业队列的RabbitMQ,我通过Spring Framework使用Java来消费它。我知道,如果我在处理作业时在代码中的某个地方抛出异常我...

回答 1 投票 0

如何更改所有设备的用户会话状态,dnd等

我基于openfire创建了一个信使。我可以在线/离线连接和设置状态,openfire控制台也会更改,但我的其他设备有问题。其他设备(其他用户)......

回答 1 投票 1

RabbitMQ对来自交换的消息的死信队列的奇怪行为

我使用amqp lib for php作为rabbitmq客户端我们想要拒绝来自名为“test”的队列的消息为了不让这个消息丢失我们定义了名为“test.deadletter”的deadletter队列。如果...

回答 1 投票 0

使用RabbitMQ在NServiceBus中设置自动删除和独占属性

有谁知道如何在NServiceBus中为RabbitMq队列设置autodelete和exclusive?我尝试了以下但它不起作用:protected override void OnConfigurationStarting(...

回答 1 投票 0

管理RabbitMQ中的消息锁定

我试图以更加非传统的方式使用RabbitMQ(虽然此时我可以选择任何其他消息队列实现,如果需要)我有一个队列(我可以有更多,如果需要),其中......

回答 1 投票 0

如何让RabbitMQ Kafka连接器生成的字节数组数据获得密钥?

我使用官方的Kafka RabbitMQ连接器从RabbitMQ实例获取JSOn消息。目前,此连接器如果配置如此名称= RabbitMQConsentConsumer connector.class = io.confluent ....

回答 1 投票 0

RabbitMQ无法启动,TCP连接成功但Erlang分发失败

我刚刚开始在Windows系统上学习和安装RabbitMQ。我在自定义文件夹中安装Erlang VM和RabbitMQ,而不是默认文件夹(两者都有)。然后我重新启动了我的电脑。通过......

回答 4 投票 4

Spring amqp使用者在网络故障后没有重新连接到队列

我们有一个spring应用程序,它有一个动态队列监听器连接到rabbitmq中的队列。假设我的弹簧应用程序总共有5个侦听器消费者连接到5个队列...

回答 1 投票 0

如何从收听者发送回复

我正在从事Java和RabbitMQ学习的家庭作业。我对Spring和RabbitMQ并不熟悉,但我无法解决这个问题。我有2个单一的申请。第一个,......

回答 1 投票 0

芹菜工人不向rabbitmq发布消息?

我有一个设置,其中celery_result_backend已配置为'amqp'。我可以看到我的任务由日志中的工作人员执行。但它正在创建具有任务ID的队列,但其状态是......

回答 1 投票 0

RabbitMQ CreateConneciton问题 - 在一个应用程序中运行,但在另一个应用程序中运行

所以这是连接代码。 var factory = new ConnectionFactory {HostName =“myserver”,UserName =“testuser”,Password =“testuserpassword”};使用(var connection = factory ....

回答 1 投票 4

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