获取RabbitMQ消息发送确认Acks的DeliveryTag对应的消息内容

//生产者
//消息确认事件
channel.BasicAcks += Channel_BasicAcks;
。。。。。。
while (a <= 5000)//channel.WaitForConfirms()
                    {
                        //String message = Console.ReadLine();
                        String message = a + "......";
                        //消息内容
                        byte[] body = Encoding.UTF8.GetBytes(message);
                        //发送消息
                        channel.BasicPublish(exchange: "", routingKey: queueName, basicProperties: null, body: body);
                        a += 1;
                        Console.WriteLine("channel.NextPublishSeqNo:" + channel.NextPublishSeqNo);
                    }
。。。。。。
 private static void Channel_BasicAcks(object sender, BasicAckEventArgs e)
    {
            Console.WriteLine("BasicAcks e.DeliveryTag:" + e.DeliveryTag);
            Console.WriteLine("BasicAcks e.Multiple:" + e.Multiple);
    }
channel.NextPublishSeqNo 每次在程序启动后都从1开始增长,和业务数据的关系建议另外处理,比如与业务数据ID一起写入本地缓存等

推荐: https://blog.csdn.net/hellozpc/article/details/81436980

原文地址:https://www.cnblogs.com/hepeng/p/12698985.html