{"id":13830,"date":"2020-03-01T19:56:43","date_gmt":"2020-03-01T19:56:43","guid":{"rendered":"https:\/\/www.gencayyildiz.com\/blog\/?p=13830"},"modified":"2020-03-01T21:43:48","modified_gmt":"2020-03-01T21:43:48","slug":"rabbitmq-topic-exchange","status":"publish","type":"post","link":"https:\/\/www.gencayyildiz.com\/blog\/rabbitmq-topic-exchange\/","title":{"rendered":"RabbitMQ – Topic Exchange"},"content":{"rendered":"

<\/div>\n

Merhaba,<\/p>\n

Bu i\u00e7eri\u011fimizde RabbitMQ’da \u00e7al\u0131\u015fma mant\u0131\u011f\u0131 belirli bir formata dayal\u0131 sistem \u00fczerine oturtulmu\u015f Topic Exchange’i inceleyece\u011fiz.<\/p>\n

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

$\"RabbitMQ$ <\/a>
\nTopic Exchange’de at\u0131lan mesajlar\u0131n routing key de\u011feri .(nokta) operat\u00f6r\u00fc kullan\u0131larak formatland\u0131r\u0131lmakta ve bu formattaki isimlerde yap\u0131lan filtrelemelere g\u00f6re uygun d\u00fc\u015fen kuyruklara mesajlar g\u00f6nderilmektedir. Yukar\u0131daki \u015femaya g\u00f6z atarsak e\u011fer;<\/p>\n\n\n\n\n\n\n
Message Routing Key<\/th>\n <\/th>\n<\/tr>\n<\/thead>\n
‘usa<\/span>.news’
\n‘usa<\/span>.weather’
\n‘europe<\/span>.news’
\n‘europe<\/span>.weather’<\/strong><\/td>\n Yandaki routing key de\u011ferlerine sahip olan mesajlar\u0131 hedef kuyru\u011fa g\u00f6nderebilmek i\u00e7in olu\u015fturdu\u011fumuz kuyruklarda a\u015fa\u011f\u0131dakine benzer bir filtreleme yap\u0131lmas\u0131 yeterlidir.<\/td>\n<\/tr>\n
\n
Topic Filtrelemesi<\/h3>\n\n\n\n\n\n
‘usa<\/span>.news’<\/strong><\/td>\n<\/tr>\n
Routing key de\u011feri ‘usa.news’<\/em> olan mesajlar bu kuyru\u011fa girecektir.<\/span><\/td>\n<\/tr>\n
$\"RabbitMQ$ <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n\n\n\n\n
‘*<\/span>.weather’<\/strong><\/td>\n<\/tr>\n
‘*<\/span><\u00f6nemli de\u011fil>.weather’<\/em> olan mesajlar bu kuyru\u011fa girecektir.<\/span><\/td>\n<\/tr>\n
$\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n\n\n\n\n
‘#<\/span>.news’<\/strong><\/td>\n<\/tr>\n
‘#<\/span>< ba\u015f\u0131 \u00f6nemli de\u011fil>.news’ olan mesajlar bu kuyru\u011fa girecektir.<\/span><\/td>\n<\/tr>\n
$\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n\n\n\n\n
‘*<\/span>.weather’<\/strong><\/td>\n<\/tr>\n
‘*<\/span><\u00f6nemli de\u011fil>.weather’ olan mesajlar bu kuyru\u011fa girecektir.<\/span><\/td>\n<\/tr>\n
$\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n\n\n\n\n
‘usa<\/span>.#’<\/strong><\/td>\n<\/tr>\n
‘usa.#<\/span>< sonu \u00f6nemli de\u011fil>’ olan mesajlar bu kuyru\u011fa girecektir.<\/span><\/td>\n<\/tr>\n
$\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n\n\n\n\n
‘europe<\/span>.*’<\/strong><\/td>\n<\/tr>\n
‘europe.*<\/span><\u00f6nemli de\u011fil>’ olan mesajlar bu kuyru\u011fa girecektir.<\/span><\/td>\n<\/tr>\n
$\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n\n\n\n\n
‘#’<\/strong><\/td>\n<\/tr>\n
‘#<\/span>< hi\u00e7biri \u00f6nemli de\u011fil>’ olan mesajlar bu kuyru\u011fa girecektir.<\/span><\/td>\n<\/tr>\n
$\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n $\"RabbitMQ$ <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
Kullan\u0131m\u0131<\/h3>\n
Bizler \u00f6rnek olarak silahl\u0131 kuvvetler hiyerar\u015fisine uygun bir \u015fekilde g\u00f6revlendirme senaryosu benimseyip mesajlar\u0131m\u0131z\u0131 ilgili r\u00fctbelere \u00f6zel g\u00f6rev bar\u0131nd\u0131ran kuyruklara iletece\u011fiz.<\/p>\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("topicexchange", type: ExchangeType.Topic);\r\n for (int i = 1; i <= 100; i++)\r\n {\r\n byte[] bytemessage = Encoding.UTF8.GetBytes($"{i}. g\u00f6rev verildi.");\r\n\r\n IBasicProperties properties = channel.CreateBasicProperties();\r\n properties.Persistent = true;\r\n channel.BasicPublish(exchange: "topicexchange", routingKey: $"Asker.Subay.{(i % 2 == 0 ? "Yuzbasi" : (i % 11 == 0 ? "Binbasi" : "Tegmen"))}", basicProperties: properties, body: bytemessage);\r\n }\r\n }\r\n }\r\n<\/pre>\n
Yukar\u0131daki \u00f6rnek publisher kod blo\u011funu incelerseniz e\u011fer 16.<\/em><\/strong> sat\u0131rda Topic exchange’e uygun formatta “Asker.Subay.[Tegmen – Yuzbasi – Binbasi]” routing keyi olu\u015fturulmaktad\u0131r. Burada senaryo gere\u011fi olu\u015fturulan 100 adet g\u00f6revin her birini ‘Te\u011fmen’, yar\u0131s\u0131n\u0131 ‘Y\u00fczba\u015f\u0131’ ve hatr\u0131 say\u0131l\u0131r az\u0131nl\u0131ktaki kadar\u0131n\u0131 ‘Binba\u015f\u0131’ r\u00fctbeli askerlerin \u00fcstlenece\u011fi \u015fekilde bir algoritma olu\u015fturulmu\u015f bulunmaktad\u0131r ve her bir g\u00f6rev mesaj olarak ilgili r\u00fctbeyi temsil eden formattaki routing key de\u011ferine sahip kuyru\u011fa g\u00f6nderilmektedir. \u015eimdi s\u0131ra kendi r\u00fctbesine uygun g\u00f6revleri bar\u0131nd\u0131ran kuyru\u011fa subscribe olan consumerlar\u0131 tan\u0131mlayama gelmi\u015f bulunmaktad\u0131r.<\/p>\n
Consumer<\/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("topicexchange", type: ExchangeType.Topic);\r\n\r\n string queueName = channel.QueueDeclare().QueueName;\r\n string routingKey = "";\r\n\r\n routingKey = args[0] switch\r\n {\r\n "1" => $"*.*.Tegmen",\r\n "2" => $"*.#.Yuzbasi",\r\n "3" => $"#.Binbasi.#",\r\n "4" => $"Asker.Subay.Tegmen",\r\n };\r\n\r\n channel.QueueBind(queue: queueName, exchange: "topicexchange", routingKey: routingKey);\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($"{routingKey} {Encoding.UTF8.GetString(e.Body)} g\u00f6revi ald\u0131.");\r\n channel.BasicAck(e.DeliveryTag, false);\r\n };\r\n Console.Read();\r\n }\r\n }\r\n<\/pre>\n
Yukar\u0131daki consumer \u00f6rnek kodlar\u0131n\u0131 incelerseniz e\u011fer 14.<\/em><\/strong> sat\u0131rda console uygulamas\u0131na verilen arg\u00fcman de\u011ferine g\u00f6re Topic format\u0131na uygun bir nitelendirme yap\u0131lmakta ve buradan elde edilen routing key 22.<\/em><\/strong> sat\u0131rda olu\u015fturulacak kuyru\u011fa verilmektedir. B\u00f6ylece belirtilen formatta uyan her bir kuyru\u011fa uygun mesajlar\u0131 consumer elde ederek t\u00fcketmektedir.<\/p>\n
Test Edelim<\/h3>\nUygulamay\u0131 derleyip \u00e7al\u0131\u015ft\u0131rd\u0131\u011f\u0131m\u0131zda hornet.rmq.cloudamqp.com<\/a> cloud adresine gider ve g\u00f6z atarsak e\u011fer Topic exchange’in olu\u015fturuldu\u011funu g\u00f6rm\u00fc\u015f olaca\u011f\u0131z.
\n $\"RabbitMQ$ <\/a><\/p>\n
$\"RabbitMQ$ <\/a><\/p>\n
G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere Topic exchange ile belli bir formatta girdi\u011fimiz routing key de\u011ferlerine g\u00f6re mesajlar\u0131m\u0131z kuyruklara yerle\u015ftiriliyor ve ard\u0131ndan ‘#’ yahut ‘*’ operat\u00f6r\u00fcleri ile yap\u0131lan filtreleme neticesinde uygun kuyru\u011fa ba\u011flanan consumerlar taraf\u0131ndan t\u00fcketiliyor. Gayet g\u00fczel \ud83d\ude42<\/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 uygulamay\u0131 indirmek i\u00e7in buraya<\/a> t\u0131klay\u0131n\u0131z.<\/p>\n","protected":false},"excerpt":{"rendered":"
Merhaba, Bu i\u00e7eri\u011fimizde RabbitMQ’da \u00e7al\u0131\u015fma mant\u0131\u011f\u0131 belirli bir formata dayal\u0131 sistem \u00fczerine oturtulmu\u015f Topic Exchange’i inceleyece\u011fiz. Topic Exchange \u0130\u015fleyi\u015fi Nas\u0131ld\u0131r? Topic Exchange’de at\u0131lan mesajlar\u0131n routing key de\u011feri .(nokta) operat\u00f6r\u00fc kullan\u0131larak formatland\u0131r\u0131lmakta ve bu formattaki...<\/p>\n","protected":false},"author":1,"featured_media":13834,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3156],"tags":[3158,3228,3229],"class_list":["post-13830","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-rabbitmq","tag-rabbitmq","tag-rabbitmq-topic-exchange","tag-topic-exchange"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13830","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=13830"}],"version-history":[{"count":69,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13830\/revisions"}],"predecessor-version":[{"id":13910,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/13830\/revisions\/13910"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/13834"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=13830"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=13830"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=13830"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}