【rabbitMQ】-延迟队列-模拟控制智能家居的操作指令

痛定思痛。 2024-03-16 16:34 34阅读 0赞

**一.什么是延迟队列？**

延迟队列存储的对象是对应的延迟消息，所谓“延迟消息” 是指当消息被发送以后，并不想让消费者立刻拿到消息，而是等待特定时间后，消费者才能拿到这个消息进行消费。

**二.如何设置延迟队列？**

1.配置2个业务队列（扫地机执行命令业务队列，洗衣机执行命令业务队列），绑定到业务交换机上

2.为业务队列配置死信交换机和路由key

3.为死信交换机配置2个延迟队列（扫地机执行命令延迟队列，洗衣机执行命令延迟队列）

![aaacd31e90443f7d411ae1e06123e92a.jpeg][]

![4715743772d4f4cbfcef4c50b3ee583d.png][]

![1b636ebc72e6999f8a28456eed3d76e5.png][]

![ed782100734d749c7e289dc3bf9d9b96.png][]

![10c6b50585fb2edc1435cb508fab1d7b.png][]

**三.延迟队列代码落地**

![5c9e0b9caede56d48fe1b4a64ce6acb4.gif][]

using MengLin.Shopping.RabbitMQ.Common;
    using RabbitMQ.Client;
    using System;
    using System.Collections;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    
    namespace MengLin.Shopping.RabbitMQ.MsgProducer.QueueType.Delay
    {
        /// <summary>
        /// 延迟队列
        /// </summary>
        public class DelayQueue
        {
            public static void SendMessage()
            {
                //业务交换机
                var exchangeBusiness = "business-exchange";
                
                var queueBusinessSaoDiJiCommand = "SaoDiJiCommand-business-queue";//扫地机执行命令业务队列
                var routeKeyBusinessSaoDiJiCommand = "SaoDiJiCommand-business-routekey";//扫地机执行命令路由key
    
                var queueBusinessXiYiJiCommand = "XiYiJiCommand-business-queue";//洗衣机执行命令业务队列
                var routeKeyBusinessXiYiJiCommand = "XiYiJiCommand-business-routekey";//洗衣机执行命令路由key
    
                //死信交换机
                var exchangeDeadLetter = "deadLetter-exchange";
    
                //扫地机执行命令的延时队列和路由key
                var delaySaoDiJiCommandQueue = "SaoDiJiCommand-delay-queue";
                var routeKeyDelaySaoDiJi = "SaoDiJi-delay-routekey";
    
                //洗衣机执行命令的延时队列和路由key
                var delayXiYiJiCommandQueue = "XiYiJiCommand-delay-queue";
                var routeKeyDelayXiYiJi = "XiYiJi-delay-routekey";
    
                using (var connection = RabbitMQHelper.GetConnection())
                {
                    using (var channel = connection.CreateModel())
                    {
                        //创建死信交换机（死信交换机对交换机类型没有要求）
                        channel.ExchangeDeclare(exchange: exchangeDeadLetter, type: ExchangeType.Direct, durable: true, autoDelete: false);
    
                        //创建扫地机执行命令的延时队列
                        channel.QueueDeclare(queue: delaySaoDiJiCommandQueue, durable: true, exclusive: false, autoDelete: false);
    
                        //创建洗衣机执行命令的延时队列
                        channel.QueueDeclare(queue: delayXiYiJiCommandQueue, durable: true, exclusive: false, autoDelete: false);
    
                        //绑定死信交换机到扫地机执行命令的延时队列
                        channel.QueueBind(exchange: exchangeDeadLetter, queue: delaySaoDiJiCommandQueue, routingKey: routeKeyDelaySaoDiJi);
    
                        //绑定死信交换机到洗衣机执行命令的延时队列
                        channel.QueueBind(exchange: exchangeDeadLetter, queue: delayXiYiJiCommandQueue, routingKey: routeKeyDelayXiYiJi);
    
                        //创建业务交换机
                        channel.ExchangeDeclare(exchange: exchangeBusiness, type: ExchangeType.Direct, durable: true, autoDelete: false);
    
                        //创建扫地机命令业务队列
                        Dictionary<string, object> dic1 = new Dictionary<string, object>();
                        dic1.Add("x-expires", 30 * 6 * 10000); //30分钟后扫地机命令业务队列自动干掉
                        dic1.Add("x-message-ttl", 10 * 6 * 10000);//设置消息在扫地机命令业务队列中的存活时间，即过期时间（消息如果10分钟内没有消费，就会放入扫地机执行命令的延时队列里）
                        dic1.Add("x-dead-letter-exchange", exchangeDeadLetter);//过期消息转向路由  
                        dic1.Add("x-dead-letter-routing-key", routeKeyDelaySaoDiJi);//设置死信交换机的路由key，死信交换机会根据路由key去找到对应的延迟队列
                        channel.QueueDeclare(queue: queueBusinessSaoDiJiCommand, durable: true, exclusive: false, autoDelete: false, arguments:dic1);
                        //绑定业务交换机到扫地机命令业务队列
                        channel.QueueBind(queue: queueBusinessSaoDiJiCommand, exchange: exchangeBusiness, routingKey: routeKeyBusinessSaoDiJiCommand);
    
    
                        //创建洗衣机命令业务队列
                        Dictionary<string, object> dic2 = new Dictionary<string, object>();
                        dic2.Add("x-expires", 30 * 6 * 10000); //30分钟后洗衣机命令业务队列自动干掉
                        dic2.Add("x-message-ttl", 20 * 6 * 10000);//设置消息在洗衣机命令业务队列中的存活时间，即过期时间（消息如果20分钟内没有消费，就会放入洗衣机执行命令的延时队列里）
                        dic2.Add("x-dead-letter-exchange", exchangeDeadLetter);//过期消息转向路由  
                        dic2.Add("x-dead-letter-routing-key", routeKeyDelayXiYiJi);//过期消息转向路由相匹配routingkey  
                        channel.QueueDeclare(queue: queueBusinessXiYiJiCommand, durable: true, exclusive: false, autoDelete: false, arguments: dic2);
                        //绑定业务交换机到洗衣机命令业务队列
                        channel.QueueBind(queue: queueBusinessXiYiJiCommand, exchange: exchangeBusiness, routingKey: routeKeyBusinessXiYiJiCommand);
    
                        Console.WriteLine("请输入发送的内容:");
                        var message = Console.ReadLine();
                        var body = Encoding.UTF8.GetBytes(message);
                      
    
                        //消息持久化，既然都要用到死信队列了，说明这条消息还是比较重要的
                        var properties = channel.CreateBasicProperties();
                        properties.Persistent = true;
    
                        if(message.Contains("aa"))
                        {
                            //发布消息到扫地机命令业务队列
                            channel.BasicPublish(exchange: exchangeBusiness,
                                                 routingKey: routeKeyBusinessSaoDiJiCommand,
                                                 basicProperties: properties,
                                                 body: body);
                        }
                        else
                        {
                            //发布消息洗衣机命令业务队列
                            channel.BasicPublish(exchange: exchangeBusiness,
                                                 routingKey: routeKeyBusinessXiYiJiCommand,
                                                 basicProperties: properties,
                                                 body: body);
                        }
    
                    }
                }
            }
        }
    }

[aaacd31e90443f7d411ae1e06123e92a.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/8ec4936410734a29b6ca03c7ce01f4ed.png
[4715743772d4f4cbfcef4c50b3ee583d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/bdc9317f5c9746dd951888e8ed2a6904.png
[1b636ebc72e6999f8a28456eed3d76e5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/0b3e49352c2b40b4bf569e1ab38f8c84.png
[ed782100734d749c7e289dc3bf9d9b96.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/a2679b5f080044a5b696826b6ffa05fd.png
[10c6b50585fb2edc1435cb508fab1d7b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/b812e6f843a34105819cae4fc07d34ae.png
[5c9e0b9caede56d48fe1b4a64ce6acb4.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/a16cf80ab5104d54b6bb3eb44dad5eb3.png