<\/div>\n

Merhaba,<\/p>\n

RabbitMQ yaz\u0131 dizimizde<\/a> exchange t\u00fcrleri aras\u0131ndan s\u0131ra Direct Exchange’e gelmi\u015f bulunmaktad\u0131r. \u015eimdi gelin hi\u00e7 vakit kaybetmeksizin ilgili exchange’i inceleyelim.<\/p>\n

Direct Exchange \u0130\u015fleyi\u015fi Nas\u0131ld\u0131r?<\/h3>\n

$\"RabbitMQ$ <\/a><\/p>\n

Publisher\u0131n g\u00f6nderece\u011fi mesaj\u0131 istedi\u011fi consumer(lar)a iletilmesini sa\u011flayan ve b\u00f6ylece hedef t\u00fcketiciye veriyi i\u015fleten bir i\u015fleyi\u015fe sahip exchange’tir. Bunun i\u00e7in mesaja bir Routing-Key de\u011feri verilmekte ve bu routing-key de\u011ferine sahip t\u00fcm kuyruklara mesaj\u0131n iletilmesi sa\u011flanmaktad\u0131r.<\/p>\n

Direct Exchange, mesaj\u0131 direkt olarak ilgili adrese anahtar teslim yapmaktad\u0131r diyebiliriz.<\/p><\/blockquote>\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("directexchange", type: ExchangeType.Direct);\r\n                for (int i = 1; i <= 100; i++)\r\n                {\r\n                    byte[] bytemessage = Encoding.UTF8.GetBytes($"say\u0131 - {i}");\r\n\r\n                    IBasicProperties properties = channel.CreateBasicProperties();\r\n                    properties.Persistent = true;\r\n                    if (i % 2 != 0)\r\n                        channel.BasicPublish(exchange: "directexchange", routingKey: "ciftsayilar", basicProperties: properties, body: bytemessage);\r\n                    else\r\n                        channel.BasicPublish(exchange: "directexchange", routingKey: "teksayilar", basicProperties: properties, body: bytemessage);\r\n                }\r\n            }\r\n        }\r\n<\/pre>\n9.<\/em><\/strong> sat\u0131ra g\u00f6z atarsan\u0131z e\u011fer “ExchangeDeclare” metodunun ‘type’ parametresini ‘ExchangeType.Direct’ de\u011feri ile Direct Exchange olarak ayarlamaktay\u0131z. 16<\/em><\/strong> ile 19.<\/em><\/strong> sat\u0131rlar aras\u0131na g\u00f6z atarsan\u0131z e\u011fer d\u00f6ng\u00fcyle \u00fcretilen mesajlar\u0131 \u00e7iftlik yahut teklik durumuna g\u00f6re declare edilen ilgili exchange \u00fczerinden ilgili route-keylerle i\u015faretleyerek kuyru\u011fa g\u00f6nderiyoruz.<\/p>\n
B\u00f6ylece art\u0131k tek say\u0131lar\u0131m\u0131z “teksayilar” routingKey’ine sahip kuyrukta tutulurken \u00e7ift say\u0131lar ise “ciftsayilar” kuyru\u011funa g\u00f6nderilecektir. Bu yap\u0131lanmadan sonra art\u0131k consumerlar\u0131m\u0131z\u0131n bir k\u0131sm\u0131 “teksayilar” route-key’ine sahip kuyru\u011fu dinlerken, bir k\u0131sm\u0131da “ciftsayilar” route-key’ine sahip kuyru\u011fu dinleyecektirler. B\u00f6ylece hangi kuyru\u011fa mesaj gelirse onu dinleyen consumerlar devreye girecek ve t\u00fcketim\/i\u015fleyi\u015f ba\u015flayacakt\u0131r.<\/p>\nConsumer<\/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("directexchange", type: ExchangeType.Direct);\r\n\r\n                string queueName = channel.QueueDeclare().QueueName;\r\n                if (int.Parse(args[0]) == 1)\r\n                    channel.QueueBind(queue: queueName, exchange: "directexchange", routingKey: "teksayilar");\r\n                else\r\n                    channel.QueueBind(queue: queueName, exchange: "directexchange", routingKey: "ciftsayilar");\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(queueName, false, consumer);\r\n                consumer.Received += (sender, e) =>\r\n                {\r\n                    Console.WriteLine(Encoding.UTF8.GetString(e.Body) + " say\u0131s\u0131 al\u0131nd\u0131.");\r\n                    channel.BasicAck(e.DeliveryTag, false);\r\n                };\r\n                Console.Read();\r\n            }\r\n        }\r\n<\/pre>\n9.<\/em><\/strong> sat\u0131rda yine “ExchangeDeclare” metodu ile t\u00fcr\u00fc Direct Exchange olan bir exchange declare ediyoruz. 12<\/em><\/strong> ile 15.<\/em><\/strong> sat\u0131r aral\u0131\u011f\u0131nda ise ‘1’ arg\u00fcman de\u011ferine sahip olan consumerlar\u0131n “teksayilar” routing-key de\u011ferine sahip kuyru\u011fu, ‘2’ arg\u00fcman de\u011ferine sahip olanlar\u0131n ise ‘ciftsayilar’ keyli kuyru\u011fu dinlemesini belirtiyoruz.<\/p>\nTest<\/h3>\nUygulamay\u0131 derleyip \u00e7al\u0131\u015ft\u0131rd\u0131\u011f\u0131m\u0131zda hornet.rmq.cloudamqp.com<\/a> adresindeki cloud servera g\u00f6z atarsak e\u011fer ilgili exchange’in olu\u015fturuldu\u011funu g\u00f6rmekteyiz.
\n<\/a><\/p>\n
<\/a>
\nEvet g\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere mesajlar router-key hedeflerine uygun t\u00fcm kuyruklara iletilmekte ve ilgili consumerlar taraf\u0131ndan an\u0131nda t\u00fcketilmektedirler…<\/p>\n
\u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle…
\nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere…
\n\u0130yi \u00e7al\u0131\u015fmalar…<\/p>\n","protected":false},"excerpt":{"rendered":"
Merhaba, RabbitMQ yaz\u0131 dizimizde exchange t\u00fcrleri aras\u0131ndan s\u0131ra Direct Exchange’e gelmi\u015f bulunmaktad\u0131r. \u015eimdi gelin hi\u00e7 vakit kaybetmeksizin ilgili exchange’i inceleyelim. Direct Exchange \u0130\u015fleyi\u015fi Nas\u0131ld\u0131r? Publisher\u0131n g\u00f6nderece\u011fi mesaj\u0131 istedi\u011fi consumer(lar)a iletilmesini sa\u011flayan ve b\u00f6ylece hedef...<\/p>\n","protected":false},"author":1,"featured_media":13803,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3156],"tags":[3224,3227,3158,3225,3226],"class_list":["post-13801","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-rabbitmq","tag-direct-exchange","tag-direct-exchange-routing-key","tag-rabbitmq","tag-rabbitmq-direct-exchange","tag-routing-key"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13801","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=13801"}],"version-history":[{"count":24,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13801\/revisions"}],"predecessor-version":[{"id":13828,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13801\/revisions\/13828"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/13803"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=13801"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=13801"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=13801"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}