Bu sözlük, ApsaraMQ for RocketMQ içindeki temel kavramları tanımlar. Terimler işlevlerine göre gruplandırılmıştır: mesajların nasıl yapılandırıldığı, nasıl üretildiği ve tüketildiği ile nasıl yönetilip izlendiği.
Mesajlar
Konu
Konu, mesajlar için birincil sınıflandırıcıdır. Üreticiler mesajları bir konuya gönderir; tüketiciler bu mesajları almak için konuya abone olur. Her konu bir veya daha fazla mesaj kuyruğu (bölüm) içerir.
Konuları yapılandırma konusunda rehberlik için bkz. Konular ve etiketler için en iyi uygulamalar.
Etiket
Etiket, bir konu içindeki mesajları kategorize eden ikincil bir sınıflandırıcıdır. Konu geniş mesaj kategorisini tanımlarken etiketler, tüketicilerin o konudaki belirli mesaj alt kümelerini filtrelemesine olanak tanır.
Etiketleri konularla kullanma konusunda rehberlik için bkz. Konular ve etiketler için en iyi uygulamalar.
Mesaj
Mesaj, ApsaraMQ for RocketMQ'deki temel veri aktarım birimidir. Her mesaj bir konuya aittir ve isteğe bağlı olarak bir etiket taşıyabilir.
Mesaj Kimliği
ApsaraMQ for RocketMQ'nin her mesaja otomatik olarak atadığı genel olarak benzersiz bir tanımlayıcıdır. Bireysel mesajları izlemek ve sorgulamak için mesaj kimliklerini kullanın.
Mesaj anahtarı
Bir mesajı belirli bir iş mantığıyla ilişkilendirmek amacıyla üretici tarafından ayarlanan iş seviyesinde bir tanımlayıcıdır. Mesaj kimliğinin (sistem tarafından oluşturulan) aksine mesaj anahtarı uygulama tarafından tanımlanır ve belirli bir iş operasyonuyla ilgili mesajların bulunmasına yardımcı olur.
Mesaj kuyruğu
Konu bölümü olarak da bilinir. Mesaj kuyruğu, bir konu içindeki fiziksel bir bölümdür. Her konu, konu oluşturulduğunda otomatik olarak atanan bir veya daha fazla kuyruk içerir. Bir konudaki kuyruk sayısı oluşturulduktan sonra değiştirilemez.
Üreticiler
Üretici
ApsaraMQ for RocketMQ'ye mesaj oluşturan ve gönderen bir varlıktır (mesaj yayıncısı olarak da adlandırılır).
Üretici örneği
Bir üretici istemci işlemidir. Farklı üretici örnekleri ayrı işlemlerde veya ayrı makinelerde çalışabilir. Üretici örnekleri iş parçacığı güvenlidir; tek bir örnek aynı işlem içinde birden çok iş parçacığı çalıştırabilir.
Tüketiciler
Tüketici
ApsaraMQ for RocketMQ'den mesaj alan ve işleyen bir varlıktır (mesaj abonesi olarak da adlandırılır). ApsaraMQ for RocketMQ iki tüketici türünü destekler:
| Tüketici türü | Davranış |
|---|---|
| Push tüketici | Aracı, mesajları tüketiciye iter. |
| Pull tüketici | Tüketici, mesajları aracıdan aktif olarak çeker. Bu tüketici türünü yalnızca Java için TCP SDK destekler. |
Pull tüketiciler Enterprise Platinum Edition örneği gerektirir. Ayrıntılar için bkz. Yöntemler ve parametreler ve Mesajlara abone olun.
Tüketici örneği
Bir tüketici istemci işlemidir. Farklı tüketici örnekleri ayrı işlemlerde veya ayrı makinelerde çalışabilir. Her tüketici örneği, mesajları işlemek için bir iş parçacığı havuzu kullanır.
Tüketici ofseti
Tüketici ofseti, bir pull tüketicinin bir bölümde ne kadar ilerlediğini takip eder. Pull tüketiciler bir bölümdeki mesajları sırayla tüketir. Her bölümde aşağıdaki ofset işaretleyicileri bulunur:
MaxOffset: Bölümdeki toplam mesaj sayısı.
MinOffset: Bölümün başlangıç noktası.
ConsumerOffset: Zaten tüketilen mesaj sayısı.
Tüketilmemiş (birikmiş) mesaj sayısı, MaxOffset eksi ConsumerOffset değerine eşittir.
Grup
Üreticilerin veya tüketicilerin mantıksal bir koleksiyonudur. Bir gruptaki tüm istemciler aynı türdeki mesajları üretir veya tüketir ve aynı yayımlama/abone olma mantığını izler.
Grup Kimliği
Bir grup için benzersiz bir tanımlayıcıdır.
Tüketim modları
ApsaraMQ for RocketMQ iki tüketim modunu destekler. Fark, her mesajın bir gruptaki tek bir tüketiciye mi yoksa tüm tüketicilere mi teslim edildiğidir.
| Mod | Teslimat davranışı | Örnek (9 mesaj, 3 tüketici) |
|---|---|---|
| Kümeleme tüketimi | Mesajlar, gruptaki tüketiciler arasında eşit şekilde dağıtılır. Her mesaj tek bir tüketiciye gider. | Her tüketici 3 mesaj işler. |
| Yayınlama tüketimi | Gruptaki her tüketici her mesajı alır. | Her tüketici 9 mesajın tamamını işler. |
Ayrıntılar için bkz. Kümeleme tüketimi ve yayınlama tüketimi.
Mesaj türleri
Zamanlanmış mesaj
Tüketicilere belirli bir zamanda teslim edilen bir mesajdır. Aracı, zamanlanmış teslimat zamanı gelene kadar mesajı tutar.
Ayrıntılar için bkz. Zamanlanmış mesajlar ve gecikmeli mesajlar.
Gecikmeli mesaj
Belirtilen bir gecikme süresinden sonra tüketicilere teslim edilen bir mesajdır. Zamanlanmış mesajın (belirli bir zamanda teslim edilir) aksine gecikmeli mesaj, gönderildikten sonraki göreli bir zaman aralığının ardından teslim edilir.
Ayrıntılar için bkz. Zamanlanmış mesajlar ve gecikmeli mesajlar.
İşlemsel mesaj
Dağıtılmış bir işleme katılan bir mesajdır. ApsaraMQ for RocketMQ, dağıtılmış işlemler arasında nihai tutarlılığı sağlamak için X/Open XA (Genişletilmiş Mimari) benzeri bir dağıtık işlem mekanizması sağlar.
Ayrıntılar için bkz. İşlemsel mesajlar.
Sıralı mesaj
Sıkı ilk giren ilk çıkar (FIFO) düzeninde yayımlanan ve tüketilen bir mesajdır.
Ayrıntılar için bkz. Sıralı mesajlar.
Bölüme göre sıralı mesaj
Tüm konu genelinde değil, belirli bir bölüm içinde sıralanan bir mesajdır. ApsaraMQ for RocketMQ, mesajları bölümlere atamak için bir parçalama anahtarı kullanır. Aynı parçalama anahtarını paylaşan mesajlar kendi bölümleri içinde sıkı FIFO düzeninde yayımlanır ve tüketilir.
Parçalama anahtarı, mesaj anahtarı olarak kullanılamaz.
Ayrıntılar için bkz. Sıralı mesajlar.
İşlemler ve izleme
Mesaj birikimi
Tüketiciler üreticilerin mesaj gönderme hızına yetişemediğinde mesaj birikimi oluşur. Tüketilmemiş mesajlar aracı üzerinde birikir.
Birikmiş mesajlar = Uçuştaki mesajlar + Hazır mesajlar
Uçuştaki mesajlar: Şu anda tüketiciler tarafından işlenen ancak henüz onaylanmamış mesajlar.
Hazır mesajlar: Tüketim için uygun ancak henüz teslim edilmemiş mesajlar.
Mesaj filtreleme
Tüketicilerin yalnızca belirli etiketlerle eşleşen mesajları almasını sağlayan aracı tarafında bir mekanizmadır. Filtreleme aracı üzerinde çalıştığından alakasız mesajlar tüketiciye asla teslim edilmez.
Ayrıntılar için bkz. Mesaj filtreleme.
Mesaj izleme
Bir üreticinin mesajı yayımladığı andan bir tüketicinin onu işlediği ana kadar mesajın yaşam döngüsünün eksiksiz bir kaydıdır. Her iz, tam rota boyunca zaman damgaları ve konumları içerir: üretici, aracı ve tüketici. Teslimat sorunlarını teşhis etmek ve mesaj akışını doğrulamak için mesaj izlerini kullanın.
Ayrıntılar için bkz. Mesaj izlerini sorgulayın.
Tüketici ofsetini sıfırlama
Bir tüketici grubunun tüketim ilerlemesini belirli bir zamana sıfırlar. Sıfırlamadan sonra tüketiciler belirtilen zaman damgasından sonra gönderilen tüm mesajları yeniden okur. Sıfırlama aralığı varsayılan olarak üç gün olan kalıcı depolama penceresiyle sınırlıdır.
Ayrıntılar için bkz. Tüketici ofsetlerini sıfırlayın.
Dead-letter kuyruğu
Başarıyla tüketilemeyen mesajları depolayan özel bir kuyruktur. Bir mesaj tüketilemediğinde ApsaraMQ for RocketMQ teslimatı yeniden dener. Mesaj maksimum yeniden deneme sayısından sonra hala başarısız olursa dead-letter mesaj haline gelir ve atılmak yerine o tüketici grubuyla ilişkili dead-letter kuyruğuna taşınır.
Ayrıntılar için bkz. Dead-letter kuyrukları.