【rabbitMQ】-延遲佇列-模擬控制智慧家居的操作指令

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);
                    }

                }
            }
        }
    }
}