rabbitmq 相关问题

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

Rabbitmq 文件描述符限制

Rabbitmq 文档说我们需要在生产中使用它之前进行一些配置。其中一项配置是关于最大打开文件数(这是操作系统参数)。 Rabbitmq 系列...

回答 3 投票 0

从 MassTransit 消费者访问 RabbitMQ 消息头

有没有办法从 RabbitMQ 获取消息标头(与通过 MassTransit 设置的标头不同)? 我的用例是,我正在尝试读取 RabbitMQ 添加的时间戳,timestamp_in_ms (

回答 1 投票 0

用于批量插入的缓冲数据

每次在我的网站上发出请求时,有关该事件的一些数据都会记录到数据库(Yandex ClickHouse)中。如果插入的大小是大块的,ClickHouse 的工作速度会显着加快...

回答 5 投票 0

Docker Compose 设置:发布者无法连接到 RabbitMQ

我正在开发一个项目,该项目使用 Docker Compose 来编排多容器设置,其中涉及 RabbitMQ、PostgreSQL 和两个 .NET 服务:发布者和订阅者。目标是拥有...

回答 1 投票 0

从 AWS Lambda 发送 RabbitMQ 消息

知道为什么 AWS Lambda 函数无法使用 amqp 协议向 RabbitMQ 发布消息吗? (我将node.js运行时与node amqplib运行时一起使用) 当使用我本地的代码时

回答 2 投票 0

异步发布忽略错误和超时

我有一个 Spring Boot 应用程序,它通过 RabbitMq 发送控制器每个查询的响应统计信息。当 RabbitMq 服务器可访问并接受消息时,它会起作用。 然而,这个p...

回答 1 投票 0

如何用Java读取RabbitMQ的头部?

我想从之前设置的消息标题中读取一些属性。我这样做了: 送货送货 = Consumer.nextDelivery(); 地图标题=交付。

回答 4 投票 0

Spring Camel 集成测试因超时消息而变慢

从RabbitMQ切换到Spring RabbitMQ后,maven故障安全测试变得更慢,有多个消息 o.a.c.i.engine.DefaultShutdownStrategy :优雅期间发生超时

回答 1 投票 0

如何配置 Celery 作为 systemd 服务与 Gunicorn 提供的 Django 应用程序一起运行?

我遵循了 Celery 官方文档,了解如何配置 Celery 以与 Django (python 3) 和 RabbitMQ 一起使用。我已经有一个 systemd 服务来使用 Gun 启动我的 Django 应用程序...

回答 1 投票 0

仲裁队列过滤?

有没有办法像流一样过滤仲裁队列中的消息? 考虑的用例是应用程序 A 通过 RabbitMQ 向应用程序 B 发送请求消息。然后它会监听

回答 1 投票 0

rabbitMQ 中的 Ack 或 Nack

我正在使用rabbitMQ,我使用basic_get从队列中获取每条消息,而没有自动确认过程,这意味着消息保留在队列中,直到我确认或确认消息。 有时我也有

回答 3 投票 0

在Symfony Messenger组件中绑定exchange到exchange

是否可以在 Symfony 消息组件中定义交换之间的绑定? (此处为 4.4 版本)。 我知道可以将交换绑定到队列,如下所示: 运输: 传入: ...

回答 1 投票 0

RabbitMQ IO 线程

我正在阅读 RabbitMq.Client 库的 .net 文档(https://www.rabbitmq.com/tutorials/tutorial-seven-dotnet)并到达这部分 var 通道 = 连接.CreateModel(); 频道。

回答 1 投票 0

RabbitMQ 获取标头值(例如 x-death)

我在使用 RabbitMQ 总线时遇到了问题。 我正在尝试从消费者事件处理程序中的 BasicDeliverEventArgs.BasicProperties.Headers 对象(标头字典)获取数据

回答 1 投票 0

RabbitMQ - 如何连接安装在其他服务器(PC)上的RabbitMQ

我想连接安装在我们另一台主机上的RabbitMQ服务器[IP - 192.168.0.115]。它在“localhost:15672”上本地运行,我尝试使用我的 C# 代码进行连接。 ...

回答 1 投票 0

Spring AMQP 和刷新范围 bean

我正在使用 spring-boot-starter-parent 3.2.3 中的 spring-amqp。 我有以下配置: @豆 @RefreshScope 公共 ConnectionFactory 连接工厂() { 缓存连接工厂

回答 1 投票 0

Docker RabbitMQ 持久性

docker 中的 RabbitMQ 在删除没有卷的容器后丢失数据。 我的 Dockerfile: 来自rabbitmq:3-管理 ENV RABBITMQ_HIPE_COMPILE 1 ENV RABBITMQ_ERLANG_COOKIE“123456” 环境

回答 2 投票 0

迁移到仲裁队列。自动删除仲裁队列

在我们的系统架构中,应用程序独立于实时事件检索其初始状态。为了实现这一点,我们利用 RabbitMQ 独有的自动删除经典队列与服务器 -

回答 1 投票 0

Rabbit MQ:迁移到仲裁队列。自动删除仲裁队列

在我们的系统架构中,应用程序独立于实时事件检索其初始状态。为了实现这一点,我们利用 RabbitMQ 独有的自动删除经典队列与服务器 -

回答 1 投票 0

带和不带x-queue-type的经典队列有什么区别:RabbitMQ中的经典

当使用默认选项在 RabbitMQ UI 中创建队列时,它会在功能列 D 中显示为持久,参数为 x-queue-type: classic。 当通过代码创建它时,您可以像这样创建...

回答 1 投票 0

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