public class RabbitServer: IRabbitMQ

    {

        private IConnection connection;

        private ConnectionFactory connectionFactory;

        public RabbitServer()

        {

            try

            {

                connectionFactory = new ConnectionFactory()

                {

                    UserName = Appsettings.app(new string[] { "RabbitMQConfig", "UserName" }),

                    Password = Appsettings.app(new string[] { "RabbitMQConfig", "Password" }),

                    HostName = Appsettings.app(new string[] { "RabbitMQConfig", "HostName" }),

                    AutomaticRecoveryEnabled= Convert.ToBoolean(Appsettings.app(new string[] { "RabbitMQConfig", "AutomaticRecoveryEnabled" })),

                    TopologyRecoveryEnabled= Convert.ToBoolean(Appsettings.app(new string[] { "RabbitMQConfig", "TopologyRecoveryEnabled" })),

                };

            }

            catch (Exception)

            {

                throw;

            }

        }

        public IConnection GetConnection()

        {

            return this.connectionFactory.CreateConnection();

        }

        /// <summary>

        /// RabbitMQ指定队列名称模式发送消息

        /// </summary>

        /// <param name="queuename">队列名字</param>

        /// <param name="obj">传输数据</param>

        public void SendData(string queuename, object obj)

        {

            connection = GetConnection();

            if (obj == null)

                return;

            if (connection == null)

                return;

            if (queuename.IsNullOrEmpty())

                return;

            using (connection)

            {

                using (var channel= connection.CreateModel())

                {

                    //声明一个队列    //队列模式   一共有四种

                    channel.QueueDeclare(queuename, false, false, false, null);

                    //第一个参数：预计大小，第二个参数每次读取几个，第三个参数是否本地

                    channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);

                    //交付模式

                    var prop = channel.CreateBasicProperties();

                    // 非持久性（1）或持久性（2）。

                    prop.DeliveryMode = 2;

                    //将对象转化为json字符串

                    var json = JsonConvert.SerializeObject(obj);

                    //将字符串转换为二进制

                    var bytes= Encoding.UTF8.GetBytes(json);

                    //开始传送

                    channel.BasicPublish("", queuename, prop,bytes);

                }

            }

        }

    }

//创建连接工厂

            ConnectionFactory factory = new ConnectionFactory

            {

                UserName = "wzw",

                Password = "wzw",

                HostName = "localhost"

            };

            //创建连接

            var connection = factory.CreateConnection();

            //创建通道

            var channel = connection.CreateModel();

            //接收到的消息处理事件

            EventingBasicConsumer Recipient = new EventingBasicConsumer(channel);

            Recipient.Received += (ch, ea) =>

            {

                var RecipientMsg = Encoding.UTF8.GetString(ea.Body);

                Console.WriteLine($"后台处理方法收到消息：{RecipientMsg}");

                //确认该消息已被处理

                channel.BasicAck(ea.DeliveryTag, false);

                Console.WriteLine($"消息已经处理【{ea.DeliveryTag}】");

            };

            channel.BasicConsume("hello", false, Recipient);

            Console.WriteLine("后台处理方法已启动");

            Console.ReadKey();

            channel.Dispose();

            connection.Close();