amqp相关内容

RabbitMQ 3.1.3和缺少的时间戳头

是否可以配置代理以在消息中缺少时间戳头时插入它？因此，如果发布客户端未添加时间戳标头，则代理是否可以将其插入与交易所收到消息的那一刻匹配的时间戳值？我应该在哪里寻找该配置？还是一个坏主意？ 解决方案 要回答您的问题，没有办法配置代理插入时间戳。 AMQP规范中的任何内容都不需要消息知道消息何时到达代理，并且请记住，在代理端手动插入时间戳仅表示代理何时接收消息，而不是消息何时发布。 如 ..
发布时间：2020-06-07 18:41:40 其他开发

无法识别运输方案：[amqp]

我正在尝试将AMQP与ActiveMQ结合使用并遇到以下错误 未识别出传输方案：[amqp] 这是我的代码 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory（ “ amqp：// localhost：61616”）; 连接连接= null; 试试{ connection ..
发布时间：2020-06-01 19:20:29 Java开发

无法使用Node.js连接到Apache ActiveMQ

背景 尝试通过 amqp10 。我正在使用以下代码（改编自述文件中的原始示例）： const AMQPClient = require（“ amqp10”） 。客户; const Promise = require（“ bluebird”）; //从以下位置修复：https：//github.com/noodlefrenzy/node-amqp10/issues/241 ..
发布时间：2020-06-01 19:13:06 其他开发

等待一个RabbitMQ消息超时

我想向RabbitMQ服务器发送一条消息，然后等待答复消息（在“答复”队列中）。当然，我不想永远等待，以防处理这些消息的应用程序关闭-需要超时。听起来这是一项非常基本的任务，但我找不到解决方法。我现在同时遇到 py-amqplib 和 RabbitMQ .NET客户端。 我最好的解决方案到目前为止，已经使用 basic_get 和 sleep 进行了轮询，但这很丑陋： def _wa ..
发布时间：2020-05-30 20:05:37 C#/.NET

用于RabbitMQ的REST API

有没有办法将数据从$ .ajax发送到RabbitMQ？ 我的应用程序由数千个Web客户端（用js编写）组成和WCF REST服务，现在我想弄清楚如何为我的应用程序创建可扩展点。这个想法是要有一个Rabbitmq实例来接收来自放置在一侧的js客户端的消息，以及一个WCF Workflow Services实例，该实例正在从队列中接收挂起的消息。 I知道AMQP和HTTP是完全不同的东西 ..
发布时间：2020-05-30 19:52:40 C#/.NET

如何延误? -php-amqplib

我想知道如何延迟使用Amqpphplib. 我使用了这个很棒的咖啡脚本教程: https://github.com/jamescarr/rabbitmq-scheduled-delivery 但它似乎不适用于PHP-amqplib. 该消息按照我的意愿过期，但是似乎"x-dead-letter-exchange"无法完成工作.我使用RabbitMQ管理控制台，可以实时查看所 ..
发布时间：2020-05-27 02:53:48 PHP

消费未确认的RabbitMq消息

我创建了一个简单的发布者和一个使用basic.consume在队列上进行订阅的使用者. 我的使用者在作业正常运行时会确认消息.每当遇到异常时，我都不会确认该消息并提早返回.仅已确认的消息从队列中消失，因此可以正常工作. 现在，我希望使用者重新获取失败的消息，但是重新使用这些消息的唯一方法是重新启动使用者. 我该如何处理这个用例? 设置代码 $channel = new A ..
发布时间：2020-05-27 02:33:56 PHP

PHP致命错误:找不到类"AMQPConnection"

我已经看过这个问题.这表明未安装AMQP PECL扩展.但是，我已经成功安装了RabbitMQ和内置的PECL AMQP扩展.以下是phpinfo()的输出. 您可以清楚地看到，AMQP已正确加载.但是，当我尝试建立连接时，它显示 PHP致命错误:找不到类'AMQPConnection'.下面是代码. $connection = new AMQPConnection(); 这是输出 ..
发布时间：2020-05-27 02:04:01 PHP

RabbitMQ春季启动会话错误

尝试将RabbitMQ队列消息传递到我的Spring Boot应用程序时遇到问题.我正在运行spring data 4，并且正在使用Neo4j作为数据库.我能够从RabbitMQ队列接收并解析JSON字符串到Spring Boot应用程序.这是接收器进程的线程更改: 14:19:17.811 [main] INFO o.s.b.c.e.t.TomcatEmbeddedServletConta ..
发布时间：2020-05-17 00:24:32 其他开发

在多租户系统中，如何在RabbitMQ中将队列设置为私有/安全?

我已经阅读了RabbitMQ提供的入门指南，甚至将第六个示例贡献给了 stormed-amqp ，所以我对知识有所了解关于AMQP. 但是，该指南并不全面，避免了身份验证和授权之类的问题. 我们正在设计一个多租户系统，该系统将在RPC类型的情况下使用RabbitMQ. RPC实现的不同之处可能在于，远程过程实际上将是系统上的其他租户程序. 基本上，我想隔离数据总线，其中包括以下断 ..
发布时间：2020-05-13 20:25:02 其他开发

微服务，amqp和服务注册表/发现

我正在研究微服务架构，实际上我在想什么. 我可以使用(反向)服务发现使请求能够在基于REST的微服务上运行，这一点我还可以.我需要知道在哪里进行服务(或至少在服务器群集的前端)来发出请求.因此，在这种情况下能够发现ip:port是有意义的. 但是我想知道在处理AMQP(仅基于基础，没有HTTP可能的调用)时使用服务注册表/发现的目的是什么? 我的意思是，使用AMQP就像“我需要它 ..
发布时间：2020-05-09 19:57:05 其他开发

AMQP如何克服直接使用TCP的困难?

AMQP如何克服发送消息时直接使用TCP的困难?或更具体地说是在发布/订阅方案中? 解决方案 在AMQP中，有一个代理，该代理接收消息，然后对将消息路由到交换和队列进行艰苦的工作.您还可以设置持久队列，即使客户端断开连接也可以为客户端保存消息. 您当然可以自己做所有这一切，但是正确地做是大量的工作.特别是RabbitMQ已经在许多部署中经过了实战测试. 您仍然在AMQP下使用T ..
发布时间：2020-05-09 01:36:02 其他开发

来自PHP的同步AMQP

PHP是否可以将AMQP视为RPC服务，并发送消息并阻塞直到返回答复?有没有很好的例子，是否有任何库都以易于使用的方式包装了这些功能? 我希望具有代理消息传递系统的灵活性，但可以保护Web层免于需要了解其异步特性. 解决方案 当然可以.查看RPC样式的请求如何在系统中流动: 发出请求 请求者现在阻止等待对该请求的答复 这完全可以通过AMQP之类的异步消息系统实现.您只需 ..
发布时间：2020-05-09 01:35:50 PHP

是否需要使用尽可能少的队列以及用于Web消息传递的解决方案

我在论坛上读到，在使用AMQP实施任何应用程序时，必须使用更少的队列.因此，如果我要克隆Twitter，我将为每个注册用户提供一个唯一且持久的队列，那我完全错误吗?似乎是最自然的方法，如果没有为每个用户分配一个唯一的队列，那么如何设计这样的东西. 什么是最常用的Web消息传递方法.我看到RabbitHUb和Rabbit WebHooks，但是Webhooks似乎不是可扩展的解决方案.我正在使 ..
发布时间：2020-05-09 01:35:16 其他开发

RabbitMQ/AMQP中的消息组

ActiveMQ/JMS具有内置的机制，可确保在使用竞争使用者模式时，队列的相同使用者始终使用共享同一标头(即JMSXGroupID标头)的消息.队列的使用者完全不了解实际的标头值，因为具有公共标头的消息保证是在服务器端而不是在使用者端执行的.有关其工作原理的更多详细信息，请参见 http://activemq.apache.org/message-groups. html . 使用AMQP ..
发布时间：2020-05-09 01:33:55 其他开发

AMQP 0-9-1和1-0

我正在寻找一个新项目的消息传递服务，该项目必须将某些C#应用程序与某些Java应用程序接口.我真的很喜欢RabbitMQ，因为它似乎对这两种技术都提供了惊人的支持.我在RabbitMQ规范中看到，目前仅提供了AMQP 0-9-1模型. 那是演出的制胜者吗?我是否应该解决提供AMQP 1.0的ActiveMQ? 感谢您的建议 解决方案 您的问题已在官方协议概述: AMQP ..
发布时间：2020-05-09 01:33:44 其他开发

为什么要使用AMQP/ZeroMQ/RabbitMQ

与编写自己的库相反. 我们正在这里的一个项目中进行工作，该项目将是一个自划分服务器池，如果其中一个区域变得太重，经理将对其进行划分并将其作为单独的进程放置在另一台计算机上.它还会警告所有连接的客户端，这会影响到新服务器的连接. 我很好奇将ZeroMQ用于服务器间和进程间通信.我的伴侣更愿意自己动手​​.我希望社区能够回答这个问题. 我本人是一个相当新手的程序员，刚刚了解了消息队列 ..
发布时间：2020-05-09 01:33:09 其他开发

RabbitMQ/AMQP:单个队列，同一条消息的多个使用者?

我一般才开始使用RabbitMQ和AMQP. 我有一条消息队列 我有多个消费者，我想用相同的消息来做不同的事情. RabbitMQ的大多数文档似乎都集中在循环上，即单个消息由单个使用者使用，而负载则在每个使用者之间分散.这确实是我目睹的行为. 一个例子:生产者只有一个队列，每2秒发送一次消息: var amqp = require('amqp'); var connect ..
发布时间：2020-05-09 01:32:27 其他开发

RabbitMQ —为什么在使用主题交换时忽略我的路由键

我正在使用RabbitMQ来协调一组服务之间的事件，如下所示: 用户管理器 希望从单独的服务中收集用户数据时发出user.collect 收听由单独服务发出的user.collected 用户收集器 在应该收集某些用户数据时监听user.collect，并且 在收集数据时会发出user.collected. 还有其他服务可以监听事件，例如 user.crea ..
发布时间：2020-05-09 01:30:44 其他开发