RabbitMQ 使用 QOS + Ack 解决内存崩溃问题

通过QOS使得每个消费者在同一时间处理一条消息。在未收到这个消费者Ack前是不会发送新的消息给此消费者。

var _client = connection.CreateModel();
_client.BasicQos(0, 1, false);



 var consumer = new EventingBasicConsumer(_client);

 consumer.Received += (model, ea) =>
 {

     _client.BasicAck(ea.DeliveryTag, false);

 };