Headers Exchange

headers也是一种交换机类型，但是在rabbitmq官网中的教程中并没有说到。资料也很少，但是找一找总会有的。

headers与direct的模式不同，不是使用routingkey去做绑定。而是通过消息headers的键值对匹配

发布者  -- >  headersexchange  -->  (user:  “小明 ”) binding  --> queue

也就是说 user: 小明 替代了之前的routingkey。在做绑定的时候有两种匹配方式供选择。x-match (all/any)

意思就是键值对中所有的项都要匹配与只要有一个匹配就可以。下面就可以动手写代码了

 

在生产消息的时候，我们往消息的headers中附加了user:admin,pwd:123456

//创建返回一个新的频道            using (var channel = RabbitMqHelper.GetConnection().CreateModel())            {                //创建properties                var properties = channel.CreateBasicProperties();                //往内容的headers中塞入值                 properties.Headers = new Dictionary
       
        ()                {                    {"user","admin" },                    {"pwd","123456" }                };                //发布一个消息                var msg = Encoding.UTF8.GetBytes($"二狗子");                channel.BasicPublish("headersExchange", routingKey: string.Empty, basicProperties: properties,body: msg);                Console.Write("发布成功！");            }            Console.ReadKey();
       

在consumer中，我们可以选择创建两种方式，any/all。绑定的时候我们放了一些匹配项在里面，也就是如果 user:admin、pwd:123456 headers类型的exchange就可以把消息推到queue中

bool flag = true;            string pattern = "";            while (flag)            {                Console.WriteLine("请选择headers匹配模式  1(any)/2(all)");                pattern = Console.ReadLine();                if (pattern == "1" || pattern == "2")                    flag = false;                else                    Console.Write("请做出正确的选择");            }            using (var channel = RabbitMqHelper.GetConnection().CreateModel())            {                //根据声明使用的队列                var headersType = pattern == "1" ? "any" : "all";                //声明交换机 headers模式                channel.ExchangeDeclare("headersExchange", ExchangeType.Headers, true, false);                channel.QueueDeclare("headersQueue", true, false, false, null);                //进行绑定                channel.QueueBind("headersQueue", "headersExchange", string.Empty, new Dictionary
       
                        {                    //第一个匹配格式 ，第二与第三个则是匹配项                    { "x-match",headersType},                    { "user","admin"},                    { "pwd","123456"}                });                //创建consumbers                var consumer = new EventingBasicConsumer(channel);                consumer.Received += (sender, e) =>                {                    var msg = Encoding.UTF8.GetString(e.Body);                    Console.WriteLine($"{msg}");                };                //进行消费                channel.BasicConsume("headersQueue", true, consumer);                Console.ReadKey();            }
       

 

这里实验一个all类型的，首先把consumer运行起来，第一次我们的生产者的headers中只一个项匹配,可以看到消息是发布出去了，但是consumer并没有从queue中收到，也就是这边是不匹配的 exchange并没有把消息推到queue。

在webui中也是可以看到queue中是没有任何消息的

 

这时再把生产者的headers中user也加上,现在是完全匹配的再发布一次消息,发布的消息被consumer消费掉了