RabbitMQ：确认消息到达队列

Question

我是 RabbitMQ 的新手，我正在尝试构建一个强大的生产者，不断尝试传递消息

所以我需要确保消息从我的生产者发送并放入队列中。 我只需要确认它在队列中“由于队列的大小可能尚未收到消费者”。

我的简单应用发布者

    var factory = new ConnectionFactory
    {
         Uri = new Uri($"amqp://{_config.MassTransit.Username}:{_config.MassTransit.Password}@{_config.MassTransit.Host}:{_config.MassTransit.Port}")
    };

    using IConnection connection = factory.CreateConnection();
    using IModel channel = connection.CreateModel();


    channel.BasicPublish(message.ExchangeName, message.RoutingKey, null, 
    Encoding.UTF8.GetBytes(JsonSerializer.Serialize(message)));

那么，如何确认队列中的消息以避免重新发送消息？

提前致谢。

Answer 1

您正在寻找publisher confirms。