SignalR Chatleşme sırasında Yazışmaları RabbitMQ Kullanılarak Sql Server’a Kaydetme Bölüm2

Bölüm 2 Büyük Yükler Altında, Yapılması Gereken Asenkron İşleri, Bir Queue’ya Atıp Sıra ile Yapma:

Selamlar,

Bu makaleye geçmeden önce İlk makaleyi  okumanızı tavsiye ederim. Bu makalede 1. makalede kalınan yerden devam edilecektir.

Artık ortak yazışılan bir chat uygulamamız var. Şimdi diyelim ki 10 bin kişi aynı anda yazışsın. İşte tam bu durumda her yazılan mesajın logunun, senkron olarak bir DB’de saklanması aynı sunucu üzerinden denenir ise, ilgili DB makinasının rem ve cpu’yusunun tavan yapması ve bir süre sonra cevap veremeyecek hale gelmesi yüksek bir ihtimaldir. Bu durumda hali hazırda yazışmaya çalışan 10bin kişi, bekletilecek ve yazılan mesajlar anlık olarak ilgili kişilere iletilemiyecektir. Ayrıca çıkabilecek hata loglarının da ayrı bir sistemde tutulması gibi bir durum söz konusu ise, bu sefer işler daha da kötüye gidecek, sorunun geçici çözümü için IIS restart hatta sunucunun restart edilmesi gerekebilecektir. İşte bu ve bunun gibi istenmiyen durumların olmaması için var olan sistemden bağımsız çalışan bir Queue mekanizmasının kullanılması güzel çözüm yöntemlerden birisi olabilir.

Bu makalede queue olarak RabbitMQ kullanılmıştır. İstenir ise Kafka, MSMQ gibi farklı Queue uygulamaları da kullanılabilir. Gelin isterseniz öncelikle DAL diye geçen uygulamanın data katmanını kodlayalım :) Database adı “Message” tablo adı “MessageLog” aşağıda görüldüğü gibidir.

Şimdi sıra geldi RabbitMQ projemizi oluşturmaya. Ben bunun için bir Windows Service oluşturucağım. RabbitMQ’nun çalışması için makinanızda önceden yukarıda görülen RabbitMQ servisinin ayağa kaldırılmış olması gerekmektedir. Bu anlamanın en iyi yolu “http://localhost:15672/” adresi browserdan çağrıldığı zaman aşağıdaki gibi bir ekranın gelmesi gerekmektedir.

Şimdi sıra geldi “MessageLogService” adında “RabbitMQ“‘daki mesajları dinleyip, “Message” DB’ye yazacak bir Windows Services’i yazmaya. Öncelikle aşağıdaki kütüphaneler NuGet Package Manager’dan Download Edilir:

Ben performansı mümkün olduğunca arttırmak için DB’ye data yazmak için Micro Orm toolarından Dapper‘ı kullanacağım. Dapper hakında bilgiyi bu makaleden edinebilirsiniz. http://www.borakasmer.com/dapper-nedir/ Ayrıca projede RabbitMQ kullanılabilmesi için RabbitMQ.Client’ın indirilmesi gerekmektedir.

Gelin öncelikle “MessageListener” adında bir sınıf yazalım.

MessageListener: Aşağıdaki codelara bakıldığında bir “DoWork()” methodu ve arkada çalışan bir “Thread()” ilk dikkati çeken öğelerdir. RabbitMQ için ConnectionFactory==> ile”localhost”‘a bağlanılıp, data çekilecek “MessageLog” channel’ının, Queue özellikleri tanımlandıktan sonra “while(true)” ile ilgili kanalı dinleme işine başlanır.

İlgili paket “MessageLog” channel’ından yakalandığı zaman, Deserialize edilip”MessageLog” modeline cast edilir. Daha sonra alınan model Dapper ile Sql’e bağlanılıp, yine Dapper Text Query ile Insert edilir. Ayrıca da Console’a bir log yazılır.

  • “Connection ve channel” using ile oluşturulur.
  • “channel.QueueDeclare” ile dinlenecek sıranın MessageLog olduğu, “queue: MessageLog” ile tanımlanır.
  • “channel.BasicConsume” ile ilgili mesaj çekme işlemine başlanır.
  • “consumer.Queue.Dequeue()” methodu ile ilgili queue’den sıradaki “MessageLog” alınmıştır.
  • İlgili paket içeriği “message“‘a atanmış ve Newtonsoft.Json kullanılarak ilgili message “<MessageLog>” tipine Deserialize edilmiştir.
  • Queue’den gelen pakete göre yeni bir “MessageLog” kaydı oluşturulur. Ve “log” değişkenine atanır.
  • Dapper sayesinde “MessageLog” tablosuna kaydedilecek insert cümlesi oluşturulur. “Insert into [dbo].[MessageLog]([Text],[CreatedDate]) VALUES (@Text,@CreatedDate)
  • Son olarak ilgili query, yandaki gibi execute edilir. “sqlConnection.Execute(sqlQuery, log);

MessageLog.cs: RabbitMQ’den alınan kaydedilecek Message paket modeli aşağıdaki gibi tanımlanır.

Windows Service Program.cs: Aşağıda görüldüğü gibi “Debug” ve “Release” durumlarında farklı code blokları çalışmaktadır. Release yani servis olarak çalışırken ilgili ServiceBase devreye girer ve Debug Model’da direk “DoWork()” methodu çağrılır.

App.config(connectionStrings):

MessageLogService.cs: Aşağıda görüldüğü gibi ilgili servisin OnStart() durumunda “DoWork()” methodu çağrılmış ve RabbitMQ’daki “Message” kanalı dinlenmeye başlanmıştır.

MessageLog Windows Servis için ProjectInstaller Oluşturma:

MessageLogService sağ tıklanıp “Add Installer” seçilir. Projeye “ProjectInstaller” adında bir dosya eklenir. “serviceProcessInstaller1” ve “MessageLogService“‘in property ekranları aşağıdak gibidir.

“MessageLogService”‘in, install işleminden sonra Servisler kısmında aşağıdaki gibi gözükmesi gerekmektedir. Servise ait “Yetkili User”‘ı değiştirmeyi ve ve tabi ki start etmeyi unutmayın:)

Windows Service’nin yani MessageLogService’in Install  edilmesi:

  1. Öncelikle .NetFrameWork’ün kurulu olduğu folder’a command prompt’dan yandaki gibi “Admin” yetkisi ile açılıp gelinir. Şu anki güncel versiyon. “C:\WINDOWS\Microsoft.NET\Framework\v4.0.30319\“. Sizde daha farklı olabilir
  2. InstallUtil.exe “C:\Users\Bora KASMER\Documents\Visual Studio 2017\Projects\SignalR_RabbitMQ\MessageLogService\bin\Release\MessageLogService.exe” komutu çalıştırılır.
  3. Önemli bir nokta”services.msc” komutu ile ilgili “MessageService”‘e gidilip sağ tıklanıp “Log On” sekmesindeki “This account” SqlServer’ınızdaki User ile aynı olmalıdır. Yoksa ilgili servis DB’ye yazma sırasında hata vermektedir.

İlgiliMessageService’in User’ı, sağ tıklanıp aşağıdaki gibi değiştirilir:

SqlDB’ye hangi user ile bağlanıldığı, property penceresinden aşağıdaki gibi görülmektedir:

Şimdi sıra geldi Yazışmalar sırasındaki tüm mesajları local’deki RabbitMQ’ya atmaya:

RabbitMQ Publisher: Burada “localhost“‘da çalışan ve credential istemeyen bir RabbitMQ servisine bağlanılmaktadır. Parametre olarak alınan “MessageLog” sınıfı Newtonsoft ile Serialized edilip byte’a çevrilir ve “BasicPublish()” methodu ile eklenecek olan “MessageLog” kanalına gönderilir.

Bu sırada QueueDeclare ayarları için:

  • durable ile in-memory mi yoksa fiziksel olarak mı RabbitMQ daki verinin saklanacağı belirlenir.
  • exclusive  İlgili Queue’nin diğer connectionlar ile kullanılması izni belirlenir.
  • autoDelete ile işlemi bitenQueue RabbitMq’dan silinir ya da istenir ise silinmez.
  • arguments ile belirlenen exchanges ile alakalı parametrelerin tanımlandığı yerdir.

Chat:Hub(Class) Son Hali:

  • Aşağıda görüldüğü gibi herhangi bir client’ın gönderdiği mesaj, önce DB’ye yazılması için RabbitMQ’a atılır. Daha sonra da “Clienats.All.SendMessage()” ile de, connected olan tüm clientlardaki “SendMessagAll()” function’ı, yazılan Message ve UserName parametreleri ile trigger olunur. Böylece bir kişnin yazdığı mesaj, bağlı olan tüm clientlara gönderilmiş olunur.

Başta da söylediğim gibi, bir sorunun tek bir çözüm yolu yoktur. Ya da tek başına muhteşem bir teknoloji de, nerde ise imkansızdır. Önemli olan amaca, ihtiyaca ve maddi imkanlara göre en iyi yapıyı oluşturmaktır. Amacın hız veya güvenlik olmasına göre seçilicek teknolojiler farklılık gösterebilecektir. Ama değişmeyen tek bir şey vardır. O da yumurtaların hepsinin tek bir sepete konmaması, ve dağıtık mimari ile  çalışmanın getirdiği tonla avantajlardır. Tabi herşeyin fazlası zarardır. Çok fazla parçaya ayırmakta, yönetim maliyeti getirebilmektedir.

Geldik bir makalenin daha sonuna. Yeni bir makalede görüşmek üzere hoşçakalın.

Source Code: https://github.com/borakasmer/SignalR_RabbitMQ

Herkes Görsün:

Bunlar da hoşunuza gidebilir...

Bir Cevap Yazın

E-posta hesabınız yayımlanmayacak. Gerekli alanlar * ile işaretlenmişlerdir