var factory = new ConnectionFactory() { HostName = "127.0.0.1", UserName = "test", Password = "test" };
      using (var connection = factory.CreateConnection())
      {
        while (Console.ReadLine() != null)
        {
          using (var channel = connection.CreateModel())
          {

            Dictionary<string, object> dic = new Dictionary<string, object>();
            dic.Add("x-expires", 30000);
            dic.Add("x-message-ttl", 12000);//隊列上消息過期時間，應小于隊列過期時間 
            dic.Add("x-dead-letter-exchange", "exchange-direct");//過期消息轉(zhuǎn)向路由 
            dic.Add("x-dead-letter-routing-key", "routing-delay");//過期消息轉(zhuǎn)向路由相匹配routingkey 
            //創(chuàng)建一個名叫"zzhello"的消息隊列
            channel.QueueDeclare(queue: "zzhello",
              durable: true,
              exclusive: false,
              autoDelete: false,
              arguments: dic);

            var message = "Hello World!";
            var body = Encoding.UTF8.GetBytes(message);

            //向該消息隊列發(fā)送消息message
            channel.BasicPublish(exchange: "",
              routingKey: "zzhello",
              basicProperties: null,
              body: body);
            Console.WriteLine(" [x] Sent {0}", message);
          }
        }
      }

      Console.ReadKey();

 var factory = new ConnectionFactory() { HostName = "127.0.01", UserName = "test", Password = "test" };

      using (var connection = factory.CreateConnection())
      {
        using (var channel = connection.CreateModel())
        {
          channel.ExchangeDeclare(exchange: "exchange-direct", type: "direct");
          string name = channel.QueueDeclare().QueueName;
          channel.QueueBind(queue: name, exchange: "exchange-direct", routingKey: "routing-delay");

          //回調(diào)，當consumer收到消息后會執(zhí)行該函數(shù)
          var consumer = new EventingBasicConsumer(channel);
          consumer.Received += (model, ea) =>
          {
            var body = ea.Body;
            var message = Encoding.UTF8.GetString(body);
            Console.WriteLine(ea.RoutingKey);
            Console.WriteLine(" [x] Received {0}", message);
          };

          //Console.WriteLine("name:" + name);
          //消費隊列"hello"中的消息
          channel.BasicConsume(queue: name,
                     autoAck: true,
                     consumer: consumer);

          Console.WriteLine(" Press [enter] to exit.");
          Console.ReadLine();
        }
      }

      Console.ReadKey();