RabbitMQ案例(入门级)

【实例截图】

【核心代码】

using RabbitMQ.Client;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApplication2
{


    /// <summary>
    /// --------------
    /// 生产者
    /// --------------
    /// </summary>
    class Program
    {


        const string ExchangeName = "test.exchange";
        const string QueueName = "test.queue";

        /// <summary>
        /// 生产者
        /// </summary>
        /// <param name="args"></param>
        static void Main(string[] args)
        {
            ConnectionFactory rabbitMqFactory = new ConnectionFactory { HostName = "localhost", UserName = "test01", Password = "test01", VirtualHost = "VH" };
            using (IConnection conn = rabbitMqFactory.CreateConnection())
            using (IModel channel = conn.CreateModel())
            {
                //声明消息队列，且为可持久化的
                channel.ExchangeDeclare(ExchangeName, "direct", durable: true, autoDelete: false, arguments: null);
                //声明消息队列，且为可持久化的
                channel.QueueDeclare(QueueName, durable: true, exclusive: false, autoDelete: false, arguments: null);
                //绑定队列
                channel.QueueBind(QueueName, ExchangeName, routingKey: QueueName);
                //将队列设置为持久化之后，还需要将消息也设为可持久化的
                
                var props = channel.CreateBasicProperties();
               // props.SetPersistent(true);        
                props.DeliveryMode = 2;


                for (int i = 0; i < 18000; i  )
                {
                   // System.Threading.Thread.Sleep(5000);
                    props.Priority = (i == 5) ? (byte)10 : (byte)i;

                    string message = "测试测试"   i.ToString();
                   
                    var body = Encoding.UTF8.GetBytes(message);

                    //发布信息
                    channel.BasicPublish(exchange: ExchangeName, routingKey: QueueName, basicProperties: props, body: body);
                    Console.WriteLine("Program Sent {0}", message);
                }
                channel.Close();
                conn.Close();
            }
            Console.WriteLine("OK-生产者...............");
        }
    }
}