我正在和 rabbitmq 具有 amqplib 在我的 node 项目。
rabbitmq
node
我使用队列在服务之间传递作业消息。 其中一个服务使用这些消息,进行一些处理并将结果返回到另一个队列。
有时排队的人 许多 消息,服务尝试同时使用所有消息,从而导致进程(服务)崩溃。
如何限制通道/服务可以处理的消息数? 我想到了一个定制的解决方案,有一个全球性的限制,但我宁愿用它作为最后的手段…
