C#通过rabbitmq实现定时任务(延时队列)

   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";
            //设置Exchange队列类型
            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(queueName, exchangeName, routingkey);
            for (int i = 0; i < 3; i++)
            {
                var time = 1000 * 5;
                var message = $@"发送时间为 {DateTime.Now:yyyy-MM-dd HH:mm:ss} 延时时间为:{time}";
                var body = Encoding.UTF8.GetBytes(message);
                var props = channel.CreateBasicProperties();
                //设置消息的过期时间
                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($@"接受到消息的时间为 {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($@"接受到消息的时间为 {DateTime.Now:yyyy-MM-dd HH:mm:ss},routingKey:{routingKey} message:{message} ");
            };
            channel.BasicConsume(queue: queueName,
                autoAck: true,
                consumer: consumer);
            Console.ReadLine();