我使用RabbitMQ来管理多台执行持久任务的服务器。每个服务器可以侦听一个或多个队列,但每个服务器一次只能处理一个任务。
每次在服务器中启动使用者时,我都会使用channel.basic_qos(prefetch_count=1)对其进行配置,以便为相应的队列只处理一个任务。
假设我们有:-2个队列: task1,task2。-2台服务器: server1、server2。-这两台服务器都与task1和task2一起工作。
如果下一条消息同时生成:- messageA for tasks1 - messageB for tasks2 - messageC for tasks1
我期望:- m