rabbitmq 相关问题

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

尝试使用OpenSSL到RabbitMQ时,Connection无限挂起 - 没有提到错误

我在RabbitMQ服务器中配置了SSL连接。在查看Rabbit日志时 - 我清楚地看到Rabbit侦听5671端口:= INFO REPORT ==== 2017年12月5日:: 15:27:59 ===启动SSL侦听器...

回答 2 投票 0

Celery Beat:一次限制为单个任务实例

我有芹菜和芹菜(四名工人)批量做一些加工步骤。其中一项任务大致是这样的,“对于每个没有创建Y的X,创建Y.”任务是......

回答 5 投票 6

具有消息队列的生产者,使用者和处理者

我参与了一个由以下应用程序组成的项目:生产者应用程序:通过ASP.NET web api从客户端接收消息,并将消息排入消息队列。消费者应用:......

回答 1 投票 -1

Celery + Redis - .get()在平稳运行约70个小时后无限期挂起

一切都运行良好多天,但随后我无限期地挂在.get()上。无限期挂起所需的时间各不相同,但运行时间为24到72小时。我......

回答 1 投票 2

在spring-boot中使用rabbitmq时,在vhost'/'中没有队列'dev_pms2invoi_queue'

我想在spring-boot项目中使用rabbitmq只是使用注释,这是我的mq配置代码,@ Configuration公共类RabbitMqConfig {@Bean(value =“pmsMqConnectionFactory”)public ...

回答 1 投票 1

Spring AMQP使用noLocal使用者发送和接收临时队列

使用临时队列发送和接收时,会创建一个使用noLocal属性设置为true的使用者(请参阅版本1.7.4的RabbitTemplate #doSendAndReceiveWithTemporary方法行1297 ....

回答 1 投票 1

@RabbitListener没有从队列接收消息

我正在使用@RabbitListner注释来接收来自RabbitMq队列的消息。虽然我已经完成了执行此操作所需的所有步骤(即在我的配置类中添加@EnableRabbit注释)并声明...

回答 1 投票 0

使用xdebug从rabbitmq队列执行调试php

我正在尝试调试RabbitMQ使用者执行的PHP代码。 xdebug在CLI和http中工作正常,但是当从队列执行某些操作时它会失败。我设置了以下跟踪:...

回答 1 投票 1

有没有办法使用PhpStorm和Xdebug调试RabbitMQ Consumer(php-ampqlib)?

这是我的开发设置:IDE:PhpStorm 9.0.2调试器:Xdebug 2.3.3消息队列服务器:RabbitMQ 3.5.6 PHP Lib连接到RabbitMQ服务器:php-ampqlib要启动我的消费者,我正在使用CakePHP任务.. 。

回答 2 投票 7

Masstransit队列以公共汽车为前缀,后缀为随机字符串

我正在接管一个项目,其中Masstransit被用作RabbitMQ的抽象。我看到许多队列以“bus”为前缀,后缀有一些随机字符串。这些是什么......

回答 1 投票 1

队列最大长度或TTL使用get但不消耗

我看到许多帖子询问限制队列长度。在我对Pika和RabbitMQ的实验中,如果我使用arguments = {'x-message-ttl':1000,'x-max-length':2,'x-overflow':'drop-head'}声明队列。 ..

回答 1 投票 1

慢网络中的大RabbitMQ消息

我正在使用RabbitMQ与Spring AMQP大消息(> 100MB,102400KB)小带宽(<512Kbps)低心跳间隔(10秒)单个代理需要> = 200 * 8秒消耗...

回答 2 投票 2

Python:使用celery处理多个服务器上的参数列表

我正在尝试使用Celery来处理输入列表。我想只处理一次输入。问题是我的服务器都是超级计算机集群的一部分。我可以发送每个服务器一个...

回答 1 投票 0

具有多个路由键的Spring引导流绑定队列

我需要使用多个路由键绑定单个队列。我在application.properties中进行了配置:spring.cloud.stream.bindings.some-channel1.destination = exch spring.cloud.stream.bindings.some -...

回答 1 投票 1

带有React的Rabbit-MQ

React是否与Rabbit-MQ一起使用?过去几天我一直在谷歌上搜索死亡,我只能找到有关React Native的结果。我可以只关注Javascript-RabbitMQ-Tutorial还是......

回答 2 投票 1

RabbitMQ在amqp_login调用时关闭套接字

我正在使用.. \ rabbitmq-c \ examples中的示例代码来创建与http:// localhost:15672的连接。从以下代码块中我得到:登录:socket是关闭输出的...

回答 1 投票 0

SpringBoot RabbitMq解析框中的json消息自动

我有我的springboot应用程序连接到RabbitMQ队列,我按照指定的Json格式推送消息,例如:{“messageId”:“de5fe5a3-1831-4b87-891d-e7a4c29295b4”,“message”:{“listingId”:“ 2" },...

回答 1 投票 1

从dockerfile构建的docker容器运行时无法连接到Rabbit MQ实例

我们正试图将一个兔子mq的实例放入我们的Kubernetes环境中。为此,我们必须将它实现到我们的构建和发布过程中,其中包括通过...创建一个docker容器。

回答 2 投票 0

如何使用带有Jhipster的RabbitMQ创建新的队列?

我创建了一个新的jhipster微服务。我添加了RabbitMQ模块。它是功能性的。不过我想创建手动队列,我试图在CloudMessagingConfiguration中添加它...

回答 1 投票 0

为什么RabbitMQ + Ubuntu 18.04(全新安装)在重启后松动所有用户/数据?

Ubuntu 18.04,更新和升级。 RabbitMQ根据当前版本使用RabbitMQ教程进行安装。机器在ESXI上运行,因此不受硬件干扰。全新安装后,......

回答 1 投票 1

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