rabbitmq 相关问题

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

RabbitMq RPC 与其他同步方法

背景 我们有一个由多个微服务组成的系统。对于通知事件,我们使用 RabbitMq 队列和交换器。对于同步请求,我们使用 HTTP/REST。 RabbitMQ RPC

回答 1 投票 0

持久的队列无法在集装箱停靠后幸存下来

我有以下设置: 版本:'3.8' 服务: 兔子MQ: 图片:rabbitmq:3-管理 容器名称:'rabbitmq' 卷: - ./rabbitmq.conf:/etc/rabbitmq/rabb...

回答 1 投票 0

@RabbitListener 与使用类映射器使用 Jackson2JsonMessageConverter 配置的 containerFactory 不会转换为映射对象

在消费者应用程序中,我有以下配置: @配置 公共类 RabbitMqConfiguration { ... @豆 公共 SimpleRabbitListenerContainerFactoryrabbitMqListenerContainerF...

回答 1 投票 0

RabbitMQ Windows 安装程序命令行参数

我正在寻找 RabbitMQ Windows 安装程序 .exe 的参数列表。我尝试过传递像 /? 这样的参数并从命令提示符帮助检查列表,但相反,.exe 文件...

回答 1 投票 0

带有 STOMP 的 Rabbitmq 拒绝从浏览器连接

我有一个启用了stomp插件的rabbitmq Docker。 每当我尝试建立与 docker 的连接时,我都会收到以下错误: STOMP 连接 172.19.0.1:54578 -> 172.19.0.2:61613

回答 1 投票 0

当我使用 IRequestClient 从状态机获取结果时,为什么 MassTransit 会抛出错误

我尝试使用 MediatR 模式通过 API 获取状态机结果,但出现超时异常,最后出现 404 - 我想知道我在这里做错了什么。 命名空间 Play.Trading.Purchases.GetPurcha...

回答 1 投票 0

rabbitmq何时从队列中删除消息?

首先我声明交换,队列并将它们绑定在一起。 我基本向这个队列发布一条消息,因此队列中有一条消息。此时我开始我的消费者程序(使用自动...

回答 2 投票 0

ampqlib 错误:docker 容器内的“帧大小超过帧最大值”

我正在尝试在基于docker的node.js + ts和rabbitmq上使用后端做简单的应用程序。所以有 2 个容器:rabbitmq 容器和后端容器,有 2 个服务器正在运行 - 生产...

回答 1 投票 0

RabbitMQ / amqplib -- 错误:帧大小超过帧最大值

与 RabbitMQ 的连接失败并出现错误:帧大小超出帧最大值。 虽然StackOverflow和Github上也提出了一些类似的问题,但仍然很模糊。 人们假设 v...

回答 3 投票 0

从 Apache Qpid java 客户端使用 RabbitMQ 服务器消息?哪个版本?

我必须使用带有Apache qpid java客户端的rabbitmq-server(因为我必须使用Apache Camel)。但我对它们两个的版本感到困惑,特别是因为 amqp 协议支持......

回答 1 投票 0

构建rabbitmq-server和erlang并从源代码启用FIPS

我尝试在启用了 FIPS 的 Ubuntu 20.04 上安装rabbitmq-server,我发现 erlang DEB 默认包中没有编译它。我阅读了本指南 - https://www.erlang.org/doc/...

回答 2 投票 0

MQTT订阅者如何在RabbitMQ中接收AMQP消息?

我将AMQP消息发布到队列,并使用绑定键#绑定到amq.topic交换。 我可以看到 MQTT 订阅者队列也通过绑定键 # 绑定到 amq.topic 交换。 虽然发表了...

回答 1 投票 0

AMQP 中持久性和持久性概念的混乱

对这两个术语有点困惑,我在想拥有持久消息但瞬态(非持久)队列的目的是什么? 毕竟,如果代理重新启动并且队列...

回答 1 投票 0

如何使用 php-amqplib 关闭来自消费者回调的rabbitmq连接

我已经能够设置一个使用 php-amqplib 库连接到 RabbitMQ 的脚本。但是,如果有必要,我希望能够退出脚本。 我们认为创建 stop.txt 文件不会...

回答 2 投票 0

如何使用 php 在 RabbitMQ 中停止或超时消费者在特定时间后的消费

这里是rabbitmq文档上关于消费者使用php和php-amqplib包的hello world示例: 这是关于消费者使用 php 和 php-amqplib 包的rabbitmq 文档上的 hello world 示例: <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->queue_declare('hello', false, false, false, false); echo " [*] Waiting for messages. To exit press CTRL+C\n"; $callback = function ($msg) { echo ' [x] Received ', $msg->getBody(), "\n"; }; $channel->basic_consume('hello', '', false, true, false, false, $callback); try { $channel->consume(); } catch (\Throwable $exception) { echo $exception->getMessage(); } $channel->close(); $connection->close(); 有没有办法在特定时间后停止或超时消费者? 我想知道如果没有因为consume()方法阻塞而发生任何异常,进程如何到达上面代码中连接和通道的close()方法? 我发现有一个 basic_cancel 方法,但我不知道在哪里以及何时使用它,因为就像我说的,consume() 方法阻塞了代码。 回调函数可以执行$msg->getChannel()->stopConsume();。

回答 1 投票 0

如何使用 Spring XML 实现 x-consistency-hash-exchange

所有其他交换类型均在 http://www.springframework.org/schema/rabbit 模式中声明,但在其中找不到 x-consistency-hash-exchange。它是在哪里定义的? 我尝试实施一致...

回答 1 投票 0

如何配置 MassTransit 从 Azure 事件中心获取消息、在 RabbitMQ 中存储故障和/或错误消息并正确使用故障<T>

我是 MassTransit 的新手,目前我正确配置 MassTransit 以从 Azure 事件中心获取和使用类型“T”的消息,但无法查看/使用故障消息...

回答 1 投票 0

带有 RabbitMQ 和 Eventlet 的 Celery 无法与 Boto3 客户端和 Timestream 一起使用

我正在尝试将 Celery 与 RabbitMQ 和 Eventlet 一起使用来处理我的 Python 应用程序中的异步任务。我的任务之一涉及使用 Boto3 客户端将文件上传到 S3 存储桶。然而,...

回答 2 投票 0

使用 Mockito 和 JUnit 测试 RabbitTemplate#convertAndSend 作为 lambda

我正在尝试测试以 lambda 形式编写的 RabbitTemplate#convertAndSend 方法,如下所示: // 为了简洁起见省略了其他内容 rabbitTemplate.convertAndSend(myQueue, jsonString, 我...

回答 3 投票 0

代理重启后 Spring-AMQP 客户端无法恢复,空闲通道被卡住

所以我有两个微服务通过 RabbitMQ 进行通信,其中一个向另一个微服务发送 RPC 请求(使用 RabbitTemplate#sendAndReceive)。我注意到,如果

回答 1 投票 0

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