<\/div>\n

$\".NET'te$ <\/a>Merhaba,
\n
\nMicroservice mimarileri yayg\u0131nla\u015ft\u0131k\u00e7a uygulamalar aras\u0131ndaki ileti\u015fim de giderek daha kritik bir hal almaktad\u0131r. Bir sipari\u015f olu\u015fturuldu\u011funda stok servisinin haberdar edilmesi, \u00f6deme tamamland\u0131\u011f\u0131nda e-posta g\u00f6nderilmesi veya arka planda \u00e7al\u0131\u015fan onlarca servisin birbirleriyle g\u00fcvenilir bir \u015fekilde haberle\u015fmesi art\u0131k modern yaz\u0131l\u0131m geli\u015ftirmenin temel ihtiya\u00e7lar\u0131ndan birisidir. Bu noktada mesajla\u015fma sistemleri (message broker) devreye girmektedir. Uzun y\u0131llard\u0131r RabbitMQ<\/a>, Apache Kafka<\/a> ve Azure Service Bus gibi \u00e7\u00f6z\u00fcmler bu ihtiyac\u0131 kar\u015f\u0131l\u0131yor olsa da son y\u0131llarda performans\u0131, d\u00fc\u015f\u00fck gecikme s\u00fcresi ve sade mimarisiyle \u00f6ne \u00e7\u0131kan NATS<\/strong><\/em> ve onun kal\u0131c\u0131 mesajla\u015fma katman\u0131 olan JetStream<\/strong><\/em>, \u00f6zellikle microserve tabanl\u0131 .NET uygulamalar\u0131nda g\u00fc\u00e7l\u00fc bir alternatif haline gelmektedir. Bu i\u00e7eri\u011fimizde, NATS<\/em> ve JetStream<\/em>‘in ne oldu\u011funu, birbirlerinden hangi noktalarda ayr\u0131ld\u0131klar\u0131n\u0131, hangi problemleri \u00e7\u00f6zd\u00fcklerini ve Asp.NET Core uygulamalar\u0131nda nas\u0131l kullan\u0131labileceklerini ad\u0131m ad\u0131m inceleyecek ve ayr\u0131ca makalenin sonunda yaln\u0131zca temel Publish\/Subscribe<\/a> yap\u0131s\u0131n\u0131 de\u011fil, kal\u0131c\u0131 mesajlar (Persistence), ACK mekanizmas\u0131, Durable Consumer, Stream yap\u0131lar\u0131 ve g\u00fcvenilir event i\u015fleme gibi production ortamlar\u0131nda ihtiya\u00e7 duyulan bir\u00e7ok \u00f6zellikleri de uygulamal\u0131 olarak irdelemi\u015f olaca\u011f\u0131z.<\/p>\n

\n
\n
Ba\u015fl\u0131klar<\/p>\n Toggle<\/span>
NATS Nedir?<\/a>
NATS’\u0131n \u00c7al\u0131\u015fma Mant\u0131\u011f\u0131 Nas\u0131ld\u0131r?<\/a><\/li><\/ul><\/li>
JetStream Nedir?<\/a><\/li>
Kullan\u0131m\u0131n\u0131 \u0130nceleyelim…<\/a>
NATS Server’\u0131n Kurulumu (Docker)<\/a><\/li>
Asp.NET Core \u00dczerinden Core NATS’a Ba\u011flanma<\/a><\/li>
Mesaj Yay\u0131nlama ve Subscriber Olu\u015fturma<\/a>
Console Application’dan Subscriber Olu\u015fturma<\/a><\/li><\/ul><\/li>
\u0130\u015flem Tamamland\u0131ktan Sonra ACK G\u00f6nderin!<\/a><\/li>
Consumer’lar\u0131 Idempotent Olarak Ayarlay\u0131n!<\/a><\/li><\/ul><\/li><\/ul><\/li><\/ul><\/nav><\/div>\n
<\/span>NATS Nedir?<\/span><\/h2>\n
NATS, distributed sistemler ve microservice mimariler i\u00e7in geli\u015ftirilmi\u015f, y\u00fcksek performansl\u0131 ve d\u00fc\u015f\u00fck gecikmeli (low latency) bir mesajla\u015fma sistemidir (ya da bir ba\u015fka deyi\u015fle message broker’d\u0131r) Temel amac\u0131, uygulamalar\u0131n birbirleriyle do\u011frudan ba\u011flant\u0131 kurmas\u0131na gerek kalmaks\u0131z\u0131n g\u00fcvenilir ve h\u0131zl\u0131 bir \u015fekilde haberle\u015febilmelerini sa\u011flamakt\u0131r.<\/p>\n
<\/span>NATS’\u0131n \u00c7al\u0131\u015fma Mant\u0131\u011f\u0131 Nas\u0131ld\u0131r?<\/span><\/h3>\n
NATS’\u0131n temel \u00e7al\u0131\u015fma prensibi Puclic\/Subscribe mant\u0131\u011f\u0131na dayanmaktad\u0131r. Bir subject<\/em><\/strong>‘e mesaj yay\u0131nland\u0131\u011f\u0131 taktirde, o subject’e abone olan\/dinleyen herkese bu mesaj g\u00f6nderilecektir. E\u011fer subject’i kimse dinlemiyorsa, mesaj kaybolacakt\u0131r. Yani anlayaca\u011f\u0131n\u0131z canl\u0131 bildirim senaryolar\u0131 i\u00e7in olduk\u00e7a uygundur ancak i\u015f kuyru\u011fu dedi\u011fimiz (work queue) i\u00e7in hi\u00e7te de\u011fildir!<\/p>\n
Esas\u0131nda NATS’te queue diye bir kavram yoktur. Onun yerine subject<\/strong> kavram\u0131 vard\u0131r. Subject<\/strong>, mesajlar\u0131n hangi topic’e ait oldu\u011funu belirten mant\u0131ksal kanald\u0131r. Producer mesaj\u0131n\u0131 belirli bir subject’e yay\u0131nlar, bu subject’i dinleyen t\u00fcm subscriber’lar ise mesaj\u0131 elde edebilirler.<\/em><\/p><\/blockquote>\n
$\".NET'te$ <\/a> $\".NET'te$ <\/a><\/p>\n
<\/span>JetStream Nedir?<\/span><\/h2>\n
JetStream, NATS’in persistent messaging katman\u0131d\u0131r.<\/em><\/p><\/blockquote>\n
NATS’in varsay\u0131lan \u00e7al\u0131\u015fma mant\u0131\u011f\u0131nda mesajlar yaln\u0131zca o anda subscribe olmu\u015f olanlara iletilecektir. E\u011fer ilgili subscriber \u00e7al\u0131\u015fm\u0131yorsa veya o subject’i dinleyen hi\u00e7bir uygulama yoksa, mesaj kal\u0131c\u0131 olarak saklanmayacak ve kaybolacakt\u0131r.<\/p>\n
Bu davran\u0131\u015f ger\u00e7ek zamanl\u0131 (real-time) haberle\u015fme senaryolar\u0131 i\u00e7in olduk\u00e7a avantajl\u0131d\u0131r. \u00c7\u00fcnk\u00fc NATS’in bu kadar y\u00fcksek performans sunmas\u0131n\u0131n en \u00f6nemli sebeplerinden biri de mesajlar\u0131 varsay\u0131lan olarak diske yazmamas\u0131d\u0131r.<\/p>\n
Ancak hak verirsiniz ki her sistem canl\u0131 bildirim mant\u0131\u011f\u0131yla \u00e7al\u0131\u015fmamaktad\u0131r. \u00d6rne\u011fin, bir e-ticaret uygulamas\u0131nda olu\u015fturulan sipari\u015f, tamamlanan \u00f6deme veya ger\u00e7ekle\u015ftirilen banka transferi gibi olaylar\u0131n kaybolmas\u0131 kabul edilebilir bir durum de\u011fildir \ud83d\ude42 E\u011fer ilgili servis o anda \u00e7al\u0131\u015fm\u0131yorsa bile, sistem aya\u011fa kalkt\u0131\u011f\u0131nda bu mesaj\u0131n al\u0131n\u0131p i\u015flenebilmesi gerekmektedir.<\/p>\n
\u0130\u015fte JetStream, tam olarak bu problemi \u00e7\u00f6zmek i\u00e7in geli\u015ftirilmi\u015ftir. JetStream, NATS’in \u00fczerine eklenen bir persistence (kal\u0131c\u0131 mesajla\u015fma) katman\u0131d\u0131r. Mesajlar\u0131 yaln\u0131zca iletmekle kalmamakta, ayn\u0131 zamanda belirlenen kurallara g\u00f6re diskte saklamakta, gerekti\u011finde ise tekrar t\u00fcketilmesini sa\u011flayarak, mesajlar\u0131n g\u00fcvenilir bir \u015fekilde i\u015flenmesini takip etmektedir.<\/p>\n
B\u00f6ylece NATS, yaln\u0131zca anl\u0131k mesajla\u015fma yapan bir message broker olmaktan \u00e7\u0131kabilmekte ve g\u00fcvenilir mesaj teslimi (reliable messaging) yapabilen ve event streaming yetene\u011fine sahip olan g\u00fc\u00e7l\u00fc bir platform haline gelmektedir.<\/p>\n
JetStream sayesinde;<\/p>\n
\n
Mesajlar kal\u0131c\u0131 olarak saklanabilmektedir.<\/li>\n
Daha sonra sisteme kat\u0131lan consumer’lar ge\u00e7mi\u015f mesajlar\u0131 okuyabilmektedir.<\/li>\n
\u0130\u015flenemeyen mesajlar tekrar i\u015flenebilmektedir (retry)<\/li>\n
Consumer’\u0131n mesaj\u0131 ba\u015far\u0131yla i\u015fledi\u011fi ACK mekanizmas\u0131yla do\u011frulanabilmektedir.<\/li>\n
Consumer kapansa bile kald\u0131\u011f\u0131 yerden devam edebilmektedir (durable consumer)<\/li>\n
\u0130stenildi\u011finde ge\u00e7mi\u015f mesajlar yeniden oynat\u0131labilmektedir (replay)<\/li>\n<\/ul>\n
K\u0131saca JetStream’in temel amac\u0131, Core NATS’in h\u0131z\u0131ndan vazge\u00e7meden, mesajlar\u0131n g\u00fcvenilir bir \u015fekilde saklanmas\u0131n\u0131 ve t\u00fcketilmesini sa\u011flamakt\u0131r.<\/em><\/p><\/blockquote>\n
$\".NET'te$ <\/a><\/p>\n
<\/span>Kullan\u0131m\u0131n\u0131 \u0130nceleyelim…<\/span><\/h2>\n
NATS ve JetStream’in hangi problemleri \u00e7\u00f6zd\u00fc\u011f\u00fcn\u00fc ve birbirlerinden hangi noktalarda ayr\u0131ld\u0131klar\u0131n\u0131 inceledi\u011fimize g\u00f6re, art\u0131k bunlar\u0131 .NET uygulamalar\u0131nda nas\u0131l kullanabilece\u011fimize ge\u00e7ebiliriz. Bu a\u015famada, \u00f6ncelikle NATS sunucusunun kurulumuna odaklanacak, ard\u0131ndan bu sunucuya ba\u011flant\u0131 kurarak, mesaj yay\u0131nlama ve dinleme i\u015flemlerini ele al\u0131yor olaca\u011f\u0131z. Devam\u0131nda ise ayn\u0131 \u00f6rne\u011fi JetStream deste\u011fiyle geli\u015ftirerek mesajlar\u0131n kal\u0131c\u0131 olarak saklanmas\u0131n\u0131 sa\u011flayacak ve nihai olarak da ACK mekanizmas\u0131n\u0131 ve g\u00fcvenilir mesaj t\u00fcketimini de uygulamal\u0131 olarak inceliyor olaca\u011f\u0131z.<\/p>\n
<\/span>NATS Server’\u0131n Kurulumu (Docker)<\/span><\/h4>\n
NATS ile ilgili \u00e7al\u0131\u015fmalara ge\u00e7meden \u00f6nce mesajlar\u0131 y\u00f6netecek olan NATS Server’\u0131 aya\u011fa kald\u0131rmam\u0131z gerekmektedir. Bunun i\u00e7in Core NATS’\u0131 JetStream deste\u011fiyle birlikte Docker ortam\u0131nda \u00e7al\u0131\u015ft\u0131rabilmek i\u00e7in a\u015fa\u011f\u0131daki talimattan istifade edebiliriz:<\/p>\n
docker run -d --name nats -p 4222:4222 -p 8222:8222 nats:latest -js -m 8222<\/strong><\/code><\/p>\n
Bu talimatta kulland\u0131\u011f\u0131m\u0131z -js<\/code> parametresi ile NATS Server’da JetStream \u00f6zelli\u011fi aktif bir \u015fekilde gelmektedir. -m 8222<\/code> parametresi ise NATS Server’\u0131n monitoring dashboard’unu http:\/\/localhost:8222\/<\/a> portunda aktifle\u015ftirecektir.<\/p>\n
<\/span>Asp.NET Core \u00dczerinden Core NATS’a Ba\u011flanma<\/span><\/h4>\nAsp.NET Core’dan NATS’a ba\u011flant\u0131 sa\u011flayabilmek i\u00e7in \u00f6ncelikle a\u015fa\u011f\u0131daki iki paketin uygulamaya y\u00fcklenmesi gerekmektedir:<\/p>\n\n\n Gerekli K\u00fct\u00fcphaneler\n <\/div>\n\n\nNATS.Net<\/a><\/li>\n NATS.Extensions.Microsoft.DependencyInjection<\/a><\/li>\n<\/ul><\/div>\n<\/div>\nArd\u0131ndan a\u015fa\u011f\u0131daki yap\u0131land\u0131rmalar e\u015fli\u011finde servisler uygulamaya eklenmelidir:<\/p>\n\n\r\nbuilder.Services.AddNatsClient(natsBuilder =>\r\n natsBuilder.ConfigureConnection(natsConnection => new NatsConnection(NatsOpts.Default with { Url = "nats:\/\/localhost:4222" })));\r\n\r\nbuilder.Services.AddSingleton(serviceProvider =>\r\n serviceProvider.GetRequiredService<INatsConnection>().CreateJetStreamContext());\r\n<\/pre>\n<\/div>\nBurada AddNatsClient<\/code> metodu ile NATS’a ait servisler uygulaman\u0131n IoC container’\u0131na y\u00fcklenmekte ve bir yandan da NATS Server’a ba\u011flant\u0131 ger\u00e7ekle\u015ftirilmektedir. CreateJetStreamContext<\/code> metodu ise bu NATS ba\u011flant\u0131s\u0131 \u00fczerinden JetStream \u00f6zelliklerine eri\u015fim sa\u011flamaktad\u0131r.<\/p>\n<\/span>Mesaj Yay\u0131nlama ve Subscriber Olu\u015fturma<\/span><\/h4>\nAsp.NET Core \u00fczerinden mesaj yay\u0131nlamay\u0131 \u00f6rneklendirebilmek i\u00e7in a\u015fa\u011f\u0131daki gibi basit bir endpoint olu\u015fturulmas\u0131 yeterli olacakt\u0131r kanaatindeyim:<\/p>\n\n\r\napp.MapGet("\/create-job", async (INatsJSContext natsJSContext, CancellationToken cancellationToken) =>\r\n{\r\n PubAckResponse pubAckResponse = await natsJSContext.PublishAsync(\r\n subject: Subjects.JobsSubject,\r\n data: new Message(Text: "Naber d\u00fcyna!", Date: DateTime.UtcNow),\r\n cancellationToken: cancellationToken);\r\n pubAckResponse.EnsureSuccess();\r\n\r\n return TypedResults.Ok();\r\n});\r\n<\/pre>\n<\/div>\nVe bu mesaj\u0131 yine Asp.NET Core’da t\u00fcketebilmek i\u00e7in de a\u015fa\u011f\u0131daki gibi bir background service tasarlanabilir:<\/p>\n\n\r\n public class JowWorkerBackgroundService(INatsJSContext natsJSContext) : BackgroundService\r\n {\r\n protected override async Task ExecuteAsync(CancellationToken stoppingToken)\r\n {\r\n await natsJSContext.CreateStreamAsync(new StreamConfig("JOBS", ["jobs-subject"])\r\n {\r\n Retention = StreamConfigRetention.Workqueue,\r\n Storage = StreamConfigStorage.File\r\n });\r\n\r\n var consumer = await natsJSContext.CreateOrUpdateConsumerAsync("JOBS", new ConsumerConfig("JOBS-CONSUMER")\r\n {\r\n AckWait = TimeSpan.FromSeconds(30),\r\n AckPolicy = ConsumerConfigAckPolicy.Explicit,\r\n MaxDeliver = 5\r\n }, cancellationToken: stoppingToken);\r\n\r\n await foreach (var message in consumer.ConsumeAsync<Message>(cancellationToken: stoppingToken))\r\n {\r\n await Console.Out.WriteLineAsync($"Message : {message.Data.Text}");\r\n await Console.Out.WriteLineAsync($"Date : {message.Data.Date}");\r\n await Console.Out.WriteLineAsync($"****************");\r\n await message.AckAsync();\r\n }\r\n }\r\n }\r\n<\/pre>\n<\/div>\nBurada \u00f6nemli g\u00f6rd\u00fc\u011f\u00fcm baz\u0131 noktalar\u0131 izah etmekte fayda g\u00f6rmekteyim; CreateStreamAsync<\/code> metodu ile mesajlar\u0131 kal\u0131c\u0131 olarak saklayabilmek i\u00e7in bir stream olu\u015fturulmaktad\u0131r. Normal \u015fartlarda NATS, fire-and-forget<\/code> davran\u0131\u015f\u0131 sergiledi\u011fi, yani al\u0131c\u0131 yoksa mesajlar kaybolaca\u011f\u0131 i\u00e7in bu \u00f6zellik tam da bu noktada JetStream ile devreye sokulmu\u015f olacakt\u0131r. Dikkat ederseniz Storage<\/code> property’sine ‘File’<\/em> de\u011feri verilmi\u015ftir. B\u00f6ylece mesajlar disk’te saklanacak ve sunucu kapansa dahi korunacakt\u0131rlar. E\u011fer bu property’e ‘Memory’<\/em> de\u011feri verilmi\u015f olsayd\u0131 mesajlar bellekte saklanacakt\u0131 ve sunucu kapand\u0131\u011f\u0131 taktirde do\u011fal olarak kaybolacaklard\u0131…<\/p>\n<\/a>Ee peki hoca, mesajlar disk’te kal\u0131c\u0131 hale getirildi\u011finde nerede tutuluyorlar?<\/strong><\/em> sorunuzu duyar gibiyim… Bunun i\u00e7in NATS’in dashboard’undan JetStream verilerine http:\/\/localhost:8222\/jsz<\/a> adresinden bakmam\u0131z yeterli olacakt\u0131r.<\/p>\n Dikkat ederseniz yandaki g\u00f6rselde de vurguland\u0131\u011f\u0131 gibi store_dir<\/em> alan\u0131 mesajlar\u0131n kal\u0131c\u0131 olarak sakland\u0131\u011f\u0131 path’i bizlere vermektedir.<\/p>\n Retention<\/code> property’sine gelirsek e\u011fer mesajlar\u0131n ne zaman silinece\u011fini belirleyen bir \u00f6zelliktir. Burada ‘Workqueue’<\/em> diyerek ilgili mesaj\u0131n ACK edildi\u011fi taktirde silinece\u011fini ifade etmi\u015f oluyoruz. Ayr\u0131ca ‘Limits’<\/em> diyerek belirleyebilece\u011fimiz boyut, say\u0131 veya s\u00fcre limitine g\u00f6re silmeyi ger\u00e7ekle\u015ftirtebiliriz ya da Interest diyerek de hi\u00e7 consumer kalmad\u0131\u011f\u0131 taktirde mesajlar\u0131 sildiretebiliriz.<\/p>\n Diyelim ki, \u00f6rnekte oldu\u011fu gibi bu alan ‘Workqueue’<\/em> olarak yap\u0131land\u0131r\u0131lm\u0131\u015f olmas\u0131na ra\u011fmen, foreach d\u00f6ng\u00fcs\u00fc i\u00e7erisinde AckAsync<\/code> \u00e7a\u011fr\u0131s\u0131 yap\u0131lmam\u0131\u015f olsayd\u0131, mesaj AckWait<\/code> s\u00fcresi dolduktan sonra yeniden subscriber taraf\u0131ndan teslim al\u0131nacakt\u0131.<\/p>\n CreateOrUpdateConsumerAsync<\/code> metoduna gelirsek e\u011fer bunla da ad\u0131 \u00fczerinde olu\u015fturulan stream’i okuyan\/t\u00fcketen bir consumer olu\u015fturulmaktad\u0131r. Burada da ak\u0131llara muhtemelen birden fazla consumer olu\u015fturursak ne olur?<\/strong><\/em> sorusu gelecektir. Bu sorunun iki t\u00fcrl\u00fc cevab\u0131n\u0131 verebiliriz;<\/p>\n \nAyn\u0131 isimde farkl\u0131 makinelerde consumer olu\u015fturulursa…<\/strong><\/em>\n\n\r\n\/\/ Makine 1\r\nnew ConsumerConfig("JOBS-CONSUMER")\r\n\r\n\/\/ Makine 2\r\nnew ConsumerConfig("JOBS-CONSUMER") \/\/ AYNI \u0130S\u0130M\r\n\r\n\/\/ Makine 3\r\nnew ConsumerConfig("JOBS-CONSUMER") \/\/ AYNI \u0130S\u0130M\r\n<\/pre>\n<\/div>\nBu durumda mesajlar makineler aras\u0131nda payla\u015ft\u0131r\u0131lacak ve b\u00f6ylece load balancing davran\u0131\u015f\u0131 sergilenmi\u015f olacakt\u0131r. Her mesaj sadece bir worker’a g\u00f6nderilecektir…<\/p>\nMesaj 1 \u2192 Makine 1 \nMesaj 2 \u2192 Makine 2 \nMesaj 3 \u2192 Makine 1\n<\/div>\n<\/li>\nFarkl\u0131 isimlerde consumer’lar olu\u015fturulursa…<\/strong><\/em>\n\n\r\n\/\/ Worker 1\r\nnew ConsumerConfig("JOBS-CONSUMER-1")\r\n\r\n\/\/ Worker 2\r\nnew ConsumerConfig("JOBS-CONSUMER-2") \/\/ FARKLI \u0130S\u0130M\r\n\r\n\/\/ Worker 3\r\nnew ConsumerConfig("JOBS-CONSUMER-3") \/\/ FARKLI \u0130S\u0130M\r\n<\/pre>\n<\/div>\nBu durumda da birbirlerinden ger\u00e7ekten farkl\u0131 consumer’lar \u00fcretilmi\u015f olacakt\u0131r. Dolay\u0131s\u0131yla mesajlar hepsine g\u00f6nderilmi\u015f olacakt\u0131r.\n<\/li>\n<\/ul>\n<\/span>Console Application’dan Subscriber Olu\u015fturma<\/span><\/h5>\nAyr\u0131ca Asp.NET Core’daki background service’in d\u0131\u015f\u0131nda bir console uygulamas\u0131ndan da nas\u0131l subscriber olu\u015fturabilece\u011fimizi ele almakta fayda g\u00f6rmekteyim. Bunun i\u00e7in ilgili console uygulamas\u0131na NATS.Net<\/a> k\u00fct\u00fcphanesi y\u00fcklenmeli ve a\u015fa\u011f\u0131daki gibi bir \u00e7al\u0131\u015fma ger\u00e7ekle\u015ftirilmelidir:<\/p>\n \n\r\nusing NATS.JetStream.Demo.Shared;\r\nusing NATS.Net;\r\n\r\nawait using var natsClient = new NatsClient();\r\n\r\nawait foreach (var message in natsClient.Connection.SubscribeAsync<Message>(subject: Subjects.JobsSubject))\r\n{\r\n await Console.Out.WriteLineAsync($"Message : {message.Data.Text}");\r\n await Console.Out.WriteLineAsync($"Date : {message.Data.Date}");\r\n await Console.Out.WriteLineAsync($"****************");\r\n}\r\n<\/pre>\n<\/div>\n<\/span>\u0130\u015flem Tamamland\u0131ktan Sonra ACK G\u00f6nderin!<\/span><\/h4>\nJetStream ile \u00e7al\u0131\u015fan consumer uygulamalar\u0131nda dikkat edilmesi gereken en \u00f6nemli husus, ACK (Acknowledgement) mesaj\u0131n\u0131n i\u015f mant\u0131\u011f\u0131 ba\u015far\u0131yla tamamland\u0131ktan sonra g\u00f6nderilmesidir. Bunun nedeni, JetStream’in sundu\u011fu at-least-once delivery (en az bir kez teslimat) garantisine davran\u0131\u015fsal olarak riayet edebilmektir. Bu garanti sayesinde bir consumer, kendisine iletilen mesajlar\u0131 i\u015flerken beklenmedik bir \u015fekilde kapanabilir yahut ACK g\u00f6ndermeden \u00f6nce hata alabilir. B\u00f6yle bir durumda JetStream, mesajlar\u0131n kaybolmas\u0131n\u0131 \u00f6nlemek i\u00e7in belirli bir s\u00fcre sonra ayn\u0131 mesaj(lar)\u0131 yeniden ilgili consumer’a teslim etmelidir. Aksi taktirde mesaja dair i\u015flem tamamlanmadan \u00f6nce ACK g\u00f6nderilirse JetStream, ilgili mesaj\u0131n ba\u015far\u0131yla i\u015flendi\u011fini varsayacak ve b\u00f6ylece bahsedilen bu riskler ciddi olarak g\u00f6ze al\u0131nm\u0131\u015f olacakt\u0131r. Bu nedenle mesaj al\u0131nd\u0131ktan sonra i\u015flenmesi beklenmeli ve ba\u015far\u0131yla i\u015flendiyse ACK g\u00f6nderilmelidir.<\/p>\n<\/span>Consumer’lar\u0131 Idempotent Olarak Ayarlay\u0131n!<\/span><\/h4>\nBununla birlikte at-least-once delivery modelinin do\u011fal bir sonucu olarak ayn\u0131 mesaj\u0131n birden fazla kez i\u015flenmesi de s\u00f6z konusu olabilir. Yani consumer bir mesaj\u0131 ba\u015far\u0131yla i\u015flemi\u015f ancak ACK g\u00f6nderilmedi\u011fi i\u00e7in JetStream taraf\u0131ndan ayn\u0131 mesaj (t\u00fcrl\u00fc nedenlerden dolay\u0131) tekrar g\u00f6nderilmi\u015f olabilir. Evet… JetStream, mesajlar\u0131n consumer’lar taraf\u0131ndan i\u015flenip i\u015flenmedi\u011fini bilememektedir. Bu nedenle consumer uygulamalar\u0131n\u0131n da idempotent<\/a> olarak tasarlanmas\u0131 b\u00fcy\u00fck \u00f6nem ta\u015f\u0131maktad\u0131r. Ba\u015fka bir ifadeyle, ayn\u0131 mesaj birden fazla kez al\u0131nsa bile sistem her seferinde ayn\u0131 sonucu \u00fcretmeli ve ayn\u0131 i\u015flemi tekrar tekrar ger\u00e7ekle\u015ftirmemelidir. <\/p>\n Nihai olarak; \nBu makale boyunca NATS ve JetStream’in temel \u00e7al\u0131\u015fma mant\u0131\u011f\u0131n\u0131, birbirlerinden hangi noktalarda ayr\u0131ld\u0131klar\u0131n\u0131 ve .NET uygulamalar\u0131nda nas\u0131l kullan\u0131labileceklerini ad\u0131m ad\u0131m incelemi\u015f olduk. G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere NATS, d\u00fc\u015f\u00fck gecikme s\u00fcreleriyle i\u015flevsellik g\u00f6steren, son derece h\u0131zl\u0131 bir message broker’d\u0131r. Varsay\u0131lan olarak mesajlar\u0131 kal\u0131c\u0131 \u015fekilde saklamad\u0131\u011f\u0131 i\u00e7in canl\u0131 bildirimler ve ger\u00e7ek zamanl\u0131 haberle\u015fmeler gibi senaryolara olduk\u00e7a uyum g\u00f6stermektedir. Ancak mesaj kayb\u0131n\u0131n kabul edilemeyece\u011fi i\u015f ak\u0131\u015flar\u0131nda yeterli olmayaca\u011f\u0131 i\u00e7in JetStream imdad\u0131na yeti\u015fmektedir. JetStream ile NATS’in \u00fczerine kal\u0131c\u0131 mesajla\u015fma, ACK mekanizmas\u0131, retry, replay ve durable consumer gibi g\u00fcvenilir bir mesajla\u015fma altyap\u0131s\u0131 sunan \u00f6zellikler eklenmektedir.<\/p>\n .NET taraf\u0131ndan olaya bakarsak e\u011fer NATS.NET paketi sayesinde hem Core NATS’in hem de JetStream yap\u0131land\u0131rmas\u0131n\u0131n olduk\u00e7a sade ve geli\u015ftirici dostu oldu\u011funu g\u00f6rmekteyiz. Birka\u00e7 sat\u0131r kodla mesaj yay\u0131nlayabilmekte, farkl\u0131 servislerde bu mesajlar\u0131 dinleyebilmekte ve JetStream sayesinde production ortamlar\u0131nda ihtiya\u00e7 duyulan g\u00fcvenilir mesaj i\u015fleme senaryolar\u0131n\u0131 kolayl\u0131kla hayata ge\u00e7irebilmekteyiz.<\/p>\n Umar\u0131m bu i\u00e7erik, NATS ve JetStream’e ba\u015flang\u0131\u00e7 yapman\u0131z i\u00e7in faydal\u0131 bir kaynak olmu\u015ftur. <\/p>\n \u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle… \nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere… \n\u0130yi \u00e7al\u0131\u015fmalar…<\/p>\n \n\n \n\u00d6rnek \u00e7al\u0131\u015fmaya a\u015fa\u011f\u0131daki GitHub reposundan eri\u015febilirsiniz.<\/div>\nhttps:\/\/github.com\/gncyyldz\/NATS.JetStream.Demo.API<\/div>\n<\/p><\/div>\n<\/p><\/div>\n\n Bu repository, ilgili konuya dair \u00f6rnek \u00e7al\u0131\u015fman\u0131n kaynak kodlar\u0131n\u0131 ve mimari yap\u0131s\u0131n\u0131 i\u00e7ermektedir. Detaylar i\u00e7in GitHub \u00fczerinden incelemede bulunabilirsiniz.\n <\/div>\n \n GitHub\u2019da G\u00f6r\u00fcnt\u00fcle \u2192 \n <\/a><\/p>\n<\/div>\n","protected":false},"excerpt":{"rendered":" Merhaba, Microservice mimarileri yayg\u0131nla\u015ft\u0131k\u00e7a uygulamalar aras\u0131ndaki ileti\u015fim de giderek daha kritik bir hal almaktad\u0131r. Bir sipari\u015f olu\u015fturuldu\u011funda stok servisinin haberdar edilmesi, \u00f6deme tamamland\u0131\u011f\u0131nda e-posta g\u00f6nderilmesi veya arka planda \u00e7al\u0131\u015fan onlarca servisin birbirleriyle g\u00fcvenilir bir...<\/p>\n","protected":false},"author":1,"featured_media":28794,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3573],"tags":[5738,5734,3575,5733,5736,5735],"class_list":["post-28771","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-microservices","tag-at-least-once-delivery","tag-jetstream","tag-microservice","tag-nats","tag-publish-subscriber","tag-reliable-messaging"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/28771","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=28771"}],"version-history":[{"count":14,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/28771\/revisions"}],"predecessor-version":[{"id":28795,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/28771\/revisions\/28795"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/28794"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=28771"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=28771"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=28771"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}