rabbitmq 相关问题

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

RabbitSubscribe 一次消费一条消息

我正在使用nestjs goleveluprabbitmq库,想知道是否可以使用RabbitSubscribe但一次只消费一条消息?目前它会在...之前收到多条消息

回答 1 投票 0

Spring Cloud Stream Rabbit Binder 动态组名称

使用Spring Cloud Stream时,我需要动态地将组值赋予绑定器,我该怎么做?

回答 1 投票 0

无法连接到rabbit mq

我正在编写一个用于连接到 RabbitMQ 的控制台应用程序,并将其作为 Docker 容器上的映像运行。 我的图像在端口 15672 上运行,当我浏览到 http://localhost:15672/#/ 时。我可以登录

回答 1 投票 0

Spring 无法为 RabbitMQ 自动装配 ConnectionFactory

我正在尝试遵循这个简单的 Spring RabbitMQ 消息传递指南。 我有两个关于自动装配的问题: 无法自动装配。未找到“ConnectionFactory”类型的 bean 无法自动装配。没有豆子...

回答 4 投票 0

RabbitMQ:通过一致的哈希交换扩展队列

(从 Github 问题中获取) 我们使用 RabbitMQ 的一致性哈希交换,这对于将路由键从交换器分片到多个队列非常有用。 我们利用队列向工人分发工作。

回答 1 投票 0

当一个微服务出现故障时如何处理

产品微服务出现故障,不返回值的情况如何处理? 异步 getStats(productId: string) { const 存在产品 = 等待firstValueFrom( ...

回答 1 投票 0

微服务中是否有队列系统的示例或设计?

我刚刚开始学习微服务和消息队列(rabbitmq),我了解一些交换,如 Direct、Topic、Fanout、Header 等。但我不清楚什么时候应该关闭之类的事情...

回答 1 投票 0

Celery 队列同时获取多条消息

我正在开发一个基于 docker、Celery 支持的 Python 应用程序,其中功能之一是触发并发送给定数字的文本消息。工作流程如下: 用户上传 CSV

回答 3 投票 0

如何使用 RabbitMQ 服务总线加过滤器实现 MassTransit 的请求/响应模式?

我正在使用 RabbitMQ 使用 IBusControl 对象和仅 1 个队列来实现 MassTransit 的请求/响应模式。 我们将运行 1 个请求发起者应用程序(当前是单元测试)并且

回答 1 投票 0

我正在尝试使用Log4j2的Rabbit Appender,但我的程序报告错误

我的Log4j2.xml 我的Log4j2.xml <Console name="STDOUT" target="SYSTEM_OUT"> <PatternLayout pattern="%d %-5p %C{2} - %m%n"/> </Console> <RabbitMQ name="rabbitmq" virtualHost="/" exchange="" exchangeType="direct" declareExchange="true" durable="true" autoDelete="false" host="127.0.0.1" port="5672" user="admin" password="1234" applicationId="myAppId" routingKeyPattern="%X{applicationId}.%c.%p" contentType="text/plain" contentEncoding="UTF-8" generateId="true" deliveryMode="NON_PERSISTENT" charset="UTF-8" senderPoolSize="3" maxSenderRetries="5"> <PatternLayout pattern="${LOG_PATTERN}"/> </RabbitMQ> 当我的程序启动时,我收到这样的错误 ERROR Error processing element RabbitMQ ([Appenders: null]): CLASS_NOT_FOUND ERROR Unable to locate appender "rabbitmq" for logger config "root" 我猜我可能缺少一些依赖项 希望有人能帮助我,谢谢 老兄,我遇到了几乎同样的问题,你解决了吗?

回答 1 投票 0

RabbitMQ - 将消息从经典队列消费到 MQTT 连接

我正在尝试使用 RabbitMQ 中的队列中的消息,该队列已设置并包含一些消息。我正在通过与 paho 库的连接来测试 MQTT 下标: 导入 paho.mqtt.cl...

回答 1 投票 0

如何在 RabbitMQ 上维护相同的内部主机?

我在本地服务器的虚拟机上运行 RabbitMQ(用于开发、测试和登台环境)。当电源不稳定时,服务器最终会重新启动,并且

回答 1 投票 0

通过karatedsl使用mongodb、redis和rabbit mq的最佳方式?

我有通过 kalatedsl 使用 mongodb、redis 和rabbitmq 的最佳方法吗?或者我必须为它们编写自己的java代码?

回答 1 投票 0

RabbitMQ 未连接到 Consumer

我们正在从事微服务工作。我们有将数据发送给第三方的功能 订单服务是创建订单并将订单数据发送到 RabbitMQ。那没问题 然后我们就有了任务服务...

回答 1 投票 0

如何检查rabbitMQ连接(健康检查)是否正常?

我正在使用 docker 运行 4 个微服务。这里一项服务依赖于其他服务。这就是为什么我需要在使用任何服务之前检查其他服务是否启动? 为了提高所有服务,我正在写......

回答 2 投票 0

将事件从发件箱附加到 Marten 并保证排序

我们目前正在研究如何将 Marten 实现为我们的整体应用程序的事件存储。为简单起见,场景范围如下: 一款整体式应用程序: 存储事件我...

回答 1 投票 0

使用 springboot 的 Rabbitmq RPC(请求-回复)

我想使用 RabbitMQ 实现微服务通信的请求-回复模式。然而,问题是每个内部调用都会创建一个新队列,并且默认情况下,队列大小在

回答 1 投票 0

同一个 Spring Boot 应用程序中的订阅者和生产者

我有一个正在运行的 RabbitMQ 服务器和两个 Spring Boot 应用程序。我们称之为 appA 和 appB appA每5m向queue1订阅一条消息。 appB 消耗queue1并进行一些数据转换和sh...

回答 1 投票 0

RabbitMQ 创建多个连接

这是生产者代码: 从“amqplib”导入*作为amqp; 导出默认类 Producer { 渠道; 异步创建频道(){ const 连接 = 等待 amqp.connect("...

回答 1 投票 0

Clickhouse / RabbitMQ

尝试创建 RabbitMQ 表时出现无法连接到 RabbiMQ 错误的任何想法 RabbitMQ 运行良好,并由 localhost:5672 上的 Spring Boot 微服务使用 Clickhous...

回答 1 投票 0

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