RabbitMQ巩固学习一

docker pull rabbitmq:management
docker run -d -p 15672:15672 -p 5672:5672 --name rabbitmq rabbitmq:management

docker exec -it rabbitmq bash --进入容器
rabbitmq-plugins enable rabbitmq_management --开启插件命令

static void Main(string[] args)
{
    //创建连接工厂
    var factory = new ConnectionFactory
    {
        UserName = "guest",//用户名
        Password = "guest",//密码
        HostName = "***.**.***.***",//rabbitmq ip
        Port = 5672,//端口号
    };
    //创建连接
    var connection = factory.CreateConnection();
    //创建信道
    var channel = connection.CreateModel();
    //创建一个队列,名称为:RabbitMQStudy
    channel.QueueDeclare("RabbitMQStudy", false, false, false, null);
    Console.WriteLine("已连接到RabbitMQ.^-^,可向队列投递消息!");
    Console.WriteLine("输入close则关闭连接");
    string text = string.Empty;
    bool flag = true;
    while (flag)
    {
        Console.WriteLine("请输入数据......");
        text = Console.ReadLine();
        switch (text)
        {
            case "close":
                flag = false;
                continue;
            default:
                flag = true;
                break;
        }
        var bytes = Encoding.UTF8.GetBytes(text);
        //发布消息
        channel.BasicPublish("", "RabbitMQStudy", null, bytes);
        Console.WriteLine("消息已发送成功!");
        Console.WriteLine(new string(‘-‘, 100));
    }
    Console.WriteLine("连接已关闭......");
    //关闭资源
    channel.Close();
    //释放连接
    connection.Close();
}

static void Main(string[] args)
{
    //创建连接工厂
    ConnectionFactory factory = new ConnectionFactory
    {
        UserName = "guest",//用户名
        Password = "guest",//密码
        HostName = "***.**.***.***",//rabbitmq ip
        Port = 5672,//端口号
    };
    //创建连接
    var connection = factory.CreateConnection();
    //创建信道
    var channel = connection.CreateModel();

    //var consumer = new DefaultBasicConsumer(channel);
    var consumer = new EventingBasicConsumer(channel);
    //为消费者送达消息时产生的事件
    consumer.Received += (ch, ea) =>
    {
        var message = ea.Body.ToArray();//接收到的消息
        Console.WriteLine($"接收到信息:{Encoding.UTF8.GetString(message)}");
        //消息已被消费
        channel.BasicAck(ea.DeliveryTag, false);
        Console.WriteLine("消息已成功接收并消费!");
        Console.WriteLine(new string(‘-‘, 100));
    };
    //启动消费者并设置为手动应答
    String consumerTag = channel.BasicConsume("RabbitMQStudy", false, consumer);
    Console.WriteLine("消费者已启动成功!");
    Console.ReadKey();
    channel.Dispose();
    connection.Close();
} 

交换器一共有四种类型:1.fanout:此类型的交换器会将发送到该交换器的的消息路由到所有与该交换器绑定的队列中
                  2.directc:如果交换器类型为direct类型,那么RoutingKey(路由键,相当于消息投送至与交换器绑定的哪个队列)和BindingKey(绑定键,交换器与队列相绑定有一个BindingKey)需要完全匹配(相同)。
                  3.topic:topic是升级版的direct类型的交换器,与direct类型交换器相同的是topic类型的交换器也是将消息路由到RoutingKey与BindingKey相匹配的队列中。与direct类型交换器不同的是topic类型的交换器有模糊匹配。 例如:我们发送消息时会路由到指定RouteKey队列中.交换器在与队列绑定的时候,BindingKey可以是模糊类型的.RouteKey和BindingKey都是以点号“.”分割的字符串.BindingKey的字符串可以存在“ * ”和“ # ”特殊字符。在以点号“ . ”为分割的字符串中，“ . ”用于匹配一个单词," # "用于匹配多个(或零个)单词.
                  4.headers:这个交换器我在这里不做介绍,我没用过??,上面介绍的三个是最常用的了。

//和上面一样,代码省略...
//创建一个队列,名称为:RabbitMQStudy
channel.QueueDeclare("RabbitMQStudy", false, false, false, null);
//创建一个队列,名称为:RabbitMQStudy1
channel.QueueDeclare("RabbitMQStudy1", false, false, false, null);
//声明一个交换器
channel.ExchangeDeclare("exange", "topic", true, false, null);
//绑定
channel.QueueBind("RabbitMQStudy", "exange","#.routeKey");
//绑定
channel.QueueBind("RabbitMQStudy1", "exange", "*.com");

//和上面一样,代码省略...

//发布消息 
channel.BasicPublish("exange", "core.routeKey", null, bytes); 

//和上面一样,代码省略...

 //启动消费者并设置为手动应答
 String consumerTag = channel.BasicConsume("RabbitMQStudy1", false, consumer);

争对上述代码及文字我们来总结一下

消息队列的优缺点：1.解耦,我上面提到了,消费者只需要拿数据,数据的投递方是谁它一点都不过问。
               2.削峰.当我们设计一个秒杀业务的时候,加入成千上万的请求涌入,服务器的压力过大。为了缓解压力我们可以将请求先放入队列中,服务器一定时间内可以承受多少请求就拿多少。
               3.异步.我上面也提到了.直接从消息队列中拿数据,无需排队等候,大大提高了系统性能。

RabbitMQ的使用过程:生产者：1.先创建连接工厂,与RabbitMQ建立连接。
                        2.创建信道。
                        3.声明一个交换器,设置交换器类型、是否持久化等。
                        4.声明队列,设置队列是否排他、是否持久化等。
                        5.将交换器与队列绑定,设置RouteKey。
                        6.发送消息至交换器,并设置交换器名称、路由键、消息主体等。
                        7.交换器根据路由键和绑定的队列相匹配,投送消息至队列中。
                        8.如果没有找到相应队列,会根据生产者配置的属性丢弃消息或者退回给生产者。
                        9.关闭连接。

                  消费者:1.先创建连接工厂,与RabbitMQ建立连接。
                        2.创建信道。
                        3.等待生产者投递消息至队列,消费者接收消息。
                        4.消费者确认接收到消息
                        5.RabbitMQ从队列中删除已确认的消息。
                        6.关闭连接。