amqp

amqp

文章 19 浏览 68

RabbitMQ basic.get 和确认

我正在调用: GetResponse response = channel.basicGet("some.queue", false); // no auto-ack .... channel.basicAck(deliveryTag, ...); 但是,当…

浊酒尽余欢 2024-12-11 14:26:18 0 0

使用来自 Apache Qpid java 客户端的 RabbitMQ 服务器消息?哪个版本?

我必须使用 Apache qpid java 客户端使用rabbitmq-server(因为我必须使用 Apache Camel)。但我对它们的版本感到困惑,特别是因为它们都支持 amqp 协…

天气好吗我好吗 2024-12-11 10:20:06 0 0

如何在多租户系统中的 RabbitMQ 中使队列私有/安全?

我已阅读 RabbitMQ 提供的 入门 指南,甚至还向 stormed-amqp,所以我对AMQP。 然而,该指南并不全面,并且避免了身份验证和授权等内容。 我们正在设…

楠木可依 2024-12-11 05:23:41 0 0

如何在 RabbitMQ/pika 中实现优先级队列

我希望用 RabbitMQ 实现优先级队列。邮件列表建议使用多个队列,每个队列代表不同的优先级。 我的问题是,如何使用 pika (或者可能是其他一些 python…

倾城花音 2024-12-09 08:45:38 0 0

如何让这个AMQP单消息订阅者稳定?

作为大型应用程序的一部分,我必须设置一些跨多个工作人员的传出请求的基本速率限制。这背后的想法相当简单:通过发布带有“立即”标志的“令牌”消息…

睫毛上残留的泪 2024-12-08 09:53:40 0 0

如何在同一个 EventMachine 反应器中运行 Net::SSH 和 AMQP?

一些背景信息:Gerrit 通过 SSH 公开事件流。这是一个可爱的技巧,但我需要将这些事件转换为 AMQP 消息。我尝试使用 ruby-amqp 和 Net::SSH 但是,好…

懒猫 2024-12-07 09:21:31 1 0

Node.js + socket.io +当“re”连接时,node-amqp 和队列 binginds通过 socket.io 连接

我有一个非常接近此示例的场景: 一个主屏幕: 此屏幕(客户端)将通过 server:9090/scope 连接到 socket.io 服务器(io.connect("http://server :909…

无声无音无过去 2024-12-07 06:33:29 1 0

哪个消息队列可以处理订阅者断开连接后仍然存在的私有队列?

我对需要消息队列的系统有一些要求: 订阅者应获得单独的队列。 当订阅者断开连接时,不应删除各个队列 如果失去连接,订阅者应能够重新连接到自己的…

旧街凉风 2024-12-06 10:02:30 1 0

如何使用 amq.topic 在 Apache Qpid 中发布/订阅消息

我有一个 C++ 发布者发送这样的消息: Connection connection; connection.open("127.0.0.1", 5672); Session session = connection.createSession();…

无法言说的痛 2024-12-05 21:33:22 0 0

使用 Python、Pika 和 AMQP 设计异步 RPC 应用程序的最佳模式是什么?

我的应用程序的生产者模块由想要提交要在小型集群上完成的工作的用户运行。它通过 RabbitMQ 消息代理以 JSON 形式发送订阅。 我尝试了几种策略,到目…

指尖微凉心微凉 2024-12-04 11:53:13 2 0

使用 node-amqp 模块在 Node.js 中手动确认

我正在使用 postwait 模块 node-amqp 。 我可以向队列发布/订阅一些消息,但我想手动确认这些消息。 例如,我希望读取消息但不确认消息,然后对此消息…

沉溺在你眼里的海 2024-12-04 01:31:24 1 0

Rabbitmq 与 Apache QPID

我试图找出这两个消息队列中的哪一个。我最初对 RabbitMQ 感兴趣,但由于它(rabbitmq)不提供稳定的 C/C++ 客户端并且似乎没有持久存储(?)…

征﹌骨岁月お 2024-12-02 22:54:19 0 0

使用 Node.js 的 AMQP,如何发布/订阅?

我正在创建一个操作 Node-AMQP 模块的类: https://github.com/postwait/node -amqp 但我无法使用它发布/订阅: var Queue = require('./Queue.js'); …

谎言 2024-12-01 19:23:33 1 0

puka 可以与 gevent 或 eventlet 配合使用吗?

我正在阅读有关较新的 Python AMQP 库 Puka(不要与 Pika 混淆)的信息,并且想知道它处理事件循环的方式是否与 gevent 或 eventlet 兼容。根据我有限…

孤者何惧 2024-11-30 13:53:05 2 0

将大量消息发布到AMQP队列

使用 Ruby amqp 库的 v0.7.1 和 Ruby 1.8.7,我尝试将大量(数百万)短(~40 字节)消息发布到 RabbitMQ 服务器。我的程序的主循环(好吧,不是真正的…

风追烟花雨 2024-11-30 06:44:58 1 0
更多

推荐作者

已经忘了多久

文章 0 评论 0

15867725375

文章 0 评论 0

LonelySnow

文章 0 评论 0

走过海棠暮

文章 0 评论 0

轻许诺言

文章 0 评论 0

信馬由缰

文章 0 评论 0

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