amqp

amqp

文章 19 浏览 68

RabbitMQ pop操作原子性

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

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

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

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

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

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

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

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

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

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

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

Rails 社交网络应用程序的可扩展状态更新/私人消息传递

我正在尝试了解有关 RoR 可扩展性的更多信息。我有一个基本的社交网络应用程序,当前使用 MySQL 来存储所有内容(用户关系、状态更新、私人消息)。 N…

南薇 2024-10-27 10:35:49 2 0

python 中的数据流计算

我有 n 个(通常 n < 10 但它应该扩展)进程在不同的机器上运行,并使用 RabbitMQ 通过 amqp 进行通信。进程通常需要长时间运行,并且可以用任何语言…

别把无礼当个性 2024-10-26 19:10:55 4 0

RabbitMQ 用直接交换来模拟主题交换

有没有办法让我可以直接交换模拟主题交换(我知道可以得到相反的结果:参见此处),但我的用例是,我已经部署了一个包含大量队列的直接交换器,每个队…

情场扛把子 2024-10-25 05:53:09 3 0

无需轮询即可在客户端之间发送消息

我有一个相互连接的 MS SQL 服务器网络,并连接到它们的 (C++/C#) 客户端。我正在设计一种客户端之间的消息传递和服务器-客户端消息传递的方式。 我已…

请你别敷衍 2024-10-23 13:37:53 10 0

重启RabbitMQ后Ruby AMQP持久消息被删除

我有一个 ruby​​ 脚本,它使用 RabbitMQ 中的 AMQP 创建消息。 # above code sets up config for connecting to RabbitMQ via APMQ AMQP.start(:hos…

森林很绿却致人迷途 2024-10-22 20:24:33 3 0

amqp queue_delete 以异步方式捕获错误

我刚刚开始将 pika(v 0.9.4) 与 Tornado 一起使用(通过使用 pika.adapters.tornado_connection.TornadoConnection),我想知道使用时捕获错误的适当…

叶落知秋 2024-10-21 18:49:09 4 0

如何在 PHP 中同步监听来自 RabbitMQ 队列的消息?

我正在使用 RabbitMQ 使用 PHP AMQP 扩展 .我需要搜索索引器恶魔来侦听队列上的消息并在可用时使用它们。 我看到两种从队列中消费内容的方法: AMQPQu…

并安 2024-10-20 20:24:21 6 0

Python Kombu 消费者未收到rabbitmq消息通知(queue.get确实有效)

如果我运行以下代码,回调(测试)将传递到 消费者永远不会被触发。 但是,如果我密切关注rabbitmq GUI,我确实会看到消息已被检索(但未确认)。所以…

淡写薰衣草的香 2024-10-20 18:53:24 3 0

用于开发和模拟的 Lite Python AMQP 服务器实现?

Closed. This question is seeking recommendations for software libraries, tutorials, tools, books, or other off-site resources. It does not …

ぇ气 2024-10-20 09:00:56 6 0

Celery (Django) 速率限制

我正在使用 Celery 来处理多个数据挖掘任务。其中一项任务连接到远程服务,该服务允许每个用户最多同时建立 10 个连接(换句话说,它可以在全球范围内…

情深缘浅 2024-10-15 07:54:17 9 0

消息传递协议 - 提供中间件监控解决方案

从我研究过的所有 NMS(网络管理解决方案)来看, 只有 Zenoss 有一个守护进程来处理 AMQP 消息(这意味着我最喜欢的 Zabbix 没有注意到它。) 这是为…

以为你会在 2024-10-14 19:52:20 5 0
更多

推荐作者

離殇

文章 0 评论 0

小姐丶请自重

文章 0 评论 0

Aik

文章 0 评论 0

国产ˉ祖宗

文章 0 评论 0

猥琐帝

文章 0 评论 0

半仙

文章 0 评论 0

更多

友情链接

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