var factory = new ConnectionFactory()
            {
                Uri = new Uri("MQ地址")
            };
           
            using var connection = factory.CreateConnection();
            using var channel = connection.CreateModel();


            var exchangeName = "delay-exchange";
            var routingkey = "delay.delay";
            var queueName = "delay_queueName";
            //設(shè)置Exchange隊(duì)列類(lèi)型
            var argMaps = new Dictionary<string, object>()
            {
                {"x-delayed-type", "topic"}
            };
            //設(shè)置當(dāng)前消息為延時(shí)隊(duì)列
            channel.ExchangeDeclare(exchange: exchangeName, type: "x-delayed-message", true, false, argMaps);
            channel.QueueDeclare(queueName, true, false, false, argMaps);
            channel.QueueBind(queueName, exchangeName, routingkey);
            for (int i = 0; i < 3; i++)
            {
                var time = 1000 * 5;
                var message = $@"發(fā)送時(shí)間為 {DateTime.Now:yyyy-MM-dd HH:mm:ss} 延時(shí)時(shí)間為:{time}";
                var body = Encoding.UTF8.GetBytes(message);
                var props = channel.CreateBasicProperties();
                //設(shè)置消息的過(guò)期時(shí)間
                props.Headers = new Dictionary<string, object>()
                {
                    {  "x-delay", 5000 }
                };
                channel.BasicPublish(exchange: exchangeName,
                    routingKey: routingkey,
                    basicProperties: props,
                    body: body);
                Console.WriteLine(message);


            }
            Console.ReadLine();

        var factory = new ConnectionFactory()
            {
                Uri = new Uri(MQ地址)
            };
            using var connection = factory.CreateConnection();
            using var channel = connection.CreateModel();
            var queueName = "delay_queueName";
            channel.QueueDeclare(queueName, true, false, false, null);
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body);
                var routingKey = ea.RoutingKey;
                Console.WriteLine($@"接受到消息的時(shí)間為 {DateTime.Now:yyyy-MM-dd HH:mm:ss},routingKey:{routingKey} message:{message} ");
            };
            channel.BasicConsume(queue: queueName,
                autoAck: true,
                consumer: consumer);
            Console.ReadLine();

  var factory = new ConnectionFactory()
            {
                Uri = new Uri(MQ地址)
            };
             using var connection = factory.CreateConnection();
            using var channel = connection.CreateModel();
            var exchangeName = "delay-exchange";
            var routingkey = "delay.delay";
            var queueName = "delay_queueName";
            var autoDelete = true;

            var argMaps = new Dictionary<string, object>()
            {
                {"x-delayed-type", "topic"}
            };
            channel.ExchangeDeclare(exchange: exchangeName, type: "x-delayed-message", true, false, argMaps);
            channel.QueueDeclare(queueName, true, false, false, argMaps);
            channel.QueueBind(queue: queueName, exchange: exchangeName, routingKey: routingkey);
            //channel.QueueDeclare(queueName, true, false, false, null);
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body);
                var routingKey = ea.RoutingKey;
                Console.WriteLine($@"接受到消息的時(shí)間為 {DateTime.Now:yyyy-MM-dd HH:mm:ss},routingKey:{routingKey} message:{message} ");
            };
            channel.BasicConsume(queue: queueName,
                autoAck: true,
                consumer: consumer);
            Console.ReadLine();