Queue, Cache, Olay ve Gerçek Zamanlı Sistemler

Üretici ile tüketici arasında işleri mesaj olarak geçici saklayan sistem.

Mesajların belirli sırayla tüketildiği kuyruk.

Queue veya topic'e mesaj yayınlayan uygulama.

Mesajı alıp işleyen uygulama veya worker.

İş emri, olay veya veri taşıyan mesajlaşma birimi.

Mesajın taşıdığı asıl veri.

Mesaj kimliği, türü ve trace bilgisi gibi metadata.

Mesajları kabul eden, saklayan ve tüketicilere ileten sistem.

Queue, exchange ve routing key kullanan mesaj broker'ı.

Yüksek hacimli olay akışlarını partition'lı kalıcı log olarak saklayan platform.

Redis içinde append-only mesaj akışı ve consumer group sağlayan veri yapısı.

Redis üzerinde Node.js job queue, retry ve schedule özellikleri sunan kütüphane.

Worker tarafından asenkron çalıştırılacak görev.

Queue'dan job alıp işlemi gerçekleştiren süreç.

Benzer job'ları ortak kuyruğa yönlendiren isim.

Aynı queue içindeki farklı görev davranışını belirten alan.

Job'ı benzersiz tanımlayıp duplicate önlemeye yardım eden kimlik.

Waiting, active, completed, failed veya delayed gibi görev durumu.

Belirli zaman geçtikten sonra işlenmeye hazır olan görev.

Takvim veya cron kuralıyla oluşturulan iş.

Belirli periyotta tekrar çalışan job.

Normal sıra yerine öncelik değerine göre daha erken işlenen görev.

Başarısız job'ı belirli sayıda tekrar çalıştırma.

Bir job'ın kaçıncı çalışma denemesi.

Retry denemeleri arasında bekleme stratejisi.

Her denemede aynı süre bekleyen retry.

Her denemede bekleme süresini katlayarak artırır.

Belirli deneme sonrası işlenemeyen mesajların taşındığı ayrı kuyruk.

İçeriği veya hatası nedeniyle her denemede consumer'ı başarısız eden mesaj.

Consumer'ın mesajı başarıyla işlediğini broker'a bildirmesi.

Mesajın işlenemediğini ve yeniden kuyruğa alınması/atılması gerektiğini bildirir.

Alınan mesajın başka consumer'a görünmeden işlenebileceği süre.

Mesajların grup üyeleri arasında paylaştırıldığı tüketici grubu.

Aynı queue'dan paralel job alan birden fazla worker.

Tek worker'ın aynı anda işleyebileceği job sayısı.

Consumer'ın acknowledgement öncesi alabileceği mesaj sayısı.

Kuyrukta bekleyen mesaj sayısı.

Consumer'ın üretilen mesaj akışının ne kadar gerisinde kaldığı.

Birim zamanda işlenen mesaj sayısı.

Mesajların yayınlandığı sırayla işlenmesi garantisi.

Mesaj akışını anahtara göre paralel alt loglara bölen yapı.

Mesajın hangi partition'a gideceğini belirleyen anahtar.

Kafka partition içindeki mesaj konumu.

Mesajların broker üzerinde ne kadar süre veya boyuta kadar saklanacağı.

Broker yeniden başlasa da queue tanımının korunması.

Broker diske yazarak yeniden başlatmada korumaya çalıştığı mesaj.

Mesajın kaybolmaması için tekrar teslim ihtimalini kabul eden model.

Tekrarı engellerken mesaj kaybı ihtimalini kabul eden model.

Aynı mesaj tekrar gelse bile iş etkisini bir kez oluşturan consumer.

İşlenmiş message id'lerini saklayarak tekrarları engeller.

Database değişikliği ve yayınlanacak olayı aynı transaction'da outbox tablosuna yazma deseni.

Outbox tablosundaki olayları broker'a güvenli biçimde yayınlayan süreç.

Consumer'ın aldığı mesajları işlenmiş kimliklerle kaydedip duplicate etkisini önlemesi.

Servislerin durum değişikliklerini olay olarak yayınlayıp diğerlerinin tepki vermesi.

Geçmişte gerçekleşmiş ve değiştirilemez anlamlı durum değişikliği.

Bir işlemin yapılmasını isteyen niyet mesajı.

Birden fazla consumer'ın abone olabildiği olay kanalı.

Yayıncının mesajı doğrudan tüketiciyi bilmeden topic'e göndermesi.

RabbitMQ'da mesajı routing kurallarıyla queue'lara yönlendiren bileşen.

Mesajın hangi queue veya binding'e yönleneceğini belirleyen anahtar.

Routing key'in tam eşleşmesine göre mesaj yönlendirir.

Noktalı wildcard desenlerine göre routing yapar.

Mesajı bağlı tüm queue'lara kopyalar.

Olay payload alanları ve türlerinin sözleşmesi.

Olay şemasını eski consumer'ları bozmadan değiştirme süreci.

Olay sözleşmesinin sürüm bilgisi.

Yeni producer olayının eski consumer tarafından işlenebilmesi.

Geçmiş olayları yeniden consumer'lara işleterek durum veya analiz üretme.

Olayla güncellenen servislerin kısa süre farklı durumlarda olabilmesi.

Veriyi daha hızlı erişilen geçici depoda saklama.

Cache, session, lock, queue ve geçici veri için kullanılan bellek tabanlı veri deposu.

Redis veya cache kaydını benzersiz tanımlayan metin.

Cache anahtarının karşılığında saklanan veri.

Redis'in metin, sayı veya binary veri saklayan temel türü.

Tek Redis key altında alan-değer çifti koleksiyonu.

Sıralı string koleksiyonu.

Tekrarsız string değerleri koleksiyonu.

Her elemanı skorla sıralanan tekrarsız koleksiyon.

Cache key'inin otomatik silinmesine kalan süre.

Key'in belirli süre veya tarihte geçersiz olması.

İstenen verinin cache'de bulunması.

İstenen verinin cache'de bulunmaması.

Toplam cache istekleri içinde hit oranı.

Uygulamanın cache'i kendisinin okuduğu ve doldurduğu desen.

Kaynak veri değiştiğinde eski cache değerini silme veya yenileme.

tenant:123:product:5 gibi anahtarları anlamlı prefix'lerle gruplama.

Popüler key sona erince çok sayıda request'in aynı anda kaynağa gitmesi.

Cache doldurma sırasında tek worker'ın kaynağa erişmesini sağlayan kilit.

Birden fazla süreç arasında tekil iş yürütmeyi koordinasyonla sağlayan kilit.

Birden fazla Redis node üzerinde dağıtık kilit algoritması.

Redis'te mesajların yalnızca o anda bağlı abonelere yayınlandığı geçici sistem.

Web session kayıtlarının Redis gibi ortak depoda tutulması.

Kullanıcı/IP istek sayısını süre penceresinde Redis ile sayma.

Sabit zaman aralıklarında istek sayısını sınırlayan algoritma.

Mevcut zamandan geriye kayan aralıkta istekleri sayan algoritma.

Belirli hızda dolan token'larla burst trafiğe kontrollü izin veren algoritma.

Dağıtık worker'lardan birini koordinasyon görevi için lider seçme.

Kullanıcıya veri değişikliklerini sayfa yenilemeden kısa gecikmeyle iletme.

İstemci ve sunucu arasında sürekli çift yönlü bağlantı.

HTTP upgrade isteğiyle WebSocket bağlantısına geçiş.

Açık istemci-sunucu iletişim oturumu.

Aktif gerçek zamanlı bağlantının benzersiz kimliği.

Belirli kullanıcı veya konu bağlantılarını mesaj grubu altında toplar.

Gerçek zamanlı mesajların konu veya erişim bazında ayrıldığı kanal.

Kullanıcının çevrim içi, aktif veya yazıyor durumunu takip etme.

Karşı kullanıcının mesaj yazdığını kısa süre gösteren olay.

Mesajın görüldüğünü veya okunduğunu bildiren kayıt.

Kullanıcının aktif bağlantısının olup olmadığını gösteren durum.

Bağlantının canlı olduğunu periyodik ping/pong mesajlarıyla doğrulama.

Bağlantı koptuğunda istemcinin yeniden bağlanması.

Tekrar bağlantı denemeleri arasında artan bekleme.

Mesajların doğru sırada gösterilmesi için sıra numarası.

Bağlantı kesildiğinde kaçırılan olayları son offset veya zamanla tekrar alma.

Sunucudan tarayıcıya tek yönlü olay akışı sağlayan HTTP tabanlı teknoloji.

Sunucunun yeni veri oluşana kadar HTTP isteğini açık tuttuğu iletişim tekniği.

İstemcinin belirli aralıklarla yeni veri olup olmadığını sorması.

Uygulama kapalıyken işletim sistemi veya tarayıcı üzerinden bildirim gönderme.

Service worker ve push subscription ile tarayıcı bildirimi gönderme.