.net Framework 4.5 MVC4 + RabbitMQ

1.首先在本地安装好RabbitMQ环境

2.因为不是.net core 所以要下载对应的dll版本 地址 https://www.nuget.org/packages/RabbitMQ.Client/3.4.3

 3.在项目进行引用

 

 

 4.编写 发布  订阅 代码 这里的UserName 用通用账号登录 guest

    public class RabbitMQCommon
    {
        /// <summary>
        /// 发送
        /// </summary>
        /// <param name="message"></param>
        public static void MQSend(string message)
        {
            try
            {
                ConnectionFactory factory = new ConnectionFactory();
                factory.HostName = "localhost";
                factory.UserName = "guest";
                factory.Password = "guest";

                using (var connection = factory.CreateConnection())
                {
                    using (var channel = connection.CreateModel())
                    {

                        bool durable = true;
                        channel.QueueDeclare("task_queue", durable, false, false, null);

                        var properties = channel.CreateBasicProperties();
                        properties.SetPersistent(true);

                        var body = Encoding.UTF8.GetBytes(message);
                        channel.BasicPublish("", "task_queue", properties, body);
                    }
                }
            }
            catch (Exception ex)
            {
                Log.Instance.Write(ex.ToString(), "MQSend_Err");
            }
        }
        /// <summary>
        /// 接收
        /// </summary>
        public static void MQReceive()
        {
            try
            {
                var factory = new ConnectionFactory();
                factory.HostName = "localhost";
                factory.UserName = "guest";
                factory.Password = "guest";

                using (var connection = factory.CreateConnection())
                {
                    using (var channel = connection.CreateModel())
                    {
                        bool durable = true;
                        channel.QueueDeclare("task_queue", durable, false, false, null);
                        channel.BasicQos(0, 1, false);

                        var consumer = new QueueingBasicConsumer(channel);
                        channel.BasicConsume("task_queue", false, consumer);

                        while (true)
                        {
                            var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();

                            var body = ea.Body;
                            var message = Encoding.UTF8.GetString(body);

                            int dots = message.Split('.').Length - 1;
                            Thread.Sleep(dots * 1000);


                            DAL.Log.Instance.Write(message, "MQReceive");

                            channel.BasicAck(ea.DeliveryTag, false);
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                Log.Instance.Write(ex.ToString(), "MQReceive_Err");
            }
        }
    }