rabbitmq 相关问题

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

Spring Boot没有连接到RabbitMQ

更新:在https://github.com/justsomecoder/boot-rabbit-issue上发布了非工作版本我试图实现一些基本的RabbitMQ发送和接收功能,但似乎无法得到它...

回答 1 投票 1

如何为RabbitMQ和Spring动态注册队列及其独占的使用者/监听器?

我有以下问题需要解决:我正在尝试使用RabbitMQ消息传递实现一个简单的延迟重试机制。我有一个基础设施,让我延迟交付......

回答 1 投票 0

如何删除rabbitmq(pika)中的消息

如何删除发布和接收的消息,在rabbitmq我用python测试rabitmq,同样的消息继续发布和接收,如何避免这种情况。我该怎么删除...

回答 1 投票 0

使用RabbitMQ插件在Grails中创建队列运行时

我有一个系统,外部系统可以订阅我的系统生成的事件。系统用Grails 2编写,使用RabbitMQ插件进行内部消息传递。外部事件......

回答 3 投票 0

如何托管MassTransit和RabbitMq

我们正在努力建立一个类似下面的体系结构,但我们将在云上提供微服务,一些在内部使用队列和总线进行相互通信,现在我对...感到困惑。

回答 2 投票 3

为什么芹菜会给rabbitmq添加数千个队列,这些队列在任务完成后似乎会持续很长时间?

我正在使用带有rabbitmq后端的芹菜。在Rabbitmq中生成数千个队列,其中包含0或1个项目,如下所示:$ sudo rabbitmqctl list_queues列出队列......

回答 2 投票 17

Docker连接上的RabbitMq失败

我正在学习RabbitMQ的基础知识,将其安装在容器上。检查容器时似乎没问题。 PS C:\ Users \ jvidin> docker port rabbitmq 25672 / tcp - > 0.0.0.0:32776 4369 / tcp - > 0.0 ....

回答 1 投票 2

为什么要运行消息队列(例如RabbitMQ)集群?

概述RabbitMQ代理是一个或多个Erlang节点的逻辑分组,每个节点运行RabbitMQ应用程序并共享用户,虚拟主机,队列,交换,绑定和...

回答 1 投票 -1

连接时Rabbitmq通道错误

我工作srv0与应用程序通常连接到rabbitmq我已经克隆srv0到srv1只是通过自定义IP登陆(用于测试目的)现在srv1上的客户端应用程序无法连接到...

回答 1 投票 1

有人可以解释花的平均负荷吗?

我使用花来监控我的rabbitmq队列,我无法理解如何计算负载平均值,如果有人可以解释那将会有很大的帮助。我有一个四核处理器。谢谢。

回答 1 投票 4

如果没有使用php amqplib显式关闭连接怎么办?

假设,在我的php脚本中,我已经使用php-amqplib客户端打开了与rabbitmq的连接。发布消息后,我没有明确地关闭频道和连接。我没有看到任何超时......

回答 1 投票 1

多服务器环境中的用户目标? (Spring WebSocket和RabbitMQ)

Spring WebSockets的文档说明:4.4.13。用户目标应用程序可以发送针对特定用户的消息,Spring的STOMP支持可识别目标...

回答 1 投票 1

如果params和任务名称已在服务器中排队,是否可以跳过委托芹菜任务?

假设我有这个任务:def do_stuff_for_some_time(some_id):e = Model.objects.get(id = some_id)e.domanystuff()我正在使用它:do_stuff_for_some_time.apply_async(args = [some_id] ,. ..

回答 3 投票 10

用于Rabbitmq Stomp的java websocket客户端

我正在寻找创建一个websocket客户端使用Java使用兔子mq stomp over websocker。我使用jetty客户端,我得到org.eclipse.jetty.websocket.api.UpgradeException:没有切换...

回答 2 投票 1

Rabbitmq联合队列与镜像

我是RabbitMQ的新手,不太确定我的目标是否可以实现。基本上,我的目标是能够设置高可用性和负载平衡的队列。所以给出了3个节点,每个节点有1个队列(让我们说...

回答 1 投票 0

使用RabbitMQ的SimpMessagingTemplate.convertAndSend工作非常慢

我正在使用带有RabbitMQ的Spring STOMP over Websocket。一切正常,但simpMessagingTemplate.convertAndSend工作很慢,调用可能需要2-10秒(同步,阻塞线程)。什么可以......

回答 1 投票 12

Pika - 处理RabbitMQ连接丢失

假设您创建了一个频道并开始在其中消费消息。 channel = get_channel()channel.queue_declare(queue = QUEUE_NAME,durable = True)channel.basic_qos(prefetch_count = 1)channel ....

回答 1 投票 0

由于缺少依赖性,无法构建RabbitMQ插件

我想开始使用我自己的RabbitMQ插件,但是我无法在干净安装Ubuntu 16.04的源代码中构建https://github.com/rabbitmq/rabbitmq-public-umbrella。我有 ...

回答 1 投票 1

rabbitmq - 不会获取队列中的所有消息

我正在尝试使用本教程(https://spring.io/guides/gs/messaging-rabbitmq/)与rabbitmq一起玩,我不知道为什么我不能立即收到所有消息。代码片段:亚军....

回答 1 投票 0

RabbitMQ Headers Exchange,其中X-Match等于任何

有人可以解释为什么会这样吗?我创建了一个头交换并将其绑定到三个具有不同参数的队列,如下所示:然后我尝试发布一个消息,其中任何队列都有...

回答 1 投票 1

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