rabbitmq

rabbitmq

文章 382 浏览 196

RabbitMQ pop操作原子性

有谁知道 RabbitMQ 队列上的 pop 操作是否是原子的? 我有几个进程从同一个队列中读取数据(该队列被标记为持久的,在版本 2.0.0 上运行),并且我看…

智商已欠费 2024-11-02 09:43:26 6 0

RabbitMQ 通道创建指南

我正在编写一个简单的类,我的应用程序将使用它来使用 RabbitMQ 发送和接收消息。 我已经阅读了尽可能多的有关 RabbitMQ 的操作方法、博客文章、白皮…

近箐 2024-11-02 00:08:39 6 0

订阅队列,接收 1 条消息,然后取消订阅

我有一个场景,我需要非常快速地分发和处理作业。我将快速将大约 45 个作业填充到队列中,并且可以同时处理大约 20 个作业(5 台机器,每台 4 个核心…

浅忆 2024-11-01 20:38:06 7 0

如何并行处理消息,同时确保每个实体 FIFO?

假设您的系统中有一个实体,例如“Person”,并且您想要处理修改各种 Person 实体的事件。重要的是: 同一 Person 的事件按 FIFO 顺序处理 多个 Perso…

放手` 2024-11-01 19:36:07 8 0

ActiveMQ CMS:超过 1 个消费者如何在同一队列上接收相同的消息(我不希望发生负载平衡)?

我已经设计和实现了我的框架,牢记rabbimq并且几乎完成了,但在最后一个状态,我必须转向activeMQ,所以目前,找到所有功能(我的设计所基于的)的等…

你列表最软的妹 2024-10-31 19:10:00 9 0

我可以在 AMQP 中多次使用相同的关联 ID 吗?

假设我有一个队列,多个消费者正在监听。我将一个请求放在队列中,其中一个消费者将处理它,并向我发送回复。 现在,假设我不耐烦,如果一段时间后没…

咆哮 2024-10-31 02:33:06 7 0

使用 celery 作为容错调度程序

我想在分布式环境中使用 celery w/rabbitmq 作为容错调度程序。 通过容错,我的意思是,如果将任务分配给工作人员并且该工作人员由于某种原因而停机,…

红玫瑰 2024-10-30 16:44:03 4 0

如何使用 Pika 发送和接收 RabbitMQ 消息?

我在让 Pika 以与 AMQP 或 RabbitMQ 文档一致的方式使用路由密钥或交换时遇到一些问题。我知道 RabbitMQ 文档使用旧版本的 Pika,所以我忽略了他们的…

闻呓 2024-10-27 16:37:30 10 0

rabbitmq+celery 内存泄漏?

我已经在生产中愉快地运行了 celery+rabbitmq+django 一个月左右。昨天,我决定从 celery 2.1.4 升级到 2.2.4,现在rabbitmq 正在失控。运行一段时间…

念﹏祤嫣 2024-10-27 13:56:13 8 0

Django Celery 和多个数据库(Celery、Django 和 RabbitMQ)

是否可以设置与 Django Celery 一起使用的不同数据库? 我有一个配置了多个数据库的项目,并且不希望 Django Celery 使用默认数据库。 如果我仍然可以…

朦胧时间 2024-10-27 11:31:37 6 0

Rabbitmq - 到单个队列的多个绑定(路由键)

我需要一个关于多个路由键绑定队列的参考。 你看,我创建了一个队列,并将其绑定一次 channel.queuebind() ,然后再次绑定, channel.queuebind() 直…

那片花海 2024-10-27 11:16:16 2 0

如何在 RABBITMQ 中为消费者端设置时间

这是我的代码,我在 autoDelete 两个队列上设置了 true ,交换最终发布在几分钟内没有向消费者发送任何消息,此时我想自动停止消费者端,也许你没有完…

樱&纷飞 2024-10-27 09:30:00 5 0

Ruby SMPP 与 RabbitMQ 和 Eventmachine,AMQP.stop 后出现问题

我对rabbitmq 有一个小问题,我不明白。 我正在使用: Ruby 版本 1.8.7 AMQP GEM 版本 0.7.0 RabbitMQ v2.3.1 ruby​​-smpp v0.4.0 我的代码如下所示…

许你一世情深 2024-10-27 00:40:02 4 0

Centos 5.5 上的 RabbitMQ 安装问题

我一直在尝试让rabbitmq-server-2.4.0在Centos上启动并运行 5.5 在 Amazon AWS 实例上。 我的实例使用以下内核:2.6.18-xenU-ec2-v1.2 我尝试使用以下…

和影子一齐双人舞 2024-10-26 20:01:06 14 0

如何在 eventmachine 中启动多个工作进程?

我正在使用 Rails 3、Eventmachine 和 RabbitMQ。 当我将消息发布到队列时,我需要启动多个工作进程。 我知道 eventmachine 是我的场景的解决方案。 …

韬韬不绝 2024-10-26 09:16:25 7 0
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文