Cacher is the code snippet organizer for pro developers

//HTTP API发送指定 http://localhost:15672/api/channels 返回查询信息
private Func<string, string> GetCount = (m) =>
 {
     string url = m;
     // 创建HttpWebRequest对象
     HttpWebRequest httpRequest = (HttpWebRequest)WebRequest.Create(url);
     // 设置GET调用方法
     httpRequest.Method = "GET";
     // 设置HTTP头Http Basic认证
     string authorization = "guest" + ":" + "guest";
     string base64 = Convert.ToBase64String(Encoding.Default.GetBytes(authorization));
     httpRequest.Headers.Add("Authorization", "Basic " + base64);

     // HttpWebRequest发起调用
     using (HttpWebResponse myResponse = (HttpWebResponse)httpRequest.GetResponse())
     {
         // StreamReader对象
         StreamReader sr = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8);
         // 返回结果
         string responseString = sr.ReadToEnd();
         return responseString;
     }
 };

//消费者注册方式
var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.UserName = "guest";
factory.Password = "guest";

using (var connection = factory.CreateConnection())
{
    using (var channel = connection.CreateModel())
    {
        channel.QueueDeclare("QueueA", false, false, false, null);

        /* 这里定义了一个消费者，用于消费服务器接受的消息
         * C#开发需要注意下这里，在一些非面向对象和面向对象比较差的语言中，是非常重视这种设计模式的。
         * 比如RabbitMQ使用了生产者与消费者模式，然后很多相关的使用文章都在拿这个生产者和消费者来表述。
         * 但是，在C#里，生产者与消费者对我们而言，根本算不上一种设计模式，他就是一种最基础的代码编写规则。
         * 所以，大家不要复杂的名词吓到，其实，并没那么复杂。
         * 这里，其实就是定义一个EventingBasicConsumer类型的对象，然后该对象有个Received事件，该事件会在服务接收到数据时触发。
         */ 
        var consumer = new EventingBasicConsumer(channel);//消费者 
        channel.BasicConsume("QueueA", true, consumer);//消费消息 autoAck参数为消费后是否删除
        consumer.Received += (model, ea) =>
        {
            var body = ea.Body;
            var message = Encoding.UTF8.GetString(body);
            Console.WriteLine("Received： {0}", message);
        };
        Console.ReadLine();
    }
}

//消费旧的普通模式
ConnectionFactory factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.UserName = "guest";
factory.Password = "guest";
// factory.Port = 15672;

using (IConnection conn = factory.CreateConnection())
 {
  using (var channel = conn.CreateModel())
  {
      channel.QueueDeclare("QueueA", false, false, false, null);//在MQ上定义一个持久化队列，如果名称相同不会重复创建
      channel.BasicQos(0, 1, false);              //输入1，那如果接收一个消息，但是没有应答，则客户端不会收到下一个消息
      //var consumer = new EventingBasicConsumer(channel);//消费者新的方式
      QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);   //在队列上定义一个消费者
      channel.BasicConsume("QueueA", false, consumer); //消费队列，并设置应答模式为程序主动应答
      while (true)
      {
          BasicDeliverEventArgs ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();  //阻塞函数，获取队列中的消息
          byte[] bytes = ea.Body;
          string message = Encoding.UTF8.GetString(bytes);
          channel.BasicAck(ea.DeliveryTag, false); //回复确认
          Console.WriteLine(message);
      }
  }
}

//Microsoft.Diagnostics.Tracing.EventSource.dll
//RabbitMQ.Client.dll
//rabbitmqctl stop_app 停止服务，会清除queue
//rabbitmqctl start_app 开启服务
//rabbitmqctl list_queues 查询当前队列
//rabbitmqctl purge_queue kibaQueue 清空指定queue队列的数据
var factory = new ConnectionFactory();
factory.HostName = "localhost";//主机名，Rabbit会拿这个IP生成一个endpoint，这个很熟悉吧，就是socket绑定的那个终结点。
factory.UserName = "guest";//默认用户名,用户可以在服务端自定义创建，有相关命令行
factory.Password = "guest";//默认密码

using (var connection = factory.CreateConnection())//连接服务器，即正在创建终结点。
{
    //创建一个通道，这个就是Rabbit自己定义的规则了，如果自己写消息队列，这个就可以开脑洞设计了
    //这里Rabbit的玩法就是一个通道channel下包含多个队列Queue
    using (var channel = connection.CreateModel())
    {
        for (int i = 0; i < 100; i++)
        {
            channel.QueueDeclare("kibaQueue", false, false, false, null);//创建一个名称为kibaQueue的消息队列
            var properties = channel.CreateBasicProperties();
            properties.DeliveryMode = 1;
            string message = "I am Kiba518"; //传递的消息内容 
            channel.BasicPublish("", "kibaQueue", properties, Encoding.UTF8.GetBytes(message)); //生产消息
            Console.WriteLine($"Send:{message}");
            Thread.Sleep(3000);
        }
    }
}