rabbitMQ的三种路由模式

rabbitMQ工作流程：

1、声明交换机

2、声明消息队列

3、绑定交换机和队列

4、生产者往交换机里发送新消息

5、交换机根据所选的模式和routingKey决定消息发往哪条消息队列

6、一个消费者只能消费一条消息队列

（如果重复声明，类型参数不变不会报错。 如果第二次声明和第一次类型参数有变化，会报异常） 

上代码：

            var factory = new ConnectionFactory();
            factory.UserName = "guest";
            factory.Password = "guest";
            factory.HostName = "127.0.0.1"; //设置RabbitMQ服务器所在的IP或主机名
            var connection = factory.CreateConnection();

            using (IModel channel = connection.CreateModel())
            {
                //声明一个交换机
                channel.ExchangeDeclare(exchange: "exchange1",
                                        type: ExchangeType.Topic,
                                        durable: true,
                                        autoDelete: false,
                                        arguments: null);

                //声明三个消息队列
                channel.QueueDeclare(
                    queue: "q1",
                    durable: true,
                    exclusive: false,
                    autoDelete: false,
                    arguments: null);

                channel.QueueDeclare(
                    queue: "q2",
                    durable: true,
                    exclusive: false,
                    autoDelete: false,
                    arguments: null);

                channel.QueueDeclare(
                    queue: "q3",
                    durable: true,
                    exclusive: false,
                    autoDelete: false,
                    arguments: null);

                //用不同的routingKey绑定队列与交换机
                channel.QueueBind(queue: "q1",
                                    exchange: "exchange1",
                                    routingKey: "person.name.*",
                                    arguments: null);

                channel.QueueBind(queue: "q2",
                                    exchange: "exchange1",
                                    routingKey: "person.age.*",
                                    arguments: null);

                channel.QueueBind(queue: "q3",
                                    exchange: "exchange1",
                                    routingKey: "person.#",
                                    arguments: null);


                //往交换机中发出一条消息
                channel.BasicPublish(
                        exchange: "exchange1",
                        routingKey: "person.name.jerry",
                        basicProperties: null,
                        body: Encoding.UTF8.GetBytes(msg));   

 三种常用路由模式：

1、Direct

这种模式下，交换机根据routingKey进行完全匹配。如果匹配失败则丢弃消息。

例如：绑定的交换机routingKey是"person.name"，而使用BasicPublish()方法往交换机发消息时用的"person.name"则匹配成功，将根据交换机名称和routingKey找到绑定的消息队列，并发送新消息。

2、Fanout

这种模式会完全忽略routingKey。

只要往交换机1中发送消息，则会广播到与交换机1绑定的所有消息队列。

3、Topic

这种模式下可以对routingKey进行模糊匹配，如果匹配失败则丢弃消息，如果匹配多个结果，则往多个结果都发送消息。

类似于正则表达式， 它有两种语法：“*”,"#"

"*"只匹配当前级别的词，如"person.*"可以匹配"person.name"，无法匹配"person.name.jerry"。无法匹配空，如"person"。

"#"能匹配多个子级别的词，如"person.#"可以匹配"person.name"，也可以匹配"person.name.jerry"。可以匹配空，如"person"。