RabbitMQ：确认消息已到达队列

Question

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

所以我需要确保消息从我的生产者发送并放入队列中。我只需要确认它在队列中 'may not received consumer yet becuse of the size of queue'.

我的简单应用发布者

    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.

RabbitMQ：确认消息已到达队列

RabbitMQ: Confirm That Message Reached The Queue

rabbitmq

queue

message-queue

rabbitmqctl