Azure Service Bus’ta mesaj \u00fcretim ve t\u00fcketimini AsbFlow ile nas\u0131l d\u00fczenleyece\u011finizi \u00f6\u011frenin. Karma\u015f\u0131k mesaj ak\u0131\u015flar\u0131n\u0131 basitle\u015ftirerek sistem performans\u0131n\u0131z\u0131 ve g\u00fcvenilirli\u011finizi art\u0131r\u0131n.<\/p>\n
Modern da\u011f\u0131t\u0131k sistemler ve mikroservis mimarileri, bile\u015fenler aras\u0131 ileti\u015fimin omurgas\u0131n\u0131 olu\u015fturur. Bu ileti\u015fimi sa\u011flayan en g\u00fc\u00e7l\u00fc ara\u00e7lardan biri de \u015f\u00fcphesiz Azure Service Bus’t\u0131r (ASB). Kuyruklar (Queues) ve Konular\/Abonelikler (Topics\/Subscriptions) arac\u0131l\u0131\u011f\u0131yla asenkron mesajla\u015fmay\u0131 m\u00fcmk\u00fcn k\u0131lan ASB, sistemlerinizin esnek, \u00f6l\u00e7eklenebilir ve dayan\u0131kl\u0131 olmas\u0131n\u0131 sa\u011flar. Ancak, b\u00fcy\u00fck \u00f6l\u00e7ekli uygulamalarda mesaj \u00fcretim ve t\u00fcketimini etkili bir \u015fekilde y\u00f6netmek, \u00f6zellikle hata durumlar\u0131, mesaj s\u0131ras\u0131 garantisi, yeniden denemeler ve mesaj tekrar\u0131 (idempotency) gibi konularda ciddi zorluklar\u0131 beraberinde getirebilir. Geli\u015ftiriciler, ham ASB SDK’s\u0131n\u0131 kullan\u0131rken bu karma\u015f\u0131k senaryolar\u0131 ele almak i\u00e7in genellikle \u00e7ok fazla tekrarlayan kod yazmak zorunda kal\u0131r. Bu durum, hem geli\u015ftirme s\u00fcresini uzat\u0131r hem de hatalara a\u00e7\u0131k bir ortam yarat\u0131r.<\/p>\n
Peki, bu karma\u015fay\u0131 nas\u0131l d\u00fczenleyebiliriz? Mesajla\u015fma altyap\u0131s\u0131n\u0131n sa\u011fl\u0131\u011f\u0131, uygulaman\u0131z\u0131n genel performans\u0131 ve g\u00fcvenilirli\u011fi i\u00e7in kritik \u00f6neme sahiptir. Yanl\u0131\u015f yap\u0131land\u0131r\u0131lm\u0131\u015f veya yetersiz y\u00f6netilen bir mesaj ak\u0131\u015f\u0131, veri kayb\u0131na, performans darbo\u011fazlar\u0131na ve sistem kesintilerine yol a\u00e7abilir. \u00d6rne\u011fin, bir e-ticaret uygulamas\u0131nda sipari\u015fin i\u015flenmesi veya bir \u00f6deme bildiriminin iletilmesi gibi kritik i\u015f s\u00fcre\u00e7leri, mesajla\u015fma altyap\u0131s\u0131n\u0131n hatas\u0131z \u00e7al\u0131\u015fmas\u0131na ba\u011fl\u0131d\u0131r. Mesajlar\u0131n do\u011fru s\u0131rayla i\u015flenmesi, ge\u00e7ici hatalar kar\u015f\u0131s\u0131nda otomatik olarak yeniden denenmesi ve ayn\u0131 mesaj\u0131n birden fazla kez i\u015flenmesini \u00f6nlemek, ba\u015far\u0131l\u0131 bir da\u011f\u0131t\u0131k sistemin olmazsa olmaz\u0131d\u0131r. ASB’nin sundu\u011fu zengin \u00f6zellik setini tam anlam\u0131yla kullanabilmek ve bu zorluklar\u0131 a\u015fmak i\u00e7in daha \u00fcst d\u00fczey bir soyutlamaya ve y\u00f6netim arac\u0131na ihtiya\u00e7 duyar\u0131z. \u0130\u015fte tam bu noktada, AsbFlow devreye girer. AsbFlow, Azure Service Bus ile \u00e7al\u0131\u015fmay\u0131 basitle\u015ftiren, geli\u015ftiricilerin odaklar\u0131n\u0131 i\u015f mant\u0131\u011f\u0131na kayd\u0131rmalar\u0131na olanak tan\u0131yan g\u00fc\u00e7l\u00fc bir k\u00fct\u00fcphanedir. Bu makalede, AsbFlow’un mesaj \u00fcretim ve t\u00fcketimini nas\u0131l optimize etti\u011fini, ger\u00e7ek d\u00fcnya senaryolar\u0131yla birlikte ad\u0131m ad\u0131m inceleyece\u011fiz.<\/p>\n
AsbFlow, .NET platformu i\u00e7in geli\u015ftirilmi\u015f, Azure Service Bus ile \u00e7al\u0131\u015fmay\u0131 kolayla\u015ft\u0131ran a\u00e7\u0131k kaynakl\u0131 bir k\u00fct\u00fcphanedir. Temel amac\u0131, ASB’nin sa\u011flad\u0131\u011f\u0131 g\u00fcc\u00fc daha y\u00f6netilebilir, hataya dayan\u0131kl\u0131 ve geli\u015ftirici dostu bir aray\u00fczle sunmakt\u0131r. Ham ASB SDK’s\u0131, temel d\u00fczeyde kontrol sa\u011flarken, AsbFlow bu temel i\u015flevsellik \u00fczerine in\u015fa edilmi\u015f bir soyutlama katman\u0131 g\u00f6revi g\u00f6r\u00fcr. Bu katman, mesaj i\u015fleme ak\u0131\u015flar\u0131n\u0131 (pipelines) tan\u0131mlama, hata y\u00f6netimi stratejilerini uygulama, yeniden deneme mekanizmalar\u0131n\u0131 yap\u0131land\u0131rma ve mesajlar\u0131n idempotent bir \u015fekilde i\u015flenmesini sa\u011flama gibi karma\u015f\u0131k g\u00f6revleri basitle\u015ftirir. B\u00f6ylece, geli\u015ftiriciler ASB’nin derinlemesine detaylar\u0131yla u\u011fra\u015fmak yerine, do\u011frudan i\u015f mant\u0131\u011f\u0131na odaklanabilirler.<\/p>\n
AsbFlow’u anlamak i\u00e7in bilmemiz gereken birka\u00e7 temel kavram bulunmaktad\u0131r:<\/p>\n
Bu \u00f6zellikler sayesinde AsbFlow, geli\u015ftiricilerin karma\u015f\u0131k mesajla\u015fma senaryolar\u0131n\u0131 daha az kodla, daha g\u00fcvenli ve daha performansl\u0131 bir \u015fekilde \u00e7\u00f6zmelerini sa\u011flar. \u00d6zellikle mikroservis mimarilerinde, her bir servisin kendi mesajla\u015fma mant\u0131\u011f\u0131n\u0131 ba\u015ftan yazmak yerine, AsbFlow gibi bir k\u00fct\u00fcphane kullanarak standart ve sa\u011flam bir yakla\u015f\u0131m benimsemek, hem tutarl\u0131l\u0131\u011f\u0131 art\u0131r\u0131r hem de bak\u0131m y\u00fck\u00fcn\u00fc azalt\u0131r.<\/p>\n
Azure Service Bus’a mesaj g\u00f6ndermek, basit g\u00f6r\u00fcnebilir ancak ger\u00e7ek d\u00fcnya senaryolar\u0131nda, mesaj\u0131n do\u011fru formatta haz\u0131rlanmas\u0131, gerekli \u00f6zelliklerin eklenmesi, oturum kimliklerinin belirlenmesi ve hata an\u0131nda yeniden denemelerin y\u00f6netilmesi gibi pek \u00e7ok detay\u0131 i\u00e7erir. AsbFlow, bu s\u00fcreci soyutlayarak, geli\u015ftiricilerin sadece g\u00f6ndermek istedikleri veri nesnesine odaklanmalar\u0131n\u0131 sa\u011flar. \u0130\u015fte AsbFlow ile mesaj \u00fcretimi ad\u0131mlar\u0131 ve bir vaka analizi:<\/p>\n
AsbFlow ile mesaj \u00fcretimi yapmak i\u00e7in \u00f6ncelikle ilgili NuGet paketini projenize eklemeniz gerekir. Ard\u0131ndan, bir mesaj \u00fcreticisi (producer) tan\u0131mlaman\u0131z ve yap\u0131land\u0131rman\u0131z gerekmektedir. Bu i\u015flem genellikle ba\u011f\u0131ml\u0131l\u0131k enjeksiyonu (dependency injection) container’\u0131 arac\u0131l\u0131\u011f\u0131yla yap\u0131l\u0131r.<\/p>\n
\n\/\/ NuGet Paketi: AsbFlow.Producer\n\/\/ Mesaj tipinizi tan\u0131mlay\u0131n\npublic class OrderCreatedEvent\n{\n public Guid OrderId { get; set; }\n public string CustomerEmail { get; set; }\n public decimal TotalAmount { get; set; }\n public DateTime CreatedDate { get; set; }\n}\n\n\/\/ Startup.cs veya Program.cs i\u00e7erisinde yap\u0131land\u0131rma\npublic void ConfigureServices(IServiceCollection services)\n{\n services.AddAsbFlow(options =>\n {\n options.SetConnection(\"Endpoint=sb:\/\/yournamespace.servicebus.windows.net\/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=YOUR_KEY\");\n });\n\n services.AddAsbProducer(\"your-order-queue\"); \/\/ Kuyruk veya Konu ad\u0131\n}\n\n\/\/ Mesaj g\u00f6ndermek i\u00e7in bir servis s\u0131n\u0131f\u0131\npublic class OrderService\n{\n private readonly IAsbProducer _producer;\n\n public OrderService(IAsbProducer producer)\n {\n _producer = producer;\n }\n\n public async Task CreateOrder(OrderCreatedEvent orderEvent)\n {\n \/\/ Mesaj\u0131 Service Bus'a g\u00f6nder\n await _producer.SendAsync(orderEvent);\n Console.WriteLine($\"Sipari\u015f olu\u015fturma eventi g\u00f6nderildi: {orderEvent.OrderId}\");\n }\n}\n <\/pre>\n<\/code><\/p>\n
Yukar\u0131daki \u00f6rnekte g\u00f6rd\u00fc\u011f\u00fcn\u00fcz gibi, AsbFlow ile mesaj g\u00f6ndermek olduk\u00e7a basittir. AddAsbProducer<\/code> metodu ile belirli bir mesaj tipi i\u00e7in bir \u00fcretici tan\u0131mlars\u0131n\u0131z ve bu \u00fcreticiyi ba\u011f\u0131ml\u0131l\u0131k enjeksiyonu arac\u0131l\u0131\u011f\u0131yla alarak SendAsync<\/code> metodunu \u00e7a\u011f\u0131r\u0131rs\u0131n\u0131z. AsbFlow, arka planda serile\u015ftirme, ASB'ye ba\u011flant\u0131 y\u00f6netimi ve mesaj\u0131n g\u00f6nderilmesi gibi t\u00fcm detaylar\u0131 otomatik olarak halleder.<\/p>\nVaka Analizi: E-Ticaret Sipari\u015f \u0130\u015fleme Ak\u0131\u015f\u0131<\/h3>\n
Bir e-ticaret platformunda, kullan\u0131c\u0131 bir sipari\u015f verdi\u011finde bir\u00e7ok arka plan i\u015flemi tetiklenir: envanter g\u00fcncelleme, \u00f6deme i\u015fleme, fatura olu\u015fturma, bildirim g\u00f6nderme vb. Bu i\u015flemlerin e\u015f zamanl\u0131 ve hataya dayan\u0131kl\u0131 bir \u015fekilde ger\u00e7ekle\u015fmesi kritik \u00f6neme sahiptir.<\/p>\n
Sorun:<\/strong> Sipari\u015f olu\u015fturma servisi, t\u00fcm bu arka plan i\u015flemlerini do\u011frudan \u00e7a\u011f\u0131rd\u0131\u011f\u0131nda, servisler aras\u0131nda s\u0131k\u0131 bir ba\u011f\u0131ml\u0131l\u0131k olu\u015fur. Bir \u00f6deme servisinin kapal\u0131 olmas\u0131, sipari\u015fin hi\u00e7 olu\u015fturulamamas\u0131na yol a\u00e7abilir. Ayr\u0131ca, manuel olarak yeniden deneme mant\u0131\u011f\u0131 uygulamak olduk\u00e7a zahmetlidir.<\/p>\n\u00c7\u00f6z\u00fcm:<\/strong> AsbFlow kullanarak, sipari\u015f olu\u015fturma servisi sadece bir OrderCreatedEvent<\/code> mesaj\u0131n\u0131 Azure Service Bus'a g\u00f6nderir. Bu, servisi di\u011fer i\u015flemlerden ay\u0131r\u0131r ve i\u015f y\u00fck\u00fcn\u00fc asenkron hale getirir. Di\u011fer servisler (Envanter Servisi, \u00d6deme Servisi, Bildirim Servisi), kendi AsbFlow t\u00fcketicileri arac\u0131l\u0131\u011f\u0131yla bu mesaj\u0131 dinler ve i\u015fler.<\/p>\n\n\/\/ Sipari\u015f Olu\u015fturma Servisinde\npublic async Task PlaceOrder(CreateOrderRequest request)\n{\n \/\/ Sipari\u015f veritaban\u0131na kaydedildi diyelim\n var orderEvent = new OrderCreatedEvent\n {\n OrderId = Guid.NewGuid(),\n CustomerEmail = request.CustomerEmail,\n TotalAmount = request.TotalAmount,\n CreatedDate = DateTime.UtcNow\n };\n\n \/\/ AsbFlow ile olay\u0131 Service Bus'a g\u00f6nder\n await _producer.SendAsync(orderEvent); \/\/ _producer IAsbProducer\n\n return orderEvent.OrderId;\n}\n <\/pre>\n<\/code><\/p>\n
Bu yakla\u015f\u0131m, sipari\u015f olu\u015fturma servisini daha h\u0131zl\u0131 ve daha az ba\u011f\u0131ml\u0131 hale getirir. Mesaj ba\u015far\u0131yla ASB'ye g\u00f6nderildikten sonra, sipari\u015f olu\u015fturma i\u015flemi tamamlanm\u0131\u015f kabul edilebilir. Arka plandaki di\u011fer i\u015flemler, mesaj\u0131n AsbFlow t\u00fcketicileri taraf\u0131ndan otomatik olarak y\u00f6netilen yeniden denemeler ve hata i\u015fleme mekanizmalar\u0131 sayesinde g\u00fcvenilir bir \u015fekilde tamamlan\u0131r. Bu sayede, sistemin genel esnekli\u011fi ve dayan\u0131kl\u0131l\u0131\u011f\u0131 art\u0131r\u0131l\u0131rken, geli\u015ftiricilerin operasyonel karma\u015f\u0131kl\u0131kla u\u011fra\u015fma s\u00fcresi \u00f6nemli \u00f6l\u00e7\u00fcde azal\u0131r.<\/p>\n
AsbFlow ile G\u00fc\u00e7l\u00fc Mesaj T\u00fcketimi Nas\u0131l Uygulan\u0131r?<\/h2>\n
Mesajlar\u0131 g\u00fcvenilir bir \u015fekilde t\u00fcketmek, da\u011f\u0131t\u0131k sistemlerin en zorlu y\u00f6nlerinden biridir. Mesaj\u0131n al\u0131nmas\u0131, i\u015flenmesi, hatalar\u0131n y\u00f6netilmesi, yeniden denemelerin uygulanmas\u0131 ve nihayetinde mesaj\u0131n ASB'den kald\u0131r\u0131lmas\u0131 (veya \u00f6l\u00fc harf kuyru\u011funa g\u00f6nderilmesi) s\u00fcre\u00e7leri, dikkatli bir m\u00fchendislik gerektirir. AsbFlow, bu karma\u015f\u0131k d\u00f6ng\u00fcy\u00fc basitle\u015ftirerek, geli\u015ftiricilerin sadece i\u015f mant\u0131\u011f\u0131na odaklanmas\u0131n\u0131 sa\u011flayan sa\u011flam bir t\u00fcketici (consumer) \u00e7er\u00e7evesi sunar.<\/p>\n
Ad\u0131m Ad\u0131m Mesaj T\u00fcketimi ve Hata Y\u00f6netimi<\/h3>\n
AsbFlow ile mesaj t\u00fcketimi i\u00e7in bir mesaj i\u015fleyici (message handler) ve bir t\u00fcketici (consumer) yap\u0131land\u0131rman\u0131z gerekir. Mesaj i\u015fleyici, belirli bir mesaj tipini nas\u0131l i\u015fleyece\u011finizi tan\u0131mlad\u0131\u011f\u0131n\u0131z yerdir.<\/p>\n
\n\/\/ NuGet Paketi: AsbFlow.Consumer\n\/\/ Mesaj i\u015fleyiciyi tan\u0131mlay\u0131n\npublic class OrderCreatedEventHandler : IAsbMessageHandler\n{\n private readonly ILogger _logger;\n private readonly IInventoryService _inventoryService;\n\n public OrderCreatedEventHandler(ILogger logger, IInventoryService inventoryService)\n {\n _logger = logger;\n _inventoryService = inventoryService;\n }\n\n public async Task HandleAsync(OrderCreatedEvent message, CancellationToken cancellationToken)\n {\n _logger.LogInformation($\"Sipari\u015f olu\u015fturma eventi i\u015fleniyor: {message.OrderId}\");\n\n try\n {\n \/\/ Envanter servisi \u00e7a\u011fr\u0131s\u0131 - bu bir hata f\u0131rlatabilir\n await _inventoryService.UpdateInventoryForOrder(message.OrderId);\n _logger.LogInformation($\"Envanter ba\u015far\u0131yla g\u00fcncellendi: {message.OrderId}\");\n }\n catch (InventoryServiceException ex)\n {\n _logger.LogError(ex, $\"Envanter g\u00fcncelleme hatas\u0131: {message.OrderId}. Yeniden denenecek.\");\n \/\/ Ge\u00e7ici bir hata ise AsbFlow'un yeniden deneme mekanizmas\u0131n\u0131 tetiklemek i\u00e7in hata f\u0131rlat\u0131l\u0131r\n throw; \n }\n catch (Exception ex)\n {\n _logger.LogCritical(ex, $\"Kritik hata: {message.OrderId}. DLQ'ya g\u00f6nderiliyor.\");\n \/\/ Kal\u0131c\u0131 bir hata ise, burada \u00f6zel bir i\u015flem yap\u0131labilir veya hata f\u0131rlat\u0131l\u0131r\n \/\/ AsbFlow, belirlenen yeniden deneme say\u0131s\u0131 a\u015f\u0131ld\u0131\u011f\u0131nda mesaj\u0131 DLQ'ya g\u00f6nderecektir.\n throw new AsbFlowDeadLetterException(\"Kal\u0131c\u0131 i\u015fleme hatas\u0131\", ex); \n }\n }\n}\n\n\/\/ Startup.cs veya Program.cs i\u00e7erisinde yap\u0131land\u0131rma\npublic void ConfigureServices(IServiceCollection services)\n{\n services.AddAsbFlow(options =>\n {\n options.SetConnection(\"Endpoint=sb:\/\/yournamespace.servicebus.windows.net\/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=YOUR_KEY\");\n });\n\n \/\/ Mesaj i\u015fleyiciyi kaydet\n services.AddAsbMessageHandler();\n\n \/\/ Bir t\u00fcketici tan\u0131mla\n services.AddAsbConsumer(\"your-order-queue\", options =>\n {\n options.MaxConcurrentCalls = 5; \/\/ Ayn\u0131 anda ka\u00e7 mesaj\u0131n i\u015flenece\u011fi\n options.MaxRetries = 3; \/\/ Mesaj\u0131n ka\u00e7 kez yeniden denenece\u011fi\n options.EnableDeadLetteringOnMessageExpiration = true;\n options.DeadLetterMessageOnUnrecoverableException = true; \/\/ AsbFlowDeadLetterException'da DLQ'ya g\u00f6nder\n options.PrefetchCount = 10; \/\/ \u00d6nceden ka\u00e7 mesaj\u0131n \u00e7ekilece\u011fi\n });\n}\n <\/pre>\n<\/code><\/p>\n
Yukar\u0131daki \u00f6rnekte, OrderCreatedEventHandler<\/code> s\u0131n\u0131f\u0131, OrderCreatedEvent<\/code> mesajlar\u0131n\u0131 nas\u0131l i\u015fleyece\u011fini tan\u0131mlar. HandleAsync<\/code> metodu i\u00e7inde i\u015f mant\u0131\u011f\u0131 bulunur. E\u011fer i\u015fleme s\u0131ras\u0131nda ge\u00e7ici bir hata olu\u015fursa (\u00f6rne\u011fin InventoryServiceException<\/code>), bu hatay\u0131 tekrar f\u0131rlatmak AsbFlow'un yap\u0131land\u0131r\u0131lm\u0131\u015f yeniden deneme mekanizmas\u0131n\u0131 tetikler. AddAsbConsumer<\/code> ile t\u00fcketicinin davran\u0131\u015f\u0131n\u0131 (e\u015f zamanl\u0131 \u00e7a\u011fr\u0131 say\u0131s\u0131, yeniden deneme say\u0131s\u0131 vb.) yap\u0131land\u0131rabilirsiniz. E\u011fer belirli bir hata kal\u0131c\u0131 ise ve yeniden denemenin bir faydas\u0131 olmayacaksa, AsbFlowDeadLetterException<\/code> f\u0131rlatarak mesaj\u0131n do\u011frudan \u00f6l\u00fc harf kuyru\u011funa g\u00f6nderilmesini sa\u011flayabilirsiniz.<\/p>\nVaka Analizi: \u00d6deme A\u011f Ge\u00e7idi Entegrasyonu<\/h3>\n
Bir \u00f6deme servisinin, ASB \u00fczerinden gelen \u00f6deme taleplerini i\u015fledi\u011fini d\u00fc\u015f\u00fcnelim. Bu t\u00fcr senaryolarda, \u00f6deme i\u015fleminin g\u00fcvenilirli\u011fi ve tutarl\u0131l\u0131\u011f\u0131 hayati \u00f6neme sahiptir. Ge\u00e7ici a\u011f sorunlar\u0131, \u00fc\u00e7\u00fcnc\u00fc parti \u00f6deme sa\u011flay\u0131c\u0131s\u0131ndaki kesintiler veya API limit a\u015f\u0131m\u0131 gibi durumlar, \u00f6deme taleplerinin ba\u015far\u0131s\u0131z olmas\u0131na neden olabilir.<\/p>\n
Sorun:<\/strong> Ham ASB SDK's\u0131yla, her bir \u00f6deme talebi i\u015flenirken meydana gelebilecek olas\u0131 hatalar\u0131 manuel olarak ele almak, yeniden denemeleri uygulamak ve \u00f6l\u00fc harf kuyru\u011funa g\u00f6nderme mant\u0131\u011f\u0131n\u0131 yazmak olduk\u00e7a karma\u015f\u0131kt\u0131r. Bu durum, veri kayb\u0131 veya tutars\u0131z \u00f6deme durumlar\u0131 riskini art\u0131r\u0131r.<\/p>\n\u00c7\u00f6z\u00fcm:<\/strong> AsbFlow, bu s\u00fcreci basitle\u015ftirir. \u00d6deme servisi, PaymentRequestEvent<\/code> mesajlar\u0131n\u0131 dinleyen bir AsbFlow t\u00fcketicisi olarak yap\u0131land\u0131r\u0131l\u0131r. \u0130\u015fleyici, \u00f6deme a\u011f ge\u00e7idiyle etkile\u015fime girer. E\u011fer \u00f6deme a\u011f ge\u00e7idinde ge\u00e7ici bir sorun olursa, i\u015fleyici bir hata f\u0131rlat\u0131r ve AsbFlow, mesaj\u0131 yap\u0131land\u0131r\u0131lm\u0131\u015f yeniden deneme politikas\u0131na g\u00f6re otomatik olarak yeniden denemeye al\u0131r. \u00d6rne\u011fin, 3 kez yeniden denendikten sonra hala ba\u015far\u0131l\u0131 olunam\u0131yorsa, mesaj otomatik olarak \u00f6l\u00fc harf kuyru\u011funa g\u00f6nderilir. Bu sayede, \u00f6deme ekibi bu mesajlar\u0131 manuel olarak inceleyip sorunu \u00e7\u00f6zebilir veya alternatif bir \u00f6deme y\u00f6ntemi \u00f6nerebilir.<\/p>\n\n\/\/ PaymentService'te \u00f6deme i\u015fleyici\npublic class PaymentRequestEventHandler : IAsbMessageHandler\n{\n private readonly IPaymentGatewayService _gatewayService;\n\n public PaymentRequestEventHandler(IPaymentGatewayService gatewayService)\n {\n _gatewayService = gatewayService;\n }\n\n public async Task HandleAsync(PaymentRequestEvent message, CancellationToken cancellationToken)\n {\n try\n {\n await _gatewayService.ProcessPayment(message.TransactionId, message.Amount);\n Console.WriteLine($\"\u00d6deme ba\u015far\u0131yla i\u015flendi: {message.TransactionId}\");\n }\n catch (PaymentGatewayTemporaryException ex) \/\/ Ge\u00e7ici hata\n {\n Console.WriteLine($\"Ge\u00e7ici \u00f6deme hatas\u0131, yeniden denenecek: {message.TransactionId}\");\n throw; \/\/ AsbFlow'un yeniden deneme mekanizmas\u0131n\u0131 tetikle\n }\n catch (PaymentGatewayPermanentException ex) \/\/ Kal\u0131c\u0131 hata\n {\n Console.WriteLine($\"Kal\u0131c\u0131 \u00f6deme hatas\u0131, DLQ'ya g\u00f6nderiliyor: {message.TransactionId}\");\n throw new AsbFlowDeadLetterException(\"Kal\u0131c\u0131 \u00f6deme a\u011f ge\u00e7idi hatas\u0131\", ex);\n }\n }\n}\n <\/pre>\n<\/code><\/p>\n
Bu yakla\u015f\u0131m, \u00f6deme sisteminin dayan\u0131kl\u0131l\u0131\u011f\u0131n\u0131 art\u0131r\u0131rken, geli\u015ftiricilerin yeniden deneme ve hata i\u015fleme mant\u0131\u011f\u0131n\u0131 her seferinde s\u0131f\u0131rdan yazma ihtiyac\u0131n\u0131 ortadan kald\u0131r\u0131r. AsbFlow, \u00f6deme i\u015flemlerinin g\u00fcvenilir bir \u015fekilde tamamlanmas\u0131n\u0131 sa\u011flayarak, finansal i\u015flemlerdeki riskleri minimize eder.<\/p>\n
AsbFlow ile \u0130leri D\u00fczey Senaryolar ve Performans \u0130pu\u00e7lar\u0131 Nelerdir?<\/h2>\n
AsbFlow, temel mesaj \u00fcretim ve t\u00fcketimini basitle\u015ftirmenin \u00f6tesinde, daha karma\u015f\u0131k da\u011f\u0131t\u0131k sistem gereksinimlerini kar\u015f\u0131lamak i\u00e7in ileri d\u00fczey \u00f6zellikler ve yap\u0131land\u0131rma se\u00e7enekleri sunar. Bu b\u00f6l\u00fcmde, oturum tabanl\u0131 i\u015flemden performansa kadar \u00e7e\u015fitli ileri d\u00fczey konular\u0131 inceleyece\u011fiz.<\/p>\n
Oturum Tabanl\u0131 Mesaj \u0130\u015fleme ile S\u0131ra Garantisi<\/h3>\n
Baz\u0131 senaryolarda, belirli mesaj gruplar\u0131n\u0131n s\u0131ras\u0131yla i\u015flenmesi kritik \u00f6neme sahiptir. \u00d6rne\u011fin, bir kullan\u0131c\u0131n\u0131n sepetindeki \u00fcr\u00fcnleri g\u00fcncelleme veya sipari\u015f durumunu de\u011fi\u015ftirme gibi i\u015flemlerin kronolojik s\u0131raya g\u00f6re ger\u00e7ekle\u015fmesi gerekebilir. Azure Service Bus, bu durumu oturumlar (sessions) ile destekler. AsbFlow, oturum tabanl\u0131 mesaj t\u00fcketimini kolayla\u015ft\u0131r\u0131r:<\/p>\n
\n\/\/ Oturum destekli bir t\u00fcketici yap\u0131land\u0131rmas\u0131\npublic void ConfigureServices(IServiceCollection services)\n{\n \/\/ ... di\u011fer AsbFlow ayarlar\u0131 ...\n\n services.AddAsbConsumer(\"your-session-queue\", options =>\n {\n options.MaxConcurrentCalls = 1; \/\/ Oturum ba\u015f\u0131na tek i\u015flem\n options.SessionProcessorOptions.MaxConcurrentSessions = 5; \/\/ Ayn\u0131 anda 5 farkl\u0131 oturumu i\u015fleyebilir\n options.SessionProcessorOptions.SessionIdleTimeout = TimeSpan.FromMinutes(2);\n options.SessionProcessorOptions.MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(10);\n options.UseSessions = true; \/\/ Oturum \u00f6zelli\u011fini etkinle\u015ftir\n });\n}\n\n\/\/ Mesaj g\u00f6nderirken oturum kimli\u011fini belirtin\npublic class SessionProducerService\n{\n private readonly IAsbProducer _producer;\n\n public SessionProducerService(IAsbProducer producer)\n {\n _producer = producer;\n }\n\n public async Task SendSessionMessage(SessionMessage message, string sessionId)\n {\n await _producer.SendAsync(message, new SendOptions { SessionId = sessionId });\n }\n}\n <\/pre>\n<\/code><\/p>\n
Oturumlar\u0131 etkinle\u015ftirerek, ayn\u0131 SessionId<\/code>'ye sahip t\u00fcm mesajlar\u0131n ayn\u0131 t\u00fcketici \u00f6rne\u011fi taraf\u0131ndan ve geldikleri s\u0131raya g\u00f6re i\u015flenmesini sa\u011flayabilirsiniz. Bu, \u00f6zellikle veri tutarl\u0131l\u0131\u011f\u0131n\u0131n \u00f6n planda oldu\u011fu i\u015f ak\u0131\u015flar\u0131nda vazge\u00e7ilmez bir \u00f6zelliktir.<\/p>\n\u00d6zel Middleware ve \u0130\u015fleme Ak\u0131\u015flar\u0131<\/h3>\n
AsbFlow'un boru hatt\u0131 (pipeline) yakla\u015f\u0131m\u0131, mesaj i\u015fleme s\u00fcrecine \u00f6zel mant\u0131k eklemenize olanak tan\u0131r. Kendi \u00f6zel middleware'\u0131n\u0131z\u0131 olu\u015fturarak, t\u00fcm mesajlar \u00fczerinde ortak i\u015flemler (loglama, yetkilendirme, do\u011frulama, metrik toplama) yapabilirsiniz.<\/p>\n
\n\/\/ \u00d6zel bir loglama middleware'\u0131\npublic class LoggingMiddleware : IAsbMessageMiddleware\n{\n private readonly ILogger> _logger;\n\n public LoggingMiddleware(ILogger> logger)\n {\n _logger = logger;\n }\n\n public async Task InvokeAsync(AsbMessageContext context, Func next)\n {\n _logger.LogInformation($\"Mesaj i\u015flenmeye ba\u015fland\u0131: {context.Message.GetType().Name} - ID: {context.MessageId}\");\n await next(); \/\/ Bir sonraki middleware'\u0131 veya i\u015fleyiciyi \u00e7a\u011f\u0131r\n _logger.LogInformation($\"Mesaj i\u015fleme tamamland\u0131: {context.Message.GetType().Name} - ID: {context.MessageId}\");\n }\n}\n\n\/\/ Middleware'\u0131 yap\u0131land\u0131rmaya ekle\npublic void ConfigureServices(IServiceCollection services)\n{\n services.AddAsbFlow(options =>\n {\n options.UseMiddleware>(); \/\/ Belirli bir mesaj tipi i\u00e7in\n \/\/ veya\n options.UseMiddleware>(); \/\/ T\u00fcm mesajlar i\u00e7in\n });\n \/\/ ...\n}\n <\/pre>\n<\/code><\/p>\n
Bu sayede, i\u015f mant\u0131\u011f\u0131n\u0131z\u0131 temiz tutarken, ortak sorumluluklar\u0131 ayr\u0131, yeniden kullan\u0131labilir bile\u015fenlere ay\u0131rabilirsiniz.<\/p>\n
Performans \u0130pu\u00e7lar\u0131 ve En \u0130yi Pratikler<\/h3>\n\n- Toplu G\u00f6nderim (Batching):<\/strong> Birden fazla mesaj\u0131 tek bir i\u015flemde g\u00f6ndermek, a\u011f gecikmesini azalt\u0131r ve ASB'nin i\u015flem hacmini art\u0131r\u0131r. AsbFlow'un
SendBatchAsync<\/code> metodunu kullanabilirsiniz.<\/li>\n- \u00d6nceden Getirme (Prefetching):<\/strong> T\u00fcketicilerin, bir sonraki mesaj\u0131 beklemeden \u00f6nceden belirli say\u0131da mesaj\u0131 belle\u011fe \u00e7ekmesini sa\u011flar. Bu, mesaj gecikmesini azalt\u0131r ve i\u015flem hacmini art\u0131r\u0131r.
PrefetchCount<\/code> ayar\u0131n\u0131 dikkatlice yap\u0131land\u0131r\u0131n (\u00f6rnekte 10 olarak belirtildi).<\/li>\n- E\u015f Zamanl\u0131l\u0131k (Concurrency):<\/strong>
MaxConcurrentCalls<\/code> veya oturumlar i\u00e7in MaxConcurrentSessions<\/code> ayarlar\u0131yla, ayn\u0131 anda ka\u00e7 mesaj\u0131n veya oturumun i\u015flenece\u011fini belirleyebilirsiniz. Sistem kaynaklar\u0131n\u0131za ve i\u015f y\u00fck\u00fcn\u00fcze uygun de\u011ferler se\u00e7mek performans\u0131 optimize eder.<\/li>\n- Mesaj Boyutu:<\/strong> ASB, tek bir mesaj i\u00e7in belirli bir boyut limitine sahiptir. B\u00fcy\u00fck mesajlar yerine, dosya referanslar\u0131 gibi meta verileri g\u00f6ndermek ve ger\u00e7ek veriyi Blob Storage gibi daha uygun bir yerde saklamak, hem performans\u0131 art\u0131r\u0131r hem de maliyetleri d\u00fc\u015f\u00fcr\u00fcr.<\/li>\n
- Ba\u011flant\u0131 Y\u00f6netimi:<\/strong> AsbFlow, ASB ba\u011flant\u0131lar\u0131n\u0131 otomatik olarak y\u00f6netir ve yeniden kullan\u0131r. Ba\u011flant\u0131 nesnelerini uygun \u015fekilde ya\u015fam d\u00f6ng\u00fcs\u00fc boyunca y\u00f6netmek \u00f6nemlidir. Genellikle singleton olarak yap\u0131land\u0131r\u0131l\u0131rlar.<\/li>\n<\/ul>\n\n Uzman \u0130pucu: PrefetchCount de\u011ferini MaxConcurrentCalls de\u011ferinin kat\u0131 olarak ayarlamak (\u00f6rne\u011fin MaxConcurrentCalls = 5 ise PrefetchCount = 10 veya 15), t\u00fcketici taraf\u0131nda bekleme s\u00fcrelerini minimize ederek performans\u0131 %20-40 oran\u0131nda art\u0131rabilir. Ancak \u00e7ok y\u00fcksek de\u011ferler bellek t\u00fcketimini art\u0131rabilir, bu y\u00fczden test ederek optimize edin.\n <\/div>\n
Mobil uyumlu HTML \u00fcretme kural\u0131 gere\u011fi, AsbFlow kullan\u0131m\u0131yla do\u011frudan ilgili olmasa da, web aray\u00fczleri geli\u015ftirirken mobil uyumluluk i\u00e7in media query \u00f6rnekleri a\u015fa\u011f\u0131da verilmi\u015ftir. Bu, genel bir tasar\u0131m ilkesi olarak projenizin kullan\u0131c\u0131 aray\u00fcz\u00fc k\u0131sm\u0131nda ele al\u0131nabilir.<\/p>\n