amqp 相关问题

AMQP是一种开放式消息传递标准。它为高性能企业消息传递定义了线级协议和语义框架。如果您正在使用特定代理(例如:[rabbitmq]),则AMQP标记可能是多余的。 AMQP不应与Apache [ActiveMQ]混淆

RabbitMQ 交替交换和交换到交换绑定

RabbitMQ v3.7.8 (AE = 交替交换) 文档指出: 每当与已配置 AE 的交换无法将消息路由到 任何队列,它都会将消息发布到指定的AE

回答 1 投票 0

客户端的单独队列是仅向他们发送消息的好方法吗?

我有一个系统,客户端从队列中提取任务(通过 amqp,使用 RabbitMQ 作为消息服务器)。当一个新客户端产生时,他会拉取一个任务,告诉主服务器他是ch中的那个......

回答 1 投票 0

RabbitMQ DefaultConsumer 导致消费者标签过多

我有一个 RabbitMQ 客户端应用程序,用于侦听特定队列。客户端创建DefaultConsumer的实例并实现handleDelivery方法。这是代码 受保护

回答 3 投票 0

RabbitMQ中的PublisherConfirm模式和事务有什么区别?

我觉得publisher的confirm模式和transaction都需要broker确认消息的接收,那为什么publisher的confirm模式被认为是轻量级的操作,有更好的效果

回答 1 投票 0

是否可以使用 RabbitMQ .NET 客户端查看队列中所有活动消费者的名称/标签?

我正在创建一个 .NET 应用程序,该应用程序将从我的应用程序未创建或维护的多个第三方队列中使用,我希望每个队列有一个消费者

回答 1 投票 0

RabbitMQ:basic_ack也需要服务器确认吗?

假设我使用“confirm.select”将通道置于确认模式,并将确认模式设置为手动,然后我执行以下操作(伪代码): 函数 msg_handler(msg: TheDelivery, chan:

回答 1 投票 0

Pika Amqps 连接:连接尝试已完成,AMQPConnectorAMQPHandshakeError:不兼容协议错误

我正在尝试使用 pika 连接到 AMQPS 服务(我没有配置访问权限或获取证书的方法)。 这是代码: 进口鼠兔 从 urllib.parse 导入 urlparse 导入SSL

回答 2 投票 0

消息优先级在消息队列系统中本质上不重要吗?

我看过的大多数消息系统似乎都对优先级消息队列有基本的(如果有的话)支持。例如,AMQP 只指定最少 2 个优先级。 RabbitMQ,一个 AMQP

回答 4 投票 0

Heroku 的 AMQP 将如何工作?

我看到他们很快就会有 AMQP 的插件。 我即将学习如何将 AMQP 与 RabbitMQ 结合使用。我认为该插件不处理 RabbitMQ。 AMQP 不只是一个协议吗?他们在使用...

回答 1 投票 0

使用 Java 通过 AMQP 1.0 连接到 ActiveMQ Artemis

我正在尝试使用 Java 通过 AMQP 1.0 连接到 ActiveMQ Artemis,但到目前为止我还很不成功。我尝试了以下客户端框架: org.apache.qpid:qpid-客户端 org.apache.qpid:质子-...

回答 1 投票 0

Rabbitmq集群,当节点离线时,如何保证离线队列收到来自扇出交换机的消息?

我有三个节点集群,两个队列绑定到一个扇出交换机。我的要求是所有发送到exchange的消息都必须保存到这两个队列中,所有消息不能丢失并且m...

回答 1 投票 0

AMQPNETLITE - ActiveMQ Artemis (Red Hat AMQ) - 自动创建多消费者多播队列

这个问题是关于在.Net 中使用 AMQP 消费消息。文档推荐 amqpnetlite:https://access.redhat.com/documentation/en-us/red_hat_amq/7.0/html-single/using_the_amq_。

回答 1 投票 0

Camel Spring 使用 ActiveMQ Artemis Proton/Qpid 客户端进行远程处理 - 挂起发送消息

当我使用Camel Spring远程处理配置发送一些消息时,生产者和消费者都在不同的JVM中运行。 使用 Apache ActiveMQ Artemis 2.14.0 版本 骆驼版本...

回答 1 投票 0

RabbitMq 选择协议时应该注意什么

我尝试深入研究 Java 中的消息传递。我正在研究 RabbitMq 和 AMQP 协议。首先,我重复了 https://spring.io/guides/gs/messaging-rabbitmq/ 中的几个示例以及...

回答 3 投票 0

使用用户名和密码通过 AMQP 发布到 Azure 服务总线主题

我正在处理一个在 .Net 中实现的系统,该系统使用 AMPQ 使用用户名和密码以及主机、端口和协议将消息发布到 Active MQ Artemis 实例。 amqps://访客:访客...

回答 1 投票 0

尝试使用 Celery+RabbitMQ 设置优先级队列时出现“PreconditionFailed - 队列的不等价参数‘x-max-priority’”错误

我有 RabbitMQ 设置,有两个队列:低和高。我希望我的芹菜工作人员在消耗低优先级队列的任务之前先消耗高优先级队列的任务。我得到以下信息...

回答 1 投票 0

AMQP 将消息插入 Rabbit MQ

我正在尝试使用主机、端口、用户、通行证、交换队列、队列名称和路由密钥将消息插入 Rabbit MQ 在此输入图像描述 出现这些错误- ForgivingExceptionHandler:一个

回答 1 投票 0

使用 AMQPNetLite.Core 2.4.6 的消息组和独占消费者

我正在尝试使用 ActiveMQ Artemis 的消息组 (https://activemq.apache.org/message-groups) 和 Exclusive Consumer (https://activemq.apache.org/exclusive-consumer) 功能.NET

回答 1 投票 0

PHP AMQP 消费者一段时间后没有响应

我的 php amqp 消费者遇到了一个小问题,它在一段时间后停止工作。下面你可以看到我的 silex 命令。我还尝试使用心跳和保活配置来处理损坏的

回答 2 投票 0

RabbitMQ basic.get 和确认

我正在调用: GetResponse 响应 =channel.basicGet("some.queue", false); // 没有自动确认 .... 通道.basicAck(deliveryTag, ...); 但是,当我调用 basicGet 时,队列中的消息会保留...

回答 3 投票 0

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