amqp 相关问题

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

Spring Boot RabbitMQ 尝试反序列化未经授权的类异常

我在 Spring Boot 项目中使用 RabbitMQ: 发件人 @成分 @AllArgsConstructor 公共类 UserSender { 私人最终 RabbitTemplaterabbitTemplate; 公共字符串发送(){ 用户你...

回答 1 投票 0

SpringBoot RabbitMQ 尝试反序列化未授权类异常

我在Springboot项目中使用RabbitMQ: 发件人 @成分 @AllArgsConstructor 公共类 UserSender { 私人最终 RabbitTemplaterabbitTemplate; 公共字符串发送(){ 使用我们...

回答 1 投票 0

RMQ - “配置对队列的访问被拒绝”,只读用户附加到队列(AMQP 1.0)

尝试使用 RabbitMQ 中的 AMQP 1.0 插件使用现有队列时,出现错误:“ACCESS_REFUSED - 配置对用户队列‘xxx’的访问被拒绝”。 用户具有只读权限

回答 1 投票 0

如何使用 AMQP/Node 处理每秒 >100 条消息

我们目前正在设计一个微服务(Node v8.3.0)原型,该服务每秒必须消耗 RabbitMQ 大约 60-150 条消息(RabbitMQ 3.6.12、Erlang 19.2.1)。有时它就像一种魅力和...

回答 1 投票 0

列出绑定到 RabbitMQ 中交换器的所有队列

我在javascript和node.js中使用amqllib 我想列出绑定到特定交换的所有队列。 最好的做法是什么?

回答 1 投票 0

如何一次只处理一条给定类型的消息?

我有多个生产者,它们产生处理组件的请求。这些组件有很多,每一个组件的处理都需要大量时间。 问题是有...

回答 2 投票 0

rabbitmq createConnection 抛出错误 [错误:连接结束:可能是由于身份验证失败。]

嗨,我尝试使用node.js 连接rabbitmq 但出现错误。 [错误:连接结束:可能是由于身份验证失败。] var MessageQueue = AMQP.createConnection({'host' =&g...

回答 2 投票 0

使用 NTLM 进行 RabbitMQ 身份验证(无密码)

我已经配置了 RabbitMQ,但目前它使用简单的用户名/密码连接到队列。这并不理想,因为我必须将密码存储在应用程序配置中。 理想情况下,我

回答 1 投票 0

读取交换的所有标头而不传输有效负载

我想根据标头信息(主要是路由密钥,但最好还有其他标头)生成一个交换上的按摩流量的统计信息。由于涉及的带宽很大,我会

回答 1 投票 0

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

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.