RabbitMQ, .Net Core ile asenkron işlemler.

16 January 2021 - 4 mins read time
Tags: HowTo Notes RabbitMQ .Net Core

Merhaba,

Günlük hayatımızda veya iş hayatımızda, herhangi bir meslek erbabı eğer sorumluluklarının bilincindeyse veya ortaya güzel bir sonuç çıkarmak istiyorsa arayış içerisindedir. Bu arayış aslında mükemmelliğe doğru bir arayıştır. Her zaman yaptığı işin mükemmel olmasını veya sorumluluğunun karşılığını tam verdiğini hissettirmek ister. Bu mükemmellik arayışında işini daha çok kolaylaştıracak veya işine kalite katacak materyalleri arayıp bulmaya ve bunları kullanmaya başlar.

Yazılım geliştirirken de bir problemin,bir hatanın çözümünü sağlayacak bir kod parçası veya bir teknoloji öğrendiğinizde oh be diye bir gevşeme bir yumuşaklık bir hoşluk hissedersiniz :) . Özellikle kullandığınız bir programlama dilinin her yeni versiyonunda bir problem veya bir ihtiyaç için çözümler üretilmesi yazılımcılar için mutluluk kaynağıdır.

Finansal işlemleri çok fazla olan ve bunları muhasebeleştirmek zorunda olan bir yazılım ürününüzün olduğunu düşünün. Muhasebe işlemleri çoğunlukla asenkron bir yapıya ihtiyaç duyarlar. Örneğin ATM’ye gidip maaşınızı çektiğinizde banka tarafında bu kasa işlemlerinin o anda senkron olmasına gerek yoktur. Kaldı ki asenkron yapıldığında performans ve zaman açısında size birçok faydası vardır. Bankalar muhasebe işlemlerini genelde Queue(kuyruk) yapıları ile sürdürürler. Doğrudan bu işi yapmadım ama gözlemleyebildim :)

RabbitMQ teknolojisini incelerken, .Net ile implemente edip kullanmak istediğimde aklıma bu muhasebe işlemleri geldi ve bu konu üzerinde basit bir örnek yapmak istedim.

RabbitMQ ile ilgili olarak çok fazla kaynak ve detaylı yazılar bulabilirsiniz. Adem Olguner tarafından kaleme alınan şu yazıyı inceleyip RabbitMQ hakkında bilgi sahibi olup, kurulumlarını yapabilirsiniz.

.Net projemizin genel structure aşağıdaki gibi olacak. Bir client bir de bu clienttan gelen isteklere cevap veren api diye ikiye ayırıyoruz. Bu web api RabbitMQ işlemlerini yapacak.

Birinci adım olarak Accounting.Client projesini ayağa kaldırıyoruz.

UI’dan Api’ye aşağıdaki gibi istek atan Controller methodumuz.

[HttpPost]
public async Task<IActionResult> PushAsync(FisModel fisModel)
{
    string json = JsonConvert.SerializeObject(fisModel);
    StringContent data = new StringContent(json, Encoding.UTF8, "application/json");

    var client = new HttpClient();

    var response = await client.PostAsync(base_url+"AddQueue", data);
    string result = await response.Content.ReadAsStringAsync();
            
    client.Dispose();
            
    return RedirectToAction("Index");
}

Bir sonraki adımda Accounting.RabbitMQ.Api projemizi ayağa kaldırıyoruz. /swagger ile kontrol edebilirsiniz. AddQeue ile Post alan bir method göreceksiniz.

Burada requestleri AddQueue ile alıp RabbitMQService’e iletiyoruz. RabbitMQService aşağıdaki gibi iletileri alıp kuyruğa ekliyor.

public class RabbitMQService
{
   public FisModel data;
   public RabbitMQService(FisModel _data)
   {
      this.data = _data;
   }
   public string Post()
   {
      var factory = new ConnectionFactory() { HostName = "localhost" };
      using (var connection = factory.CreateConnection())
      using (var channel = connection.CreateModel())
      {
         channel.QueueDeclare(queue: "Fiş Kuyruğu",
                              durable: false,
                              exclusive: false,
                              autoDelete: false,
                              arguments: null);

         var fisModel = JsonConvert.SerializeObject(data);
         var body = Encoding.UTF8.GetBytes(fisModel);

         channel.BasicPublish(exchange: "",
                              routingKey: "Fiş Kuyruğu",
                              basicProperties: null,
                              body: body);
         return "TransactionObjectId:" + data.TransactionObjectId+ " added queue.";
       }
    }
}

Üçüncü adım olarak da daha önce kurmuş olduğunuz RabbitMQ’nun admin paneli ile UI projesini açarak denemeler yaptığınızda fişlerin kuyruğa eklendiğini göreceksiniz.

Bu çalışma ile asenkron bir ihtiyacımızı ,mesaj(process) kuyruğu sistemi olan RabbitMQ ile nasıl karşılayabiliriz sorusunun cevabının bir kısmını incelemiş olduk. RabbitMQ kurgusunun üç bileşeni bulunuyor. Biz mesajları(process) ileten Publisher yapısını ve bu iletileri alıp kuyruğa ekleyen yapıyı incelemiş olduk. Üçüncü bileşen ise Consumer bileşeni yani kuyruktaki iletileri dinleyen veya bunları tüketen bileşen.

Consumer yapısını bir sonraki yazıda Node.js kullanıp MongoDB ye kaydeden bir yapı şeklinde devam etmek istiyorum.

Görüşmek dileğiyle, sağlıcakla kalın.

Kaynak Kodlar :
Accounting.Client
Accounting.RabbitMQ.Api