![\"icons--rabbitmq-200x200\"](\"\/wp-content\/uploads\/2016\/06\/icons-rabbitmq-200x200.png\"){kind=icon}
<\/a><\/p>\nBir \u00f6nceki makalem olan “RabbitMQ Nedir ve Windows\u2019a Kurulumu<\/a>”\u00a0isimli makale ile,\u00a0RabbitMQ konusuna bir giri\u015f yapm\u0131\u015f idik. Bu makale kapsam\u0131nda\u00a0ise RabbitMQ’nun C# provider’\u0131n\u0131 kullanarak\u00a0en s\u0131k kullan\u0131lan\u00a0Messaging Pattern<\/strong>‘lerinden birisi olan “Publish \/ Subscribe<\/strong>” pattern’i mant\u0131\u011f\u0131nda,\u00a0basit bir \u015fekilde nas\u0131l\u00a0mesaj g\u00f6nderilir ve al\u0131n\u0131ra\u00a0bak\u0131yor olaca\u011f\u0131z.<\/p>\n RabbitMQ’nun Procuder, Queue ve Consumer yap\u0131s\u0131n\u0131 basit olarak hat\u0131rlamak gerekirse;<\/p>\n Genel bilgileri tekrardan hat\u0131rlad\u0131\u011f\u0131m\u0131za g\u00f6re \u015fimdi kodlamaya ba\u015flayabiliriz. \u00d6rnek olarak bir Console Application olu\u015fturaca\u011f\u0131z ve Queue’ya mesaj g\u00f6nderecek olan Publisher’\u0131 ve bu mesajlar\u0131 dinleyecek olan Consumer yap\u0131s\u0131n\u0131 olu\u015fturaca\u011f\u0131z.<\/p>\n \u00d6ncelikle Nuget Package Manager \u00fczerinden a\u015fa\u011f\u0131da g\u00f6rm\u00fc\u015f oldu\u011fumuz “RabbitMQ.Client”\u00a0paketini kural\u0131m.<\/p>\n Kurmu\u015f oldu\u011fumuz bu client paketi sayesinde RabbitMQ\u00a0ile haberle\u015febilece\u011fiz.<\/p>\n RabbitMQ’nun C#\u00a0Client provider’\u0131 connection i\u015flemlerini “ConnectionFactory” \u00fczerinden yaratarak ger\u00e7ekle\u015ftirmektedir. Bu connection’a hem “Publisher” hemde “Consumer” i\u00e7erisinde ayn\u0131 \u015fekilde ihtiyac\u0131m\u0131z olaca\u011f\u0131 i\u00e7in, “RabbitMQService” isminde bir class ekleyelim ve burada\u00a0“ConnectionFactory” class’\u0131n\u0131 kullanarak ortak i\u015flemleri kodlamaya ba\u015flayal\u0131m.<\/p>\n RabbitMQService<\/strong> class’\u0131m\u0131z haz\u0131r durumda. Connection i\u015flemleri “IConnection” interface’inden t\u00fcremektedir ve factory class’\u0131 \u00fczerinden “HostName” property’sini set ederek, “CreateConnection()” method’u arac\u0131l\u0131\u011f\u0131 ile yeni bir connection olu\u015fturulabilmektedir.<\/p>\n \u015eimdi “Publisher” g\u00f6revini\u00a0g\u00f6recek olan Publisher class’\u0131n\u0131 kodlamaya ge\u00e7elim.<\/p>\n \u015eimdi neler yapt\u0131\u011f\u0131m\u0131za ad\u0131m ad\u0131m bir bakal\u0131m.<\/p>\n Yukar\u0131daki sat\u0131r\u00a0ile a\u00e7m\u0131\u015f oldu\u011fumuz connection \u00fczerinden “CreateModel” method’unu \u00e7a\u011f\u0131rarak, RabbitMQ \u00fczerinde yeni bir channel\/session yaratmaktay\u0131z. Bu Channel\u00a0sayesinde bir Queue olu\u015fturabilirken, mesaj g\u00f6nderme\u00a0i\u015flemlerini de ger\u00e7ekle\u015ftirebilmekteyiz.<\/p>\n Bu sat\u0131rda ise method isminden de anla\u015f\u0131labilece\u011fi \u00fczere, yeni bir queue tan\u0131ml\u0131yoruz.\u00a0Burada \u00f6nemli olan ilk \u00fc\u00e7 parametresine bakmak gerekirse;<\/p>\n Art\u0131k Channel\u00a0ve Queue haz\u0131r bir durumda oldu\u011fu i\u00e7in, “BasicPublish” method’u ile kolay bir \u015fekilde olu\u015fturmu\u015f oldu\u011fumuz ilgili Queue’ya mesaj g\u00f6nderiyoruz.<\/p>\n “BasicPublish” method’un kulland\u0131\u011f\u0131m\u0131z parametrelerine bakarsak:<\/p>\n Publisher’\u0131 test edebilmek i\u00e7in “Program.cs” class’\u0131n\u0131 a\u00e7al\u0131m ve a\u015fa\u011f\u0131daki gibi kodlayal\u0131m.<\/p>\n Queue ismini “GOKHANGOKALP” olarak\u00a0belirleyelim ve constructor \u00fczerinden Queue ismini ve g\u00f6ndermek istedi\u011fimiz mesaj\u0131 set edelim. Uygulamay\u0131 \u00e7al\u0131\u015ft\u0131rmadan \u00f6nce RabbitMQ Management ekran\u0131 \u00fczerinden Queues tab’\u0131na\u00a0bir bakal\u0131m. Management ekran\u0131na “localhost:15672” adresinden eri\u015febilirsiniz.<\/p>\n Yukar\u0131da g\u00f6rd\u00fc\u011f\u00fcm\u00fcz gibi \u015fuan herhangi bir Queue bulunmamaktad\u0131r. \u015eimdi olu\u015fturmu\u015f oldu\u011fumuz Console uygulamas\u0131n\u0131 \u00e7al\u0131\u015ft\u0131ral\u0131m.<\/p>\n Publisher Console\u00a0uygulamas\u0131 \u00fczerinden\u00a0ba\u015far\u0131l\u0131 bir \u015fekilde \u00e7al\u0131\u015ft\u0131 ve “GOKHANGOKALP” isminde bir Queue olu\u015fturarak “Hello RabbitMQ World!” mesaj\u0131n\u0131 Queue’ya ekledi. Management ekran\u0131n\u0131 bir de \u015fimdi kontrol edelim.<\/p>\n Tada… “GOKHANGOKALP” isminde bir Queue olu\u015fmu\u015f ve “Read” state’inde bir mesaj\u0131n bulundu\u011funu s\u00f6yl\u00fcyor. \u015eimdi s\u0131ra geldi bu mesajlar\u0131 alacak\u00a0yani Subscribe edecek olan Consumer’\u0131 kodlamaya. “Consumer” isminde yeni bir class olu\u015fturarak, a\u015fa\u011f\u0131daki gibi kodlamaya ba\u015flayal\u0131m.<\/p>\n Consumer k\u0131sm\u0131nda ad\u0131m ad\u0131m ne yapt\u0131\u011f\u0131m\u0131z\u0131 inceleyelim \u015fimdi.<\/p>\n As\u0131l i\u015flemlerimizi ger\u00e7ekle\u015ftirecek old\u0131u\u011fumuz “consumer”\u00a0nesnemizdir. “EventingBasicConsumer” class’\u0131 sayesinde constructor \u00fczerinden channel verildi\u011finde, “Recevied” event’i sayesinde s\u00fcrekli “listening” modunda olacakt\u0131r. Queue’daki ilgili mesajlar\u0131 s\u0131ras\u0131yla almaktad\u0131r ve “Body” property’sinde bar\u0131nd\u0131rmaktad\u0131r. Hat\u0131rlarsak mesajlar\u0131 “byte[]” tipinde g\u00f6ndermi\u015ftik. G\u00f6ndermi\u015f oldu\u011fumuz mesaj\u0131n “string” tipinde oldu\u011funu bildi\u011fimiz i\u00e7in “Encoding” alt\u0131nda bulunan “GetString” method’u ile “Decode” i\u015flemini ger\u00e7ekle\u015ftiriyoruz.<\/p>\n NOT: RabbitMQ Queue’su FIFO<\/strong>(First in Frist out) mant\u0131\u011f\u0131nda \u00e7al\u0131\u015fmaktad\u0131r.<\/p><\/blockquote>\n Burada ise method isminden yine anla\u015f\u0131labilece\u011fi \u00fczere (isimlendirmenin ne kadar \u00f6nemli oldu\u011fu buradan da anla\u015f\u0131labilir) basic bir \u015fekilde verilmi\u015f olan Queue ismine g\u00f6re mesajlar\u0131 alma i\u015flemini ba\u015flat\u0131yoruz. Burada dikkat \u00e7ekmek istedi\u011fim bir ka\u00e7 parametre bulunmaktad\u0131r:<\/p>\n Console\u00a0uygulamas\u0131n\u0131n “Program.cs” class’\u0131n\u0131 \u015fimdi a\u015fa\u011f\u0131daki gibi g\u00fcncelleyelim ve tekrardan \u00e7al\u0131\u015ft\u0131ralm.<\/p>\n Publisher’\u0131 ayn\u0131 \u015fekilde ba\u015flatarak tek fark olarak Consumer’\u0131 tan\u0131ml\u0131yor ve ayn\u0131 “_queueName” parametresini ge\u00e7erek, ayn\u0131 Queue \u00fczerindeki mesajlar\u0131 dinlemesini s\u00f6yl\u00fcyoruz.<\/p>\n Bunun sonucunda Console uygulamas\u0131n\u0131n \u00e7\u0131kt\u0131s\u0131 a\u015fa\u011f\u0131daki gibi olacakt\u0131r.<\/p>\n G\u00f6rd\u00fc\u011f\u00fcm\u00fcz gibi sonu\u00e7 olarak Consumer ba\u015far\u0131l\u0131 bir \u015fekilde “GOKHANGOKALP” Queue’sunu dinleyerek, i\u00e7erisinde bulunan mesaj\u0131 \u00e7ekip ekrana basm\u0131\u015ft\u0131r. “noAck” parametresini True olarak set etmi\u015f idik. \u015eimdi Management ekran\u0131n\u0131 bir kontrol edelim bakal\u0131m Queue \u00fczerinde herhangi bir mesaj var m\u0131?<\/p>\n G\u00f6rd\u00fc\u011f\u00fcm\u00fcz gibi “GOKHANGOKALP” Queue’su oldu\u011fu gibi durmaktad\u0131r fakat herhangi bir mesaj i\u00e7erisinde bulunmamaktad\u0131r. \u015eimdi “noAck” parametresini False olarak set edip, tekrardan Console uygulamas\u0131n\u0131 \u00e7al\u0131\u015ft\u0131ral\u0131m ve sonuca tekrardan Management ekran\u0131 \u00fczerinden bir bakal\u0131m.<\/p>\n<\/a><\/p>\n\n
<\/a><\/p>\nusing RabbitMQ.Client;\r\n\r\nnamespace RabbitMQSample\r\n{\r\n public class RabbitMQService\r\n {\r\n \/\/ localhost \u00fczerinde kurulu oldu\u011fu i\u00e7in host adresi olarak bunu kullan\u0131yorum.\r\n private readonly string _hostName = \"localhost\";\r\n\r\n public IConnection GetRabbitMQConnection()\r\n {\r\n ConnectionFactory connectionFactory = new ConnectionFactory()\r\n {\r\n \/\/ RabbitMQ'nun ba\u011flant\u0131 kuraca\u011f\u0131 host'u tan\u0131ml\u0131yoruz. Herhangi bir g\u00fcvenlik \u00f6nlemi koymak istersek, Management ekran\u0131ndan password ad\u0131mlar\u0131n\u0131 tan\u0131mlay\u0131p factory i\u00e7erisindeki \"UserName\" ve \"Password\" property'lerini set etmemiz yeterlidir.\r\n HostName = _hostName\r\n };\r\n\r\n return connectionFactory.CreateConnection();\r\n }\r\n }\r\n}<\/pre>\nusing System;\r\nusing System.Text;\r\n\r\nnamespace RabbitMQSample\r\n{\r\n public class Publisher\r\n {\r\n private readonly RabbitMQService _rabbitMQService;\r\n\r\n public Publisher(string queueName, string message)\r\n {\r\n _rabbitMQService = new RabbitMQService();\r\n\r\n using (var connection = _rabbitMQService.GetRabbitMQConnection())\r\n {\r\n using (var channel = connection.CreateModel())\r\n {\r\n channel.QueueDeclare(queueName, false, false, false, null);\r\n\r\n channel.BasicPublish(\"\", queueName, null, Encoding.UTF8.GetBytes(message));\r\n\r\n Console.WriteLine(\"{0} queue'su \u00fczerine, \\\"{1}\\\" mesaj\u0131 yaz\u0131ld\u0131.\", queueName, message);\r\n }\r\n }\r\n }\r\n }\r\n}<\/pre>\nvar channel = connection.CreateModel()<\/pre>\n
channel.QueueDeclare(queueName, false, false, false, null);<\/pre>\n
\n
channel.BasicPublish(\"\", queueName, null, Encoding.UTF8.GetBytes(message));<\/pre>\n
\n
namespace RabbitMQSample\r\n{\r\n class Program\r\n {\r\n private static readonly string _queueName = \"GOKHANGOKALP\";\r\n private static Publisher _publisher;\r\n\r\n static void Main(string[] args)\r\n {\r\n _publisher = new Publisher(_queueName, \"Hello RabbitMQ World!\");\r\n\r\n Console.ReadKey();\r\n }\r\n }\r\n}<\/pre>\n<\/a><\/p>\n<\/a><\/p>\n<\/a><\/p>\nusing System;\r\nusing System.Text;\r\nusing RabbitMQ.Client.Events;\r\n\r\nnamespace RabbitMQSample\r\n{\r\n public class Consumer\r\n {\r\n private readonly RabbitMQService _rabbitMQService;\r\n\r\n public Consumer(string queueName)\r\n {\r\n _rabbitMQService = new RabbitMQService();\r\n\r\n using (var connection = _rabbitMQService.GetRabbitMQConnection())\r\n {\r\n using (var channel = connection.CreateModel())\r\n {\r\n var consumer = new EventingBasicConsumer(channel);\r\n \/\/ Received event'i s\u00fcrekli listen modunda olacakt\u0131r.\r\n consumer.Received += (model, ea) =>\r\n {\r\n var body = ea.Body;\r\n var message = Encoding.UTF8.GetString(body);\r\n\r\n Console.WriteLine(\"{0} isimli queue \u00fczerinden gelen mesaj: \\\"{1}\\\"\", queueName, message);\r\n };\r\n\r\n channel.BasicConsume(queueName, true, consumer);\r\n Console.ReadLine();\r\n }\r\n }\r\n }\r\n }\r\n}<\/pre>\nvar consumer = new EventingBasicConsumer(channel);<\/pre>\n
channel.BasicConsume(queueName, true, consumer);<\/pre>\n
\n
namespace RabbitMQSample\r\n{\r\n class Program\r\n {\r\n private static readonly string _queueName = \"GOKHANGOKALP\";\r\n private static Publisher _publisher;\r\n private static Consumer _consumer;\r\n\r\n static void Main(string[] args)\r\n {\r\n _publisher = new Publisher(_queueName, \"Hello RabbitMQ World!\");\r\n\r\n _consumer = new Consumer(_queueName);\r\n }\r\n }\r\n}<\/pre>\n<\/a><\/p>\n<\/a><\/p>\nchannel.BasicConsume(queueName, false, consumer);<\/pre>\n