Sıralı mesajlar, kesin ilk giren ilk çıkar (FIFO) modelini izleyerek gönderildikleri sırayla tam olarak aynı düzende tüketilir. İş mantığınızın ardışık işleme dayandığı durumlarda; örneğin finansal menkul kıymetler ve e-ticaret alanlarında sıralı mesajları kullanın.
Temel kavramlar
Sıralı mesajlar, ApsaraMQ for RocketMQ içindeki özel bir mesaj türüdür. Bir konu içinde sıralı mesajlar kesin FIFO sırasına göre yayınlanır ve tüketilir.
Parçalama anahtarı, bir mesajın hangi parçaya yönlendirileceğini belirler. Aynı parçalama anahtarına sahip mesajlar her zaman aynı parçaya gönderilir; bu sayede aralarındaki göreceli sıra korunur.
Parça bazında sıralı mesajlar, bir konunun her bir parçası içinde FIFO sıralaması sağlar. Mesajlar parçalama anahtarına göre parçalara ayrılır ve FIFO sıralaması yalnızca aynı parçalama anahtarını paylaşan mesajlar arasında garanti edilir. Farklı parçalar arasındaki mesajların birbirlerine göre herhangi bir sıralama garantisi yoktur.
Not: Sıralı mesajlar, zamanlanmış mesajlar ve işlemli mesajlar birbirini dışlayan türlerdir. Tek bir mesaj bu türlerden birden fazlasına ait olamaz.
Kullanım senaryoları
Parça bazında sıralı mesajlar, mantıksal gruplamalar arasında değil ancak bu gruplamalar içinde kesin sıralama gerektiren yüksek aktarım hızına sahip sistemlere uygundur.
| Kullanım senaryosu | Parçalama anahtarı | Sıralamanın önemi |
|---|---|---|
| E-ticaret siparişleri | Sipariş ID'si | Aynı siparişe ait oluşturma, ödeme ve iade olaylarının tutarlı sipariş durumunu korumak için ardışık olarak işlenmesi gerekir. |
| Kullanıcı doğrulama | Kullanıcı ID'si | Aynı kullanıcıya ait doğrulama kodu mesajlarının istenen sırayla ulaşması gerekir. |
Alibaba Group bünyesindeki tüm dahili e-ticaret sistemleri, çevrimiçi siparişlerin kararlı performansla ve ardışık olarak işlenmesi için parça bazında sıralı mesajları kullanır.
Çalışma mekanizması
ApsaraMQ for RocketMQ, yayınlama, depolama ve tüketim olmak üzere üç aşamada FIFO sıralamasını zorunlu kılar.
Mesaj yayınlama
Yukarıdaki diyagramda A ve B Siparişlerine ait mesajlar şu sırayla üretilir: A1, B1, A2, A3, B2, B3. Her bir siparişin mesajları, üretildikleri göreceli sırayla aynı düzende tüketilmelidir: önce A1 sonra A2 sonra A3 ve önce B1 sonra B2 sonra B3.
Normal (sırasız) mesajlarda broker mesajları kuyruklara döngüsel (round-robin) şekilde dağıtır; bu yaklaşım sıralamayı korumaz. Sıralı mesajlarda ise broker aynı parçalama anahtarına (örneğin aynı sipariş ID'sine) sahip tüm mesajları aynı kuyruğa yönlendirerek sıralarını korur.
Sıralama göndericiye bağlıdır. Broker, mesaj sırasını tek bir üretici veya iş parçacığının gönderme sırasına göre belirler. Birden çok üretici veya iş parçacığı eş zamanlı olarak mesaj gönderirse broker mesajları varış zamanına göre sıralar; bu sıra, amaçlanan iş sırasından farklı olabilir.
Mesaj depolama
Sıralı mesaj konusundaki her bir mantıksal kuyruk tam olarak bir fiziksel kuyruğa eşlenir. Mesajlar mantıksal kuyruğa sıralı şekilde gelir ve aynı sırada karşılık gelen fiziksel kuyruğa kalıcı olarak kaydedilir.
Mesaj tüketimi
Broker, mesajları tüketicilere depolandıkları sırayla iletir. Aynı parçalama anahtarını paylaşan mesajlar tek bir iş parçacığı tarafından tüketilir; bu sayede tüketim sırası hem depolama sırasına hem de orijinal yayınlama sırasına uyar.
Kullanım notları
Bir grup, bir mesaj türü. Her grup tek bir konu türüne bağlıdır. Aynı grubu kullanarak hem sıralı hem de sırasız mesaj göndermek veya almak için kullanmayın.
Tek üreticili sıralama. Broker, sıralamayı tek bir üreticinin veya iş parçacığının mesajları gönderme sırasına göre korur. Birden çok üretici veya iş parçacığı eş zamanlı gönderim yaparsa broker varış zamanına göre sıralama yapar; bu sıra iş tarafındaki sıradan farklı olabilir. Üreticiler arasında kesin sıralamayı garanti etmek için aynı iş sırasındaki tüm mesajları tek bir üretici örneği üzerinden yönlendirin.
Yalnızca eşzamanlı gönderim. Sıralı mesajlar güvenilir eşzamanlı iletim gerektirir. Eşzamansız iletim desteklenmez çünkü eşzamansız gönderimler teslimat sırasını garanti edemez.
Yalnızca kümeleme tüketimi. Sıralı mesajlar kümeleme tüketimini destekler ancak yayınlama tüketimini desteklemez.
SSS
Bir mesaj aynı anda sıralı mesaj, zamanlanmış mesaj ve işlemli mesaj olabilir mi?
Hayır. Sıralı, zamanlanmış ve işlemli mesajlar birbirini dışlayan türlerdir.
Hangi bölgeler sıralı mesajları destekler?
Sıralı mesajlar, ApsaraMQ for RocketMQ'nun dağıtıldığı tüm Alibaba Cloud bölgelerinde ve Finans Bulutu bölgelerinde kullanılabilir.
Sıralı mesajlar hangi iletim modlarını destekler?
Yalnızca güvenilir eşzamanlı iletim. Kesin sıralamayı garanti edemediği için eşzamansız iletim desteklenmez.
Sıralı mesajlar yayınlama tüketimini destekler mi?
Hayır. Sıralı mesajlar yalnızca kümeleme tüketimini destekler.