RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。
我围绕 RabbitMQ 编写了一个快速包装器,但很难发布超过 1 条消息? 如果我有一批 1,000 条消息需要随机添加,我会使用 PublishBatch,它只是...
如何在没有 Web 端点的情况下为 Spring Boot 应用程序设置监控
我在 Spring Boot 上有多个服务。其中之一是其他服务的网关。网关具有带有控制器和端点的 Web 实现。当客户端向网关发出请求时,网关
RabbitMQ:多个队列的 1 个交换 - 仅在订阅者中创建队列?
我已经阅读了 RabbitMQ 教程并阅读了几篇文章,但我仍然不清楚发布到交换和创建交换的最佳实践是什么。 我的用例...
RabbitMq 消费者不工作,因为 micronaut 将执行线程分配给 kafka 消费者
我在 Kotlin 的 micronaut v3.4.3 中运行 kafka,最近我使用 micronaut-rabbitmq v3.4.0 将 RabbitMq 与服务器集成。在文档中提到指定 Rab 的执行者......
我不知道 https://www.rabbitmq.com/access-control.html#authorisation 中描述的基于 RabbitMQs regEx 的授权有多强大或多不强大。 我想做的是创建一个用户...
Camel RabbitMQ 3.22.0 版本未正确评估 QueueType
我一直在使用带有队列 Arg ( x-queue-type) 的 camel-rabbitmq 组件在 RabbitMQDeclareSupport 类(第 106 行)-> 对象 queueType = queueArgs.get(
我想尝试使用 MassTransit 的 RabbitMQ Streams。 目标是仅为队列的子集定义配置。 当消费者是
NodeJS amqplib:与 RabbitMQ 的连接有效,但无法从浏览器控制台看到任何连接/通道/队列信息
我是RabbitMQ的新手,我想这应该是一个简单的问题,但我已经被困在这个问题上很长一段时间了。 我正在运行这个 rabbitMQ docker 容器: 版本:'3' 服务: 兔子:
无法使用 amqp-client-5.16.0.jar 在 AnyLogic 8.5.2 中创建示例“hello world” 尝试运行时: ConnectionFactory factory = new ConnectionFactory(); 连接连接=工厂。
我正在尝试创建一个新的 rabbitmq 流,我的 rabbitmq 安装在 docker 中。 下面是我实施的步骤。 在 TCP 端口 5672 下的 docker 中安装了 RabbitMQ 启用兔子
MassTransit:在 Saga 状态机中取消的正确方法
我有一个关于取消使用 RabbitMQ 的 Saga 状态机实例的问题。我有这种情况: 我有一个公开端点的 API,该端点(当被击中时)发布初始消息...
为什么使用 Pika RabbitMQ,消费者在长时间空闲时会默默地断开队列?
在我的公司,我们目前正面临使用 rabbitMQ 的奇怪行为。我们托管在 Kubernetes 集群中的微服务之一是用 Python 构建的(其他的是用 Java 构建的,它们没有显示这个问题......
RabbitMQ - 在使用参数'x-expires'删除队列后将消息转发到另一个队列
我对 rabbitMQ 配置有疑问。我想在 RabbitListener(失去网络连接或有人关闭应用程序)关闭后 20 分钟将所有消息从队列转发到另一个队列。 ...
RabbitMQ ssl 连接失败并出现错误“因原因崩溃:amqp_direct_connection:ssl_info/1 中没有匹配 false 的 case 子句”
我已经全新安装了 RabbitMQ 3.8.3。我想通过 SSL 和 MQTT 协议连接到它。我的活动插件是: rabbitmq_management rabbitmq_web_dispatch rabbitmq_auth_mechanism_ssl
Celery 是否适合我们的用例,我有点困惑。 我们有数以千计的网络设备,我们可以在这些设备上获取/发送信息。这些操作可能非常耗时,因此芹菜。 我们有 X ...
@RabbitListener 抛出 java.lang.IllegalArgumentException:需要交换名称;绑定队列 xxx
我尝试使用@RabbitListener 自动创建和绑定交换和队列,但它抛出异常。 2023-02-19 16:56:58.040 错误 23348 --- [主要] o.s.boot.SpringApplication ...
RabbitMQ支持两种分布式协议,一种是“镜像队列”,另一种是“仲裁队列”。 我如何找到它在 RabbitMQ 中使用的分布式协议? 我可以得到它...
我的 Mac 上的 RabbitMQ for Node.js 出现错误
我正在使用 javascript 跟随 rabbitMQ 的“hello world”教程,但我遇到了一个我不明白的错误 当我使用节点运行我的 send.js 文件时,出现此错误: ...
使用RabbitMQ作为代理,我想将所有消息从一个队列复制到另一个队列,以便进行testdebug。通过RabbitMQ Web管理控制台Cli,最简单的方法是什么?P.S. 在...
如何在 Node.js 中构建一个类来抽象 RabbitMQ 和 amqplib 功能?
我正试图构建一个小库,以抽象一些与RabbitMQ通信所需的amqplib锅炉模板。我使用的是 promises api 和 asyncawait 语法。我正试图构建...