使用rabbitmq如何做限流？

在RabbitMQ中有两种限流方式：基于QoS（Quality of Service）和基于Consumer。

1. 基于QoS

基于QoS的限流方式通过限制RabbitMQ队列中未确认的消息数目来实现限流。我们可以通过以下方式设置：

channel.basic_qos(prefetch_count=1)

这个方法会告诉RabbitMQ一次只发送一条消息给消费者，直到消费者确认了这条消息。当消费者确认了这条消息之后，RabbitMQ会立即发送下一条消息给消费者，以此类推。

2. 基于Consumer

基于Consumer的限流方式通过限制每个消费者每秒钟可以处理的消息数目来实现限流。我们可以通过以下方式设置：

channel.basic_consume(queue='queue', on_message_callback=callback, auto_ack=True, consumer_tag='tag')
channel.basic_qos(prefetch_count=1, per_consumer_limit=True)

这个方法会告诉RabbitMQ一次只发送一条消息给消费者，直到消费者确认了这条消息。当消费者确认了这条消息之后，RabbitMQ会立即发送下一条消息给消费者，以此类推。

基于Consumer的限流方式比基于QoS的限流方式更加灵活，因为它可以针对每个消费者进行限流，而不是对整个队列进行限流。但是，它需要我们手动实现每个消费者的限流，所以在实现上比较复杂。