RabbitMq学习一入门篇（hello world）

 public static void RunSend()
        {
            ConnectionFactory connectionFactory = new ConnectionFactory()
            {
                HostName = "192.168.35.129",
                Port = 5672,
                Password = "123",
                UserName = "mquser"
            };

            //建立连接rabbitmq 消息代理服务器。
            using (IConnection conn = connectionFactory.CreateConnection())
            {
                //创建Channel对象
                using (IModel channel = conn.CreateModel())
                {
                    //声明队列  
                    channel.QueueDeclare("hello", durable: false,
                        exclusive: false,
                        autoDelete: false,
                        arguments: null);
                    //消息 ，此处是简单的字符串，你也可以定义复杂的消息体
                    string msg = "Hello World";

                    var body = Encoding.UTF8.GetBytes(msg);

                    //把消息放到队列中
                    channel.BasicPublish(exchange:"",
                        routingKey:"hello",
                        basicProperties:null,
                        body:body);

                    Console.WriteLine("send {0}",msg);

                }
            }
        }

public static void RunReceive()
        {

            ConnectionFactory connectionFactory = new ConnectionFactory()
            {
                HostName = "192.168.35.129",
                Port = 5672,
                Password = "123",
                UserName = "mquser"
            };
            using (IConnection conn = connectionFactory.CreateConnection())
            {

                using (IModel channel = conn.CreateModel())
                {
                    //注意：在 send.CS 中也声明了队列Hello，这里为什么要再次声明
                    //第一：QueueDeclare 实现了幂等性，创建的时候如果已经存在，就不会再次创建。
                    //第二：因为 两边都进行创建，不用考虑 生产者 和消费者 启动的顺序了。
                    channel.QueueDeclare("hello", durable: false,
                        exclusive: false,
                        autoDelete: false,
                        arguments: null);

                    //创建事件驱动的消费者类型；建议使用此种方式，不要使用while（true）
                    //理由吗 哈哈 看看王清培的博客吧。不稳定不优雅。。。 
                    var consumer = new EventingBasicConsumer(channel);
                    consumer.Received += (sender, e) =>
                    {
                        var body = e.Body;
                        var message = Encoding.UTF8.GetString(body);
                        Console.WriteLine(" [x] Received {0}", message);
                    };

                    channel.BasicConsume(queue: "hello",
                                noAck: true,
                                consumer: consumer);

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