amqp

我在设置与远程 RabbitMQ 服务器的连接时遇到问题。 基本上我让消费者​​和服务器在远程 ubuntu 机器上运行，并希望我的本地机器充当发布者。我可以通过 ssh 访问远程机器。我已阅读以下内容的答案，似乎有可能 RabbitMQ on Amazon EC2 Instance & Locally? 但是当我尝试连接到远程主机时 connection = AMQP.connect... »

我正在使用 Ruby AMQP Carrot 库，并且正在尝试与虚拟机上的测试 RabbitMQ 服务器通信。机器上的 AMQP 端口已打开，但我无法让 Carrot 建立外部连接。我尝试了以下方法： Carrot.queue('message', :durable => true, :server => '192.168.162.176') Carrot.queue('message', :d... »

我在我的 Rabbitmq 服务器中使用自签名证书，并且代理使用 SSL 端口成功启动。我现在正在尝试更新/使用新的 SSL 证书、SSL 密钥和信任库，但我不想重新启动正在运行的 rabbitmq 服务器，因为我的应用程序应该连续运行。我在网上查看了在运行时刷新/重新加载 erlang/rabbitmq 以读取/重新加载这些新 SSL 证书的解决方案，我偶然发现了他们建议使用的几个链接 - ra... »

我有一个使用 AMQP 的后台作业处理系统。多个服务器正在使用同一队列中的作业。这些服务器中的每一个都运行 4 个工作进程。到目前为止一切顺利。 现在要处理的作业本身需要一些 IPC，为了保持一致，我再次使用 AMQP 队列（当然不同的队列）。这个想法是每个工人都将拥有它的 IPC 对应物，如下所示： / IPC queue \ Main ... »

我在 Spring 集成中使用了 Aggregator，还看到了 PriorityChannel。是否有可能以某种方式使用其中两个来实现以下要求： 从 RabbitMQ 接收消息并存储在具有聚合器的 spring 组件中 Aggregator 正在进行聚合，但同时它会根据一些复杂的排序算法优先发布消息。 随着时间的推移，队列中的消息优先级可能会发生变化，我们需要能够在某个时间点重新安排优先级。... »

我有一个使用 Spring Boot (1.5.12) 和 spring-boot-starter-amqp 在 Cloud Foundry 上运行的应用程序 基于之前对set heartbeat property on rabbitmq autoconfig connectionfactory bean 的SO 回答，我尝试如下设置心跳属性。 cf set-env app spring.ra... »

有没有办法从消费者那里获取消息放入队列时的时间戳。 不是发布的时候，而是它真正进入队列的时候。 除非我遗漏了什么，好像没有写一个rabbitmq插... »

我想知道是否有任何方法可以将消息返回到队列中的原始位置。例如，假设我们有这样的顺序： A-B-C-D A 是头部，D 是尾部。通常，当我们使用nack 或reject 和requeue=true 时，它只是将消息排入当前尾部之后。在这种情况下，当A 重新排队时，新的排序变为B-C-D-A。但是，我想知道是否有任何方法可以排入队列的开头。因此，如果 A 被“送回”，它将被放置在队列的开头，在它原来... »

[编辑] 上传完整的配置： rabbit.xml 从 rabbit 中出队 <rabbit:connection-factory id="amqpConnectionFactoryInbound" host="${rabbit.host}" port="${rabbit.port}" username="${rabbit.username}" password="${rabbit.pa... »

我编写了简单的示例来从控制台读取文本并将其发送到 rabbitMq 服务器： @Configuration @EnableIntegration @IntegrationComponentScan public class Config { @Autowired private AmqpTemplate amqpTemplate; @Bean public I... »

我目前正在开发一个使用 C# 作为业务层的 N 层应用程序。这是一种 ERP，我需要对此应用程序进行身份验证（电子邮件/密码）。 我还需要基于登录的权限（创建订单，删除文章） 所有这些信息都应该存储在一个数据库中。 作为 UI 客户端，我计划制作 WPF 客户端、ASP.Net 以及未来的 iPhone/Android。 作为消息代理，我使用 RabbitMQ（客户端仅通过 AMQP 与业务层对... »

我使用“github.com/streadway/amqp”通过队列（RabbitMQ）异步处理请求。 并且我使用“github.com/gorilla/rpc”注册我的服务而没有解决方法，但我必须使用丑陋的解决方案将 amqp.Delivery 转换为 http.Request（mux.Server 只能与 http.Request 一起使用） . 我可以为这项任务使用更优雅的解决方案吗？ ... »

我无法通过 kaazing javascript AMPQ 库发送发布消息。下面的代码非常适合 FANOUT 交换，但不适用于 DIRECT 交换。我能够连接但无法将消息发布到 DIRECT 交换。 function amqpTest(){ load(); var $ = function(s) { return document.getElementById(s); }; var conso... »

假设我喜欢我的 rabbitmq 队列上的 100000 个事件，限制系统串联处理它们而不是尝试一次消耗所有事件的最佳方法是什么？ 我正在尝试几个选项，但是，机器在尝试一次处理所有选项时冻结。... »

我正在使用： RabbitMQ 3.5.1 Java RabbitMQ 客户端 具有两个 RabbitMQ 实例的集群 我有一个队列： 耐用=假 独占=假 自动删除=true 队列镜像不影响结果 在我的应用程序中，有一个异步消费者通过回调接收消息。 当我尝试通过禁用与​​代理的网络通信来模拟连接失败时，就会出现问题。重新建立连接后，队列（在 Web 管理界面中）显示两个消费者使用相同的... »

我尝试在我的 java 代码中使用带有注释的死信交换。也许我的假设是错误的，它应该如何工作。但是在我的方法 processMpcMessage 中，我将消息从队列反序列化为 POJO。如果我收到 IllegalargumentException，我希望将消息放入死信队列。我配置了死信交换和路由键，请参阅我的代码示例。 如果我抛出“throw new AmqpRejectAndDontRequeue... »

我的实际代码中有以下代码 sn-p。我有多个消费者在听队列。 @RabbitListener private void abc(ETLConfigDTO config){ try{ log.info("load started"); loadService.loadData(config); } catch(Exception e){ log.error("L... »

我正在使用 NestJS 应用程序来使用 RabbitMQ 队列。 无论顺序如何，每条消息都可以被处理，所以我想知道为同一个队列声明新消费者的最佳做法是什么。 预期行为：队列由该服务处理，该服务使用多个消费者 队列：[1,2,3,4,5,6, ...N]; 在nestJS 中，您可以使用@RabbitSubscribe 装饰器分配一个函数来处理数据。我想做的事情可以通过简单地用装饰器复制（和重... »

我正在尝试在 ActiveMQ (5.13) 中找到一个选项，该选项允许我为代理配置来自一个客户端的最大数量的 amqp 连接。目标是防止一个恶意或故障客户端消耗代理上所有可用的连接，从而阻止其他客户端连接。 我知道在 transportConnector 上设置 maximumConnections 的可能性，但是，只要我理解正确，这是对所有连接的全局限制，因此在这种情况下没有帮助。 我对... »

我正在寻找一种从我的 django 应用程序向 rabbitmq 服务器发布消息的方法。这不是用于任务卸载，所以我不想使用 Celery。目的是使用 django 应用程序发布到交易所，并在 docker 容器中使用该队列中的姐妹（非 django）应用程序。 这一切看起来都非常简单，但是，我似乎无法在每次不建立和关闭连接的情况下发布到交易所，即使没有明确要求这样做。 为了解决这个问题，我定义... »