message-queue

message-queue

文章 3 浏览 169

了解基本 celery 消息队列的工作原理

我已经实现了一个小测试,它使用 celery 进行消息队列,我只是想确保我了解它在基本层面上的工作原理(Django-Celery,使用 Redis 作为代理)。 我的…

马蹄踏│碎落叶 2024-12-13 18:33:14 5 0

具有 WCF 和持久队列的 RabbitMQ

我正在尝试编写一个通过rabbitMQ 绑定工作的wcf 服务。我能够成功创建服务器和客户端,并让客户端通过队列向服务器发送消息。我对 2 个问题感到困惑。…

橘香 2024-12-13 15:58:52 3 0

Amazon SQS:如何找到作业结束?

假设我有很多工作,每个工作都由许多工作应用程序所处理的大量基本操作组成。 我将每个操作的消息发送给工作人员,以便他们可以捕获这些消息,执行所…

╰◇生如夏花灿烂 2024-12-12 14:08:16 8 0

ZeroMQ、RabbitMQ 和 Apache Qpid 的性能比较

我的应用程序需要高性能消息总线,因此我正在评估 ZeroMQ、RabbitMQ 和 Apache Qpid 的性能。为了测量性能,我正在运行一个测试程序,该程序使用其中…

逐鹿 2024-12-12 13:57:34 8 0

在 Java EE 应用程序中通过消息队列对临时数据进行后台处理

我正在构建一个 Java EE Web 应用程序,它还有一个 JAX-RS API,以便其他网站上的插件可以向它发送数据,将其视为一个分析服务器,它从各个客户端站点…

枫林﹌晚霞¤ 2024-12-12 04:04:37 5 0

单一生产者单一消费者现在我需要多个消费者

我遇到过这样的情况:我编写了一个简单的生产者消费者模型,用于从蓝牙读取数据块,然后每 10k 字节将其写入文件。我使用标准 PC 模型,使用 Vector …

煮茶煮酒煮时光 2024-12-12 02:02:02 3 0

如何快速从 Amazon SQS(简单队列服务)队列中删除事件?

假设我的 SQS 队列中有数百万个事件,我想快速删除它们,但我不能只删除队列并创建一个新队列。 从队列中删除/排出这些事件的最快方法是什么?…

你爱我像她 2024-12-12 01:25:55 10 0

使用 Celery 动态创建队列

我正在使用 Django、Celery 和 RabbitMQ 编写一个邮件列表管理器。当收到消息时,将为每个收件人执行一项任务。所有任务都进入一个队列,一个或多个工…

话少心凉 2024-12-12 00:56:19 3 0

如何在不杀死数据库的情况下使用 Gearman 进行文件处理?

我目前正在设计一个用于处理上传文件的系统。 文件通过 LAMP Web 前端上传,并且必须通过多个阶段进行处理,其中一些阶段是连续的,另一些阶段可能并…

天生の放荡 2024-12-11 19:52:38 6 0

关于JMS体系结构

我正在编写一个服务器/客户端游戏,一个典型的场景是这样的:一个客户端(clientA)向服务器发送一条消息,服务器中有一个 MessageDrivenBean 来处理…

白日梦 2024-12-11 13:15:24 5 0

将类对象指针打包成 char * 用于消息队列

是否可以通过 POSIX 消息队列正确且安全地传递类对象指针? 例如, Object *obj = new Object(); mq_send(mqdes, static_cast&obj, sizeof(obj), 1); …

淡淡の花香 2024-12-11 10:02:37 6 0

ZMQ PUSH/PULL模型:当节点PUSH消息并退出时消息丢失

我需要 PHP Web 应用程序将消息写入非阻塞队列,并且其他进程将它们出队。我当前的设计是 PHP 应用程序创建一个 ZMQ.PUSH 套接字,对目标地址进行 连…

快乐很简单 2024-12-11 05:42:12 4 0

Posix 消息队列 - 多写入器和多写入器多读者

我对队列(POSIX)感到困惑。 队列中的多个写入者或队列中的多个读取者是否需要受到保护? 多个线程将写入队列,多个线程将从队列中读取。 正如定义所…

一页 2024-12-11 01:41:01 6 0

Python 多处理队列可扩展到大量工作人员

我有一个启动工作进程的 python(2.6.5 64 位,Windows 2008 Server R2)应用程序。父进程将作业放入作业队列中,工作人员从中获取作业。类似地,它有…

若相惜即相离 2024-12-10 21:53:38 4 0

对 ObservableCollection 更新进行排队

我正在编写一个 TAPI 应用程序,它使用状态模式来处理 TK 可能处于的不同状态。传入和传出调用通过 ListView 中的 ObservableCollection 进行记录(打…

十年九夏 2024-12-10 08:01:09 6 0
更多

推荐作者

alipaysp_snBf0MSZIv

文章 0 评论 0

梦断已成空

文章 0 评论 0

瞎闹

文章 0 评论 0

寄意

文章 0 评论 0

似梦非梦

文章 0 评论 0

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