是否有一个具有稳定C ++客户端库的AMQP实现
是否有一个具有稳定C ++客户端库的AMQP实现 解决方案 Apache Qpid具有稳定的C ++客户端库-请参见 qpid.apache.org .
..
amqp相关内容
何时通过扇出交换使用直接交换
据我所知，没有直接交换的适当用户案例，因为您可以使用扇出交换进行任何操作，只能扩展得多. 更具体地说，在阅读《 RabbitMQ in Action》 时，作者多次提到用例，例如:“假设用户上传图片时需要生成缩略图.但是随后的营销也告诉您奖励上传照片的积分.使用RabbitMQ，您只需创建另一个队列即可，而制作人方面则无需任何工作！" 但是，如果您具有远见卓识，可以在生产者端创建一个扇
..
使用HTTP API发布到默认RabbitMQ交换
因此，我正在使用rabbitmqs http api在rabbit中执行一些非常基本的操作.它在大多数情况下都很好用，但是我在弄清楚如何使用它将消息发布到默认的rabbitmq交换时遇到了问题.此交换始终存在，不能删除，并且具有与每个队列名称相同的路由密钥的每个队列绑定. 我的问题是此队列没有名称，或者，它的名称是空字符串“".我必须使用URL来通过HTTP api发布此消息，其中包括交换的
..
HAProxy关闭长寿命的TCP连接，而忽略TCP keepalive
我已经配置了HAProxy(1.5.4，但我也尝试了1.5.14)，以在TCP模式下平衡两个服务器在5672端口上公开的AMQP协议(WSO2消息代理). 客户端通过HAProxy创建并使用与AMQP服务器的永久连接. 我更改了客户端和服务器的TCP keepalive超时，设置为net.ipv4.tcp_keepalive_time = 120(CentOS 7). 在HAProxy
..
芹菜有效，但带花不起作用
我已经安装了芹菜，RabitMQ和鲜花.我能够浏览到花港.我有以下简单的工作程序，可以将其附加到celery并从python程序调用: # -*- coding: utf-8 -*- """ Created on Sat Dec 12 16:37:33 2015 @author: idf """ from celery import Celery app = Celery('tasks
..
什么是实现循环队列的排队机制?
我有多个任务生产者，它们将工作添加到队列中.我也有多个消耗该队列的使用者.由于这些队列是FIFO，因此以添加队列的相同顺序出队. 在我的场景中，任务从HTTP请求添加到队列中.每个任务都与一个帐户关联，并且没有速率限制.因此，有可能使一个帐户中的任务泛滥到消息队列中. 为了解决这个问题，我一直在寻找一个队列实现，该队列实现允许我以循环方式从多个帐户处理排队的任务，以保持公平. 我
..
相关性和RPC模型中的临时队列-AMQP
我正在使用RabbitMQ在AMQP中阅读 RPC模型.本教程将创建一个临时队列以及correlationId.临时队列是唯一的，那么为什么我们需要correlationId?我是JMS的人，在JMS中，我们通过两种方式进行请求/响应: 为每个请求/响应创建临时队列 创建一个响应队列，并使用correlationId和消息选择器. 有人可以解释为什么在AMQP RPC模型中我们既
..
Rails应用程序中的AMQP订户
是否可以通过我的Rails应用启动AMQP订户?可能通过初始化程序之类的东西. 我想让它同时运行，并且还可以与Rails模型进行交互.下面是我的意思的伪代码示例. queue.subscribe do |msg,body| Foo.create(....) end 解决方案 我通常通过加载Rails环境的单独消息传递守护程序来做到这一点. 因此，在rails_root/
..
什么是“交付模式"?在AMQP中?
我了解有2种选择: “非持久" “持久" 但这实际上是什么意思? “非持久性"，如:如果没有使用者，则AMQP结构将尝试传递消息，该消息将被丢弃吗? “持久性"，如:AMQP将重试该消息，直到消费者接受为止? 解决方案 传递给“持久"队列的标记为“持久"的消息将记录到磁盘.如果发生崩溃，则会恢复持久队列以及崩溃之前存储的所有持久性消息.
..
RabbitMQ的工作池和多租户队列
我在一个基于多租户云应用程序的Web应用程序上工作(很多客户端，每个客户端都有自己单独的“环境"，但是全部在共享的硬件集上)，我们正在为用户介绍该功能分批处理工作以备后用.批处理工作的类型实际上并不重要，只是数量足够大，以至于没有工作队列就不实际.我们选择RabbitMQ作为我们的基础队列框架. 因为我们是一个多租户应用程序，所以我们不一定希望客户端能够导致另一个客户端的冗长的队列处理时间，
..
通过PECL安装AMQP
我正在尝试安装 RabbitMQ PECL扩展，但是在运行后 sudo pecl install amqp 我收到以下神秘的错误消息，但广泛的谷歌搜索并不能帮助解决该问题. 我已经安装了以下软件包: librabbitmq-RabbitMQ C客户端本身) librabbitmq-dev-开发标题等. 和RabbitMQ在本地主机上成功运行 也许C客户端的版本与
..
优秀的AMQP Python库
您能建议使用哪个Python库访问AMQP(RabbitMQ)吗?根据我的研究，pika似乎是首选. 解决方案 Pika是RabbitMQ推荐的库，而 py-ampqlib .根据您使用Rabbit的用途，您可能还需要查看 Celery (专用于分布式排队的客户端库). 同样，根据使用情况，您可能还需要查看Apache的 qpid ，它是完整的AMPQ-基于客户端-服务器的Rabbi
..
嵌入式AMQP Java代理
我正在尝试为连接到RabbitMQ代理的Scala/Java应用程序创建集成测试.为了实现这一点，我希望有一个嵌入式经纪人讲我在每次测试之前启动和停止的AMQP.最初，我试图将ActiveMQ引入AMQP作为嵌入式代理，但是该应用程序使用RabbitMQ，因此只能使用0.9.3版本的AMQP，而ActiveMQ需要1.0版本的AMQP. 是否可以使用另一个嵌入式代理代替ActiveMQ?
..
为什么CELERY_ROUTES都有两个“队列"?和一个"routing_key"?
我对AMQP的理解是，消息仅包含以下组成部分: 邮件正文 路由键 交流 队列附加到交换机.消息对队列一无所知.它们只是发布到一个交换，然后根据交换类型和路由密钥，将邮件路由到一个或多个队列. 在Celery中，建议的路由任务方式是通过CELERY_ROUTES设置.在文档中，CELERY_ROUTES是... 路由器列表，或用于将任务路由到队列的单个路由器. http:
..
如何在本地主机上停止RabbitMQ服务器
我在OS X上安装了RabbitMQ服务器，并在命令行上启动了它.现在，不知道如何停止运行?我做完之后: sudo rabbitmq-server -detached 我得到: Activating RabbitMQ plugins ... 0 plugins activated: 就是这样.我应该如何正确关闭它?在文档中，它提到使用rabbitmqctl(1)，但是我不清楚这
..
Windows服务总线错误:对等方未为链接，目标:创建远程端点，
我正在尝试使用提供的示例连接到Windows服务总线微软网站，尝试使用来自Java的AMQP连接服务总线 private String SbConnStrACS = "amqps://" + SbUsername + ":" + encode(SbPassword) + "@" + SbDomain; private String SbQueueName = SbNamespace + "/
..
单个队列，多个@RabbitListener，但服务不同
是否可以有一个@RabbitListener，例如: @RabbitListener(queues = STORAGE_REQUEST_QUEUE_NAME) public FindApplicationByIdResponse findApplicationById(FindApplicationByIdRequest request) { return repository.fi
..
带有spring amqp的rabbitmq-在AmqpException情况下卡住的消息
我在使用者内抛出了AmqpException. 我的期望是，该消息将按FIFO顺序返回到队列，并在将来的某个时间重新处理. 似乎Spring AMQP不会将消息释放回队列.但是相反，它会尝试一遍又一遍地重新处理失败的消息. 这将阻止新到达的消息被处理.被卡住的文件永远在AMQP控制台内部以“未打包"状态显示. 有什么想法吗? 解决方案 rabbitmq/Spring AMQP就
..
得到"amqp:内部错误".使用AMQP，rhea和Node从Azure Service Bus队列中查看消息时
几天前我问了同样的问题:从Azure Service Bus队列发送消息.我再次问相同的问题，但有一些区别(因此，请不要将此问题标记为其他问题的重复项): 在上一个问题中，我正在使用nodeamqp10库，但是基于该库在Github页面上的一些评论，我最终使用了 rhea 而不是nodeamqp10库. 在Azure Service Bus团队的一些帮助下，我取得了一些进展，现在我从Azu
..
Spring AMQP:将BlockedListener注册为连接
我正在尝试使用Spring AMQP的RabbitTemplate来实现RabbitMQ的阻塞侦听器.在我的代码中，我使用的是Spring-amqp 1.1.3版本的jar文件，而我也已经研究了1.3.1版本，并且在此版本中也不支持.有谁知道我是否缺少支持在RabbitMQ中将阻止的侦听器注册到新连接的任何版本.或者，如果将来有任何春季版本的amqp支持此功能. 示例代码: C
..