131得票6回答
Node.js 中的后台进程

如何处理NodeJS应用程序中的后台进程? 场景: 用户在应用程序中发布内容后,我想要对数据进行处理,从外部资源请求附加数据等操作。所有这些操作都需要花费大量时间,因此我希望将其放在req/res循环之外。理想情况下,只需具有作业队列即可快速转移作业,并且守护进程或任务运行程序将始终获取最旧...

64得票3回答
在RabbitMQ中,池化连接和通道之间是否存在性能差异?

我是一个Rabbitmq的新手(也是程序开发方面的),如果我的提问很显而易见,那么请提前原谅。我正在创建一个在队列中工作的线程之间共享的池,但我不确定在池中应该使用连接还是通道。 我知道需要使用通道来执行实际的工作,但是每个连接是否有一个通道会带来性能上的优势(对于从队列中获取更多吞吐量)?...

50得票9回答
PHP中的并行处理 - 如何实现?

我目前正在尝试在PHP中实现一个作业队列。该队列将作为批处理作业进行处理,并应能够并行处理一些作业。 我已经进行了一些研究,发现了几种实现方法,但我并不真正了解它们的优缺点。 例如,通过多次调用脚本来使用fsockopen进行并行处理,如此处所述: 在PHP中轻松进行并行处理 我找到的另一种方...

36得票1回答
App Engine任务队列中的TombstonedTaskError是什么?

TombstonedTaskError 是什么意思?在尝试从 cron-job 添加任务到队列时,它被引发:Traceback (most recent call last): File "/base/python_lib/versions/1/google/appengine/ext/w...

26得票2回答
RabbitMQ:Celery提供了什么,Pika没有的?

我一直在努力通过RabbitMQ使一些分布式任务得以运行。 我花了一些时间尝试让Celery完成我想做的事情,但无法使其工作。 然后我尝试使用Pika,事情就顺畅地在几分钟内解决了。 如果使用Pika而不是Celery,是否会有什么遗漏呢?

24得票1回答
Google应用引擎中“队列桶大小”是什么意思?

谷歌应用引擎任务队列的配置如下(示例) <queue> <name>mail-queue</name> <rate>5/m</rate> <bucket-size>10</bucket-si...

24得票1回答
谷歌应用引擎中的Push队列和Pull队列

目前为止,没有人(甚至是GAE文档)能够给我一个真正清晰的描述,说明推送队列和拉取队列之间有什么区别。 我的理解是,任务队列API允许您定义任务队列,其中可以将工作入队。以某种方式,这与GAE的自动扩展功能配合使用,因此您不需要显式地管理消耗这些队列中的任务的工作线程数量:GAE会为您处理。...

23得票2回答
如何使用q.js的Promise处理多个异步操作

注意:这个问题也在 Q.js 邮件列表上发布。 我有一个涉及多个异步操作的情况,所接受的答案指出,使用 Promise、例如 q.js 库将更加有益。 我已经被说服改写我的代码来使用 Promise,但由于代码相当长,我已经剪裁了不相关的部分,并将关键部分导出到单独的 repo 中。 ...

19得票1回答
使用RabbitMQ进行动态队列创建

我一直在学习RabbitMQ的各种拓扑结构,但是我找不到有关从生产者中动态创建队列(即声明队列)的参考资料。 其想法是根据特定事件(例如HTTP请求)动态创建临时队列,并设置TTL并以事件ID命名。 然后消费者可以订阅主题“event.*”并合并与其相关的所有消息。 例如: 1.收到HTT...

19得票3回答
从Laravel Jobs返回数据

如何在不保存数据的情况下从排队的作业中返回数据,并处理由于重试而导致作业可能运行多次的情况?如果作业不适用,是否有其他方法可以实现这一目标? 我正在为移动应用程序开发Laravel的API。 这些方法将向其他API发出请求,组合和过滤数据,改变其结构等。 应用程序的要求之一是在30秒...