Headers Exchange

headers也是一種交換機(jī)類型，但是在rabbitmq官網(wǎng)中的教程中并沒有說到。資料也很少，但是找一找總會(huì)有的。

headers與direct的模式不同，不是使用routingkey去做綁定。而是通過消息headers的鍵值對匹配

發(fā)布者? -- >? headersexchange? -->? (user:? “小明 ”) binding? --> queue

也就是說 user: 小明 替代了之前的routingkey。在做綁定的時(shí)候有兩種匹配方式供選擇。x-match (all/any)

意思就是鍵值對中所有的項(xiàng)都要匹配與只要有一個(gè)匹配就可以。下面就可以動(dòng)手寫代碼了

?

在生產(chǎn)消息的時(shí)候，我們往消息的headers中附加了user:admin,pwd:123456

//創(chuàng)建返回一個(gè)新的頻道using (var channel = RabbitMqHelper.GetConnection().CreateModel()){//創(chuàng)建propertiesvar properties = channel.CreateBasicProperties();//往內(nèi)容的headers中塞入值 properties.Headers = new Dictionary<string, object>(){{"user","admin" },{"pwd","123456" }};//發(fā)布一個(gè)消息var msg = Encoding.UTF8.GetBytes($"二狗子");channel.BasicPublish("headersExchange", routingKey: string.Empty, basicProperties: properties,body: msg);Console.Write("發(fā)布成功！");}Console.ReadKey();

在consumer中，我們可以選擇創(chuàng)建兩種方式，any/all。綁定的時(shí)候我們放了一些匹配項(xiàng)在里面，也就是如果 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;elseConsole.Write("請做出正確的選擇");}using (var channel = RabbitMqHelper.GetConnection().CreateModel()){//根據(jù)聲明使用的隊(duì)列var headersType = pattern == "1" ? "any" : "all";//聲明交換機(jī) headers模式channel.ExchangeDeclare("headersExchange", ExchangeType.Headers, true, false);channel.QueueDeclare("headersQueue", true, false, false, null);//進(jìn)行綁定channel.QueueBind("headersQueue", "headersExchange", string.Empty, new Dictionary<string, object>{//第一個(gè)匹配格式 ，第二與第三個(gè)則是匹配項(xiàng){ "x-match",headersType},{ "user","admin"},{ "pwd","123456"}});//創(chuàng)建consumbersvar consumer = new EventingBasicConsumer(channel);consumer.Received += (sender, e) =>{var msg = Encoding.UTF8.GetString(e.Body);Console.WriteLine($"{msg}");};//進(jìn)行消費(fèi)channel.BasicConsume("headersQueue", true, consumer);Console.ReadKey();}

?

這里實(shí)驗(yàn)一個(gè)all類型的，首先把consumer運(yùn)行起來，第一次我們的生產(chǎn)者的headers中只一個(gè)項(xiàng)匹配,可以看到消息是發(fā)布出去了，但是consumer并沒有從queue中收到，也就是這邊是不匹配的 exchange并沒有把消息推到queue。

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

?

這時(shí)再把生產(chǎn)者的headers中user也加上,現(xiàn)在是完全匹配的再發(fā)布一次消息,發(fā)布的消息被consumer消費(fèi)掉了

轉(zhuǎn)載于:https://www.cnblogs.com/LiangSW/p/6201940.html

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ headers Exchange的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。