小编Tow*_*man的帖子

我正在使用NodeJS和amqplib来构建一个简单的作业排队库(有点类似于Jackrabbit),以便在一个服务中使用,该服务应解析包含许多不同事件信息的相当大的订阅源.

解析信息后,它将分发到数千个队列(队列是必须遵守消息顺序的最小单元),然后由我的排队库使用.

问题是:在这种情况下,我如何遵循"每个应用程序1个连接,每个线程1个通道,每个通道1个消费者"指南？这将导致产生数千个进程,浪费大量内存和资源.

注意:每个队列中的消息数量不是很高:最多约1-2 msg/sec