amqp相关内容

如何监听动态创建的队列?

我有一个rabbitListener,它可以持续地异步监听队列“user-Messages”的用户消息。除非队列中加载了批量消息,否则一切正常。当消息批量发布到队列时,同一用户的消息会先处理,其他用户的消息则会等待处理。 我无法使用优先级队列,因为所有用户的优先级都相等。因此,我希望创建新队列并在运行时监听它们。一旦消息被使用,所有队列都将是短暂的。(该队列将被删除) 浏览时,我发现可 ..
发布时间:2022-06-24 16:07:39 Java开发

JMS和AMQP-RabbitMQ

我想了解什么是JMS,以及它是如何与AMQP术语联系在一起的。 我知道JMS是一个API,而AMQP是一个协议。 以下是我的假设(以及问题) RabbitMQ使用AMQP协议(而不是实现AMQP协议) Java客户端需要使用AMQP协议客户端库来连接/使用RabbitMQ JMS API在这里发挥什么作用?JMS API应使用AMQP客户端库连接RabbitMQ? 我们通常使用J ..
发布时间:2022-02-23 19:30:13 Java开发

如何在运行时创建 celery 队列,以便发送到该队列的任务被工作人员拾取?

我正在使用 django 1.4、celery 3.0、rabbitmq 为了描述这个问题,我在一个系统中有许多内容网络,我想要一个队列来处理与每个网络相关的任务. 但是,当系统运行时,内容是动态创建的,因此我需要动态创建队列并让现有工作人员开始处理它们. 我已经尝试通过以下方式调度任务(其中内容是 django 模型实例): queue_name = 'content.{}' ..
发布时间:2022-01-21 12:25:06 其他开发

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

AMQP如何克服发送消息时直接使用TCP的困难?或者更具体地说是在发布/订阅场景中? 解决方案 在 AMQP 中有一个代理,该代理接收消息,然后完成将它们路由到交换和队列的困难部分.您还可以设置持久队列,即使客户端断开连接,也可以为客户端保存消息. 您当然可以自己完成所有这些工作,但要正确完成这些工作量很大.尤其是 RabbitMQ,已经在许多部署中进行了实战测试. 你还在使用 ..
发布时间:2022-01-11 18:06:45 其他开发

从 RabbitMQ 队列中检索消息

我希望在我的 PHP 应用程序中实现 RabbitMQ,并且正在使用 php-amqp 扩展.我唯一的问题是,如何轻松查询以返回 PHP 中的队列内容? php-amqp 似乎无法让我这样做.如果我错了,请在这里帮助我:) 解决方案 James,你能在rabbitmq-discuss上问这个问题吗?您的问题涉及“查询"队列以获取消息的含义.在 RabbitMQ 中,您使用来自队列的消 ..
发布时间:2022-01-11 18:06:24 PHP

Rabbitmq 消息到达时间戳

有没有办法从消费者那里获取消息放入队列时的时间戳.不是发布的时间,而是实际进入队列的时间. 解决方案 不,没有办法解决这个问题,除非你声明自己为此编写了一个插件.AMQP 规范中没有任何内容表明消息必须知道它何时到达队列. 从 AMQP 的角度来看,没有必要知道这一点.还有很多情况下,消息可能会经过几个队列,那么哪个队列应该代表相关的时间戳? ..
发布时间:2022-01-11 18:05:13 C#/.NET

RabbitMQ/Celery/Django 内存泄漏?

我最近接手了我公司正在进行的项目的另一部分,并发现我们的 RabbitMQ/Celery 设置中似乎存在内存泄漏. 我们的系统有 2Gb 的内存,在任何给定时间大约有 1.8Gb 可用.我们有多个任务处理大量数据并将它们添加到我们的数据库中. 当这些任务运行时,它们会消耗相当多的内存,很快我们的可用内存就会下降到 16Mb 到 300Mb 之间的任何地方.问题是,这些任务完成后,内存并 ..
发布时间:2022-01-11 18:04:34 其他开发

为什么我不应该对所有事情都使用 rabbitmq 主题交换?

似乎工作模式、扇出和过滤主题都可以通过主题交换来实现.为什么我会改用直接或扇出交换? 我们希望将我们组织中发现的常见模式编入一个库中,该库抽象了 amqp 的无限灵活性(命名约定、默认为持久、发送通用标头、到期等).我们应该利用不同的交换类型还是使用主题实现所有模式?为什么? (我们在 Java 中通过 spring boot、golang 和 php 有消费者/发布者) 解决方 ..
发布时间:2022-01-11 18:03:04 其他开发

rabbitmq AMQP::consume()

AMQP 函数 consume() 是一个带有回调的阻塞函数,是否可以为 consume() 函数设置超时,这样在特定时间后它不再阻塞并且代码执行完成? 解决方案 是的,方法如下: $amqp = new AMQPConnection($your_connection_params);$amqp->setTimeout($seconds); 那么当你在队列上调用consume()时,如 ..
发布时间:2022-01-11 18:01:18 PHP

在 Windows 10 & 中安装 AMQPPHP 7.3

我想用 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 ..
发布时间:2022-01-11 18:00:55 PHP

如何使用自动装配的 Spring Boot 监听多个队列?

我是 Spring Boot 的新手,我正在玩它.目前我已经建立了一些我希望能够通过队列相互通信的应用程序.我目前有一个可以从特定队列接收消息的 Listener 对象. @Configuration公共类监听器{最终静态字符串 queueName = "myqueue";@豆角,扁豆SimpleMessageListenerContainer 容器(ConnectionFactory conn ..
发布时间:2022-01-11 18:00:43 其他开发

谁能告诉我 python 中 pika 和 kombu 消息传递库之间有什么区别?

我想在我的应用程序中使用消息传递库与 rabbitmq 进行交互.谁能解释一下 pika 和 kombu 库之间的区别? 解决方案 Kombu 和 pika 是两个不同的 Python 库,它们从根本上服务于相同的目的:向/从消息代理发布和消费消息. Kombu 比 pika 具有更高的抽象级别.Pika 仅支持 AMQP 0.9.1 协议,而 Kombu 可以支持其他传输(例如 R ..
发布时间:2022-01-11 17:56:23 其他开发

RabbitMQ AMQP 队列设计

以下是队列的理想设计: P 制作人.插入数据的应用程序 X 交换. C1-C3 消费者.从队列中读取的应用程序 队列详情: A.就像队列日志一样,如果没有客户端绑定,则消息将被丢弃. B.这是一个工作队列.如果有条件匹配,它会做一些事情. C.也是一个工作队列.它将转换数据 A 是可选的,但 B.C. 将始终在队列中,直到某个客户端进程连接它. 问题是确定我应 ..
发布时间:2022-01-11 17:55:40 其他开发

在队列之间移动消息 rabbitMQ

我希望能够在 Rabbit 的队列之间(手动)移动消息. 例如: first-queue 有消息 ['a','b','c','d','e','f']第二队列有消息 ['x','y'] 我希望能够将例如消息“a"从第一个队列移动到第二个队列.这可以是手动操作.两个队列都在同一个代理上,我不想通过任何交换发送它们.有没有办法做到这一点?我一直在玩rabbitmqctl,但似乎无法让它工作.我 ..
发布时间:2022-01-11 17:52:54 其他开发

使用 RabbitMQ 和 Python 进行基于内容的路由

是否可以使用 RabbitMQ 和 Python 进行基于内容的路由? AMQP 标准和 RabbitMQ 声称支持基于内容的路由,但是是否有任何 Python 库支持指定基于内容的绑定等? 我目前使用的库(py-amqplib http://barryp.org/software/py-amqplib/) 似乎只支持带有简单模式匹配(#、*)的基于主题的路由. 解决方案 答案 ..
发布时间:2022-01-11 17:52:05 Python