有的消费者处理速度快，有的消费者处理速度慢，我们想给处理快的多发消息，处理慢的少发消息，

怎么办呢？按照之前的轮询模式，肯定不行的，这里可以检测消息数量，如果消费者正在处理就不给他发

....def callback(ch, method, properties, body):    print("--->:",ch,properties)    time.sleep(10)    print("received: ", body)    ch.basic_ack(delivery_tag=method.delivery_tag)# 消费者端加这句话，表示消息限制数量channel.basic_qos(prefetch_count=1)channel.basic_consume(callback,                      queue='q1',                      )....