RabbitMQ 在消息被消费后不会删除消息

Question

我得到了一个简单的生产者和消费者。

我想手动管理删除消息的过程，所以我在消费者端设置了autoAck = false。问题是一旦消息被消费 - 它不会从队列中删除并且仍然标记为就绪（当设置 autoAck = true 时它会立即被删除）。

using RabbitMQ.Client;
using System.Text;

var factory = new ConnectionFactory();
factory.UserName = "myuser";
factory.Password = "mypassword";
factory.HostName = "myhost";
factory.Port = myport;
factory.VirtualHost = "myvhost";
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare(queue: "notifications",
                         durable: true,
                         exclusive: false,
                         autoDelete: false,
                         arguments: null);
    var properties = channel.CreateBasicProperties();
    properties.Persistent = true;

    string message = "Hello World!";
    var body = Encoding.UTF8.GetBytes(message);

    channel.BasicPublish(exchange: "",
                         routingKey: "notifications",
                         basicProperties: properties,
                         body: body);
    Console.WriteLine(" [x] Sent {0}", message);
}

Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();

这是我的消费者

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;

var factory = new ConnectionFactory();
factory.UserName = "myuser";
factory.Password = "mypassword";
factory.HostName = "myhost";
factory.Port = myport;
factory.VirtualHost = "myvhost";

using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare(queue: "notifications",
                         durable: true,
                         exclusive: false,
                         autoDelete: false,
                         arguments: null);

    var consumer = new EventingBasicConsumer(channel);
    consumer.Received += (model, ea) =>
    {
        var body = ea.Body.ToArray();
        var message = Encoding.UTF8.GetString(body);
        Console.WriteLine(" [x] Received {0}", message);
        channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
    };
    channel.BasicConsume(queue: "notifications",
                         autoAck: false,
                         consumer: consumer);
}

Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();

Answer 1

您的消费者代码在退出之前不应处理连接和通道实例。如果你早点处理，就像你原来的代码一样，就没有什么可以回调的了：

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;

var factory = new ConnectionFactory();
factory.UserName = "myuser";
factory.Password = "mypassword";
factory.HostName = "myhost";
factory.Port = myport;
factory.VirtualHost = "myvhost";

using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare(queue: "notifications",
                         durable: true,
                         exclusive: false,
                         autoDelete: false,
                         arguments: null);

    var consumer = new EventingBasicConsumer(channel);
    consumer.Received += (model, ea) =>
    {
        var body = ea.Body.ToArray();
        var message = Encoding.UTF8.GetString(body);
        Console.WriteLine(" [x] Received {0}", message);
        channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
    };
    channel.BasicConsume(queue: "notifications",
                         autoAck: false,
                         consumer: consumer);

    Console.WriteLine(" Press [enter] to exit.");
    Console.ReadLine();
}

_{注意： RabbitMQ 团队监控 rabbitmq-users mailing list 并且有时只在 Whosebug 上回答问题。}

RabbitMQ 在消息被消费后不会删除消息

RabbitMQ doesn't remove message after it was consumed

c#

.net

rabbitmq