<\/div>\n

Merhaba,<\/p>\n

Bu i\u00e7eri\u011fimizde mesaj kuyruk sistemi olan RabbitMQ’da kuyruktaki mesajlar\u0131n se\u00e7icili\u011fini artt\u0131rmak i\u00e7in kullan\u0131lan Header Exchange \u00fczerine klavye oynat\u0131yor olaca\u011f\u0131z.<\/p>\n

Header Exchange \u00c7al\u0131\u015fma Mekanizmas\u0131 Nas\u0131ld\u0131r?<\/h3>\n
$\"RabbitMQ$ <\/a>
\nHeader Exchange i\u00e7in bir \u00f6nceki makalemizde ele ald\u0131\u011f\u0131m\u0131z Topic Exchange<\/a>‘in key – value olarak tan\u0131mlanan halidir diyebiliriz. Yani anlayaca\u011f\u0131n\u0131z g\u00f6nderilen mesajlar\u0131n routing key de\u011ferini topic exchange’de oldu\u011fu gibi .(nokta) ile de\u011filde, ilgili mesaj\u0131n header k\u0131sm\u0131ndan verilen key – value format\u0131nda de\u011fer ile olu\u015fturarak, bu keylerle e\u015fle\u015fen kuyruklara ileten bir exchange t\u00fcr\u00fcd\u00fcr.<\/p>\n

Kullan\u0131m\u0131<\/h3>\n

Publisher<\/h4>\n

\r\n        static void Main(string[] args)\r\n        {\r\n            ConnectionFactory factory = new ConnectionFactory();\r\n            factory.Uri = new Uri("amqp:\/\/hkhjerrt:hcqiavAqll6-co4abXnSqUBh_hHifz-Z@hornet.rmq.cloudamqp.com\/hkhjerrt");\r\n\r\n            using (IConnection connection = factory.CreateConnection())\r\n            using (IModel channel = connection.CreateModel())\r\n            {\r\n                channel.ExchangeDeclare("headerexchange", type: ExchangeType.Headers);\r\n                for (int i = 1; i <= 100; i++)\r\n                {\r\n                    byte[] bytemessage = Encoding.UTF8.GetBytes($"{i}. mesaj");\r\n\r\n                    IBasicProperties properties = channel.CreateBasicProperties();\r\n                    properties.Persistent = true;\r\n                    properties.Headers = new Dictionary<string, object>()\r\n                    {\r\n                        ["no"] = args[0] == "1" ? "123456" : "654321"\r\n                    };\r\n\r\n\r\n                    channel.BasicPublish(exchange: "headerexchange", routingKey: string.Empty, basicProperties: properties, body: bytemessage);\r\n                }\r\n            }\r\n        }\r\n<\/pre>\nYukar\u0131daki \u00f6rnek kod blo\u011funda 16.<\/strong><\/em> sat\u0131r\u0131 incelerseniz e\u011fer g\u00f6nderilecek mesaja dair gerekli ayarlar\u0131 yapmam\u0131z\u0131 sa\u011flayan “IBasicProperties” t\u00fcr\u00fcnden nesnemiz \u00fczerinden “Headers” propertysine verilen ‘Dictionary’ koleksiyonunda ‘no’ keyine kar\u015f\u0131l\u0131k d\u0131\u015far\u0131dan verilen arg\u00fcman valuesuna g\u00f6re ‘123456’ ya da ‘654321’ de\u011ferleri girilmektedir. B\u00f6ylece ‘1’ arg\u00fcman de\u011feri verilen publisherlar {key :’no’, value :’123456′}<\/em> header de\u011ferine e\u015fde\u011fer routing key’e sahip kuyruklara mesaj iletecekken di\u011fer arg\u00fcman de\u011ferlerindeki publisherlar ise {key :’no’, value :’654321′}<\/em> header de\u011ferindeki kuyruklara iletecektirler.<\/p>\nConsumer<\/h4>\nDi\u011fer exchange t\u00fcrlerine nazaran Header Exchange’te kuyruk manuel olu\u015fturularak haz\u0131r hale getirilmelidir.<\/p>\n\r\n        static void Main(string[] args)\r\n        {\r\n            ConnectionFactory factory = new ConnectionFactory();\r\n            factory.Uri = new Uri("amqp:\/\/hkhjerrt:hcqiavAqll6-co4abXnSqUBh_hHifz-Z@hornet.rmq.cloudamqp.com\/hkhjerrt");\r\n\r\n            using (IConnection connection = factory.CreateConnection())\r\n            using (IModel channel = connection.CreateModel())\r\n            {\r\n                channel.ExchangeDeclare("headerexchange", type: ExchangeType.Headers);\r\n\r\n                channel.QueueDeclare($"kuyruk-{args[0]}", false, false, false, null);\r\n\r\n                channel.QueueBind(queue: $"kuyruk-{args[0]}", exchange: "headerexchange", routingKey: string.Empty, new Dictionary<string, object>\r\n                {\r\n                    ["x-match"] = "all",\r\n                    ["no"] = args[0] == "1" ? "123456" : "654321",\r\n                });\r\n\r\n                channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);\r\n\r\n                EventingBasicConsumer consumer = new EventingBasicConsumer(channel);\r\n                channel.BasicConsume($"kuyruk-{args[0]}", false, consumer);\r\n                consumer.Received += (sender, e) =>\r\n                {\r\n                    Console.WriteLine($"{Encoding.UTF8.GetString(e.Body)}. mesaj");\r\n                    channel.BasicAck(e.DeliveryTag, false);\r\n                };\r\n                Console.Read();\r\n            }\r\n        }\r\n<\/pre>\nYukar\u0131daki kod blo\u011funa g\u00f6z atarsan\u0131z 11.<\/em><\/strong> sat\u0131rda manuel bir kuyruk olu\u015fturulmakta ve 13.<\/em><\/strong> sat\u0131rda bu kuyru\u011fa ilgili exchange ile birlikte header bilgileri set edilerek bind edilmektedir. Yine burada publisherda oldu\u011fu gibi verilen arg\u00fcman de\u011ferine g\u00f6re key – value verisindeki value k\u0131sm\u0131 belirlenecek ve e\u015fle\u015fen kuyruk hangisi ise mesajlar\u0131 o anki consumer taraf\u0131ndan t\u00fcketilecektir.<\/p>\n
Burada header’a verilen ‘x-match’ key de\u011ferine dikkatinizi \u00e7ekerim. ‘x-match’; ‘all’ veya ‘any’ olmak \u00fczere iki de\u011fer alabilen ve fonksiyonel olarak header de\u011ferlerinden herhangi biriyle yahut hepsiyle e\u015fle\u015fme durumunu kontrol edip duruma g\u00f6re ilgili consumer\u0131 ilgili kuyru\u011fa subscribe eden bir niteli\u011fe sahiptir.<\/p>\nTest<\/h3>\nUygulamay\u0131 derleyip \u00e7al\u0131\u015ft\u0131rd\u0131\u011f\u0131m\u0131zda hornet.rmq.cloudamqp.com<\/a> adresindeki cloud servisine g\u00f6z att\u0131\u011f\u0131m\u0131zda header exchange’in olu\u015fturuldu\u011funu g\u00f6rebilmekteyiz.
\n<\/a><\/p>\n
<\/a>
\nNihai olarak g\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere kuyruklardaki key – value de\u011feri ile e\u015fle\u015fen consumerlar ilgili mesajlar\u0131 t\u00fcketmekte ve i\u015flemektedirler. B\u00f6ylece publisherlar hedef consumerlara mesaj\u0131 ileterek en ba\u015fta vurgulad\u0131\u011f\u0131m\u0131z se\u00e7icili\u011fi artt\u0131rm\u0131\u015f ve i\u015f b\u00f6l\u00fcm\u00fcn\u00fc net sa\u011flam\u0131\u015f bulunmaktad\u0131rlar.<\/p>\n
\u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle…
\nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere…
\n\u0130yi \u00e7al\u0131\u015fmalar… <\/p>\n
Not : \u00d6rnek projeyi indirebilmek i\u00e7in buraya<\/a> t\u0131klay\u0131n\u0131z.<\/p>\n","protected":false},"excerpt":{"rendered":"
Merhaba, Bu i\u00e7eri\u011fimizde mesaj kuyruk sistemi olan RabbitMQ’da kuyruktaki mesajlar\u0131n se\u00e7icili\u011fini artt\u0131rmak i\u00e7in kullan\u0131lan Header Exchange \u00fczerine klavye oynat\u0131yor olaca\u011f\u0131z. Header Exchange \u00c7al\u0131\u015fma Mekanizmas\u0131 Nas\u0131ld\u0131r? Header Exchange i\u00e7in bir \u00f6nceki makalemizde ele ald\u0131\u011f\u0131m\u0131z Topic...<\/p>\n","protected":false},"author":1,"featured_media":13913,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3156],"tags":[3230,3158,3231],"class_list":["post-13911","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-rabbitmq","tag-header-exchange","tag-rabbitmq","tag-rabbitmq-header-exchange"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13911","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/comments?post=13911"}],"version-history":[{"count":27,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13911\/revisions"}],"predecessor-version":[{"id":13942,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13911\/revisions\/13942"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/13913"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=13911"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=13911"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=13911"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}