zoukankan      html  css  js  c++  java
  • 获取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

  • 相关阅读:
    ES6——Promise
    ES6——generator-yield
    ES6——generator
    JQuery——关于CDN(内容分发网络)
    关于JSON使用要注意的地方
    第7课
    第6课
    第5课
    第4课
    第3课
  • 原文地址:https://www.cnblogs.com/hepeng/p/12698985.html
Copyright © 2011-2022 走看看