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); };