amqp相关内容
我有一个rabbitListener,它可以持续地异步监听队列“user-Messages”的用户消息。除非队列中加载了批量消息,否则一切正常。当消息批量发布到队列时,同一用户的消息会先处理,其他用户的消息则会等待处理。 我无法使用优先级队列,因为所有用户的优先级都相等。因此,我希望创建新队列并在运行时监听它们。一旦消息被使用,所有队列都将是短暂的。(该队列将被删除) 浏览时,我发现可
..
我想了解什么是JMS,以及它是如何与AMQP术语联系在一起的。 我知道JMS是一个API,而AMQP是一个协议。 以下是我的假设(以及问题) RabbitMQ使用AMQP协议(而不是实现AMQP协议) Java客户端需要使用AMQP协议客户端库来连接/使用RabbitMQ JMS API在这里发挥什么作用?JMS API应使用AMQP客户端库连接RabbitMQ? 我们通常使用J
..
我正在使用 django 1.4、celery 3.0、rabbitmq 为了描述这个问题,我在一个系统中有许多内容网络,我想要一个队列来处理与每个网络相关的任务. 但是,当系统运行时,内容是动态创建的,因此我需要动态创建队列并让现有工作人员开始处理它们. 我已经尝试通过以下方式调度任务(其中内容是 django 模型实例): queue_name = 'content.{}'
..
我已配置 HAProxy(1.5.4,但我也尝试过 1.5.14)以在 TCP 模式下平衡两台服务器在 5672 端口上公开 AMQP 协议(WSO2 消息代理).客户端通过 HAProxy 创建并使用与 AMQP 服务器的永久连接. 我更改了客户端和服务器 TCP keepalive 超时,设置 net.ipv4.tcp_keepalive_time=120 (CentOS 7).
..
有没有办法使用 .NET 使用单个同步调用来接收多条消息? 我看过 question 并且找到了 java 类com.rabbitmq.client.QueueingConsumer,但是我在.NET 命名空间(RabbitMQ.Client、RabbitMQ.Client.Events)中没有找到这样的客户端类 解决方案 您可以使用 BasicQoS.PrefetchCount 检索任
..
AMQP如何克服发送消息时直接使用TCP的困难?或者更具体地说是在发布/订阅场景中? 解决方案 在 AMQP 中有一个代理,该代理接收消息,然后完成将它们路由到交换和队列的困难部分.您还可以设置持久队列,即使客户端断开连接,也可以为客户端保存消息. 您当然可以自己完成所有这些工作,但要正确完成这些工作量很大.尤其是 RabbitMQ,已经在许多部署中进行了实战测试. 你还在使用
..
我正在尝试在 RabbitMQ 中实现一个 dlx 队列.场景很简单我有 2 个队列:1) 活着2) dead (x-dead-letter-exchange: "immediate", x-message-ttl: 5000) 以及绑定到 1) 活着的“立即"交换 我试图运行这个例子:http://blog.james-carr.org/2012/03/30/rabbitmq-sen
..
我希望在我的 PHP 应用程序中实现 RabbitMQ,并且正在使用 php-amqp 扩展.我唯一的问题是,如何轻松查询以返回 PHP 中的队列内容? php-amqp 似乎无法让我这样做.如果我错了,请在这里帮助我:) 解决方案 James,你能在rabbitmq-discuss上问这个问题吗?您的问题涉及“查询"队列以获取消息的含义.在 RabbitMQ 中,您使用来自队列的消
..
有没有办法从消费者那里获取消息放入队列时的时间戳.不是发布的时间,而是实际进入队列的时间. 解决方案 不,没有办法解决这个问题,除非你声明自己为此编写了一个插件.AMQP 规范中没有任何内容表明消息必须知道它何时到达队列. 从 AMQP 的角度来看,没有必要知道这一点.还有很多情况下,消息可能会经过几个队列,那么哪个队列应该代表相关的时间戳?
..
我最近接手了我公司正在进行的项目的另一部分,并发现我们的 RabbitMQ/Celery 设置中似乎存在内存泄漏. 我们的系统有 2Gb 的内存,在任何给定时间大约有 1.8Gb 可用.我们有多个任务处理大量数据并将它们添加到我们的数据库中. 当这些任务运行时,它们会消耗相当多的内存,很快我们的可用内存就会下降到 16Mb 到 300Mb 之间的任何地方.问题是,这些任务完成后,内存并
..
似乎工作模式、扇出和过滤主题都可以通过主题交换来实现.为什么我会改用直接或扇出交换? 我们希望将我们组织中发现的常见模式编入一个库中,该库抽象了 amqp 的无限灵活性(命名约定、默认为持久、发送通用标头、到期等).我们应该利用不同的交换类型还是使用主题实现所有模式?为什么? (我们在 Java 中通过 spring boot、golang 和 php 有消费者/发布者) 解决方
..
AMQP 函数 consume() 是一个带有回调的阻塞函数,是否可以为 consume() 函数设置超时,这样在特定时间后它不再阻塞并且代码执行完成? 解决方案 是的,方法如下: $amqp = new AMQPConnection($your_connection_params);$amqp->setTimeout($seconds); 那么当你在队列上调用consume()时,如
..
我想用 PHP 7.3 在 windows 10 中安装 AMQP,以便在 symfony 4 中使用.windows 不使用任何 apache/iis/nginx 并直接由 symfony 运行. 一切正常!直到,我决定在项目中使用rabbitmq并需要amqp. 所以,1.下载AMQP 1.9.4 (php7.3兼容) 2. 将 php_amqp.dll 复制到 c:\php
..
我是 Spring Boot 的新手,我正在玩它.目前我已经建立了一些我希望能够通过队列相互通信的应用程序.我目前有一个可以从特定队列接收消息的 Listener 对象. @Configuration公共类监听器{最终静态字符串 queueName = "myqueue";@豆角,扁豆SimpleMessageListenerContainer 容器(ConnectionFactory conn
..
我正在使用 Java 客户端在 RHEL 5.3 上使用 RabbitMQ.我有 2 个节点(机器).Node1 正在使用 Java 帮助程序类 QueueingConsumer 从 Node2 上的队列中消费消息. QueueingConsumer 消费者 = new QueueingConsumer(channel);channel.basicConsume("MyQueueOnNode
..
我有一个 2.8.2 RabbitMQ 服务器和一个 2.8.2 客户端 dll,有声明队列和获取消息的代码,它工作正常(所有参数都正确): IModel 通道=null;ConnectionFactory 工厂 = new ConnectionFactory ();factory.HostName = "192.168.68.4";_QueueName = "172.16.1.1";facto
..
我想在我的应用程序中使用消息传递库与 rabbitmq 进行交互.谁能解释一下 pika 和 kombu 库之间的区别? 解决方案 Kombu 和 pika 是两个不同的 Python 库,它们从根本上服务于相同的目的:向/从消息代理发布和消费消息. Kombu 比 pika 具有更高的抽象级别.Pika 仅支持 AMQP 0.9.1 协议,而 Kombu 可以支持其他传输(例如 R
..
以下是队列的理想设计: P 制作人.插入数据的应用程序 X 交换. C1-C3 消费者.从队列中读取的应用程序 队列详情: A.就像队列日志一样,如果没有客户端绑定,则消息将被丢弃. B.这是一个工作队列.如果有条件匹配,它会做一些事情. C.也是一个工作队列.它将转换数据 A 是可选的,但 B.C. 将始终在队列中,直到某个客户端进程连接它. 问题是确定我应
..
我希望能够在 Rabbit 的队列之间(手动)移动消息. 例如: first-queue 有消息 ['a','b','c','d','e','f']第二队列有消息 ['x','y'] 我希望能够将例如消息“a"从第一个队列移动到第二个队列.这可以是手动操作.两个队列都在同一个代理上,我不想通过任何交换发送它们.有没有办法做到这一点?我一直在玩rabbitmqctl,但似乎无法让它工作.我
..
是否可以使用 RabbitMQ 和 Python 进行基于内容的路由? AMQP 标准和 RabbitMQ 声称支持基于内容的路由,但是是否有任何 Python 库支持指定基于内容的绑定等? 我目前使用的库(py-amqplib http://barryp.org/software/py-amqplib/) 似乎只支持带有简单模式匹配(#、*)的基于主题的路由. 解决方案 答案
..