ApsaraMQ for RocketMQ, kurumsal düzeyde internet mimarisinin çekirdek ürünü olarak profesyonel bir mesaj ara yazılımıdır. Mikroservisler, dağıtık sistemler ve sunucusuz uygulamalar arasında güvenilir mesaj tabanlı eşzamansız iletişimi destekler. Bu hizmet ile gevşek bağlaşımlı ve yüksek kullanılabilirliğe sahip ölçeklenebilir bir dağıtık sistem kolayca oluşturabilirsiniz.
ApsaraMQ for RocketMQ, 11 yılı aşkın süredir Alibaba Group altyapısına entegre olup 9 yıldır Alibaba'nın 11-11 e-ticaret etkinliğine hizmet vermektedir. Düşük gecikme, yüksek eşzamanlılık, yüksek kullanılabilirlik, yüksek güvenilirlik ve güçlü mesaj birikimi yeteneği sunar; trilyon seviyesinde veri akışını destekler. MQ ile uygulama bileşenleri arasında her ölçekte serbestçe veri iletimi sağlayabilirsiniz.
Avantajlar

-
Yüksek Performans ve Düşük Gecikme
Message Queue, 10 milyon seviyesinde Saniyedeki Sorgu Sayısı (QPS) ve trilyon seviyesinde mesaj akışını destekler; eşzamanlılık ve üst performans sınırı yoktur.

-
Yüksek Güvenilirlik
Message Queue, sunucular arası senkron çift yazma, ultra üçlü kopya veri yedekliliği ve hızlı geçiş teknolojisini destekler. Veri güvenilirliği %99,99999999 seviyesine ulaşır.

-
Yüksek Ölçeklenebilirlik
Message Queue, on binlerce mesajı destekler. Kuyruk sayısı elastik olarak ölçeklendirilebilir ve küme ölçeği otomatik olarak ayarlanabilir. Bu süreç kullanıcılara tamamen şeffaftır.

-
İzin Kontrolü
Message Queue, mesaj konusu ve tüketici kimliği ile her mesajın gönderme ve alma izinlerini kontrol ederek mesaj güvenliğini sağlar.
Özellikler
-
Yüksek Performans ve Düşük Gecikme
ApsaraMQ for RocketMQ, devasa mesaj birikimi durumunda bile küme hizmetini etkilemeden yüksek performans sağlar. Bu durum özellikle yük kaydırma (trafik emilimi) sırasında önemlidir.
Alibaba Cloud teknik ekibi, Alibaba'nın yıllık 11-11 e-ticaret etkinliğine yıllarca hizmet vererek edindiği deneyimle, süper yüksek eşzamanlılık nedeniyle sistem yükünden kaynaklanan yanıt süresi jitter sorunlarını çözme yöntemleri geliştirmiştir. 2017 11-11 etkinliğinde trilyon seviyesinde mesaj akışında, mesaj yazma isteklerinin %99,6'sının gecikme süresi 1 ms'nin altında, %99,996'sının gecikme süresi ise 10 ms'nin altında kaydedilmiştir.
Mesaj sunucuya ulaştıktan hemen sonra gönderilir ve bu sayede zamanında mesaj iletimi sağlanır.
-
Yüksek Kullanılabilirlik, Güvenilirlik ve Ölçeklenebilirlik
ApsaraMQ for RocketMQ, dünya genelinde birden fazla bölgede yüksek kullanılabilirlikte mesaj bulut hizmetleri sunar. Sunucu odaları ve donanım tesisleri, Alibaba'nın IDC standartlarına uygun olarak yüksek standartlarda inşa edilmiştir. Her bölgede birden fazla sunucu odası dağıtılmıştır. Tüm bir sunucu hizmet dışı kalsa bile, Message Queue uygulamalara mesajları etkili bir şekilde iletmeye devam edebilir.
ApsaraMQ for RocketMQ, Doğu Çin 1 (Hangzhou), Doğu Çin 2 (Shanghai), Güney Çin 1 (Shenzhen) ve diğer bölgeler dahil birden fazla finansal bölgede şehir içi çoklu aktif dağıtım çözümlerini destekleyerek çekirdek finansal işlem sistemlerini korur.
-
Güvenli Erişim Kontrolü
ApsaraMQ for RocketMQ, ana hesap ve alt hesap oluşturmayı, kara liste ve beyaz liste işlevselliğini ve Alibaba Cloud RAM'in STS işlevlerini destekler.
ApsaraMQ for RocketMQ, hesaplar arası yetkilendirmeyi ve ana hesap ile alt hesaplar aracılığıyla yetkilendirmeyi destekler.
Sıralı mesajlar, serbest bırakılma sırasına göre tüketilir (ilk giren ilk çıkar). Message Queue, mesajların küresel sıralanmasını ve parçalı sıralanmasını destekler.
-
Konu Modeli (Topic)
ApsaraMQ for RocketMQ, Pub/Sub modunu destekler. Bu modda, üretici mesajı belirtilen konuya gönderir. Bir veya birden fazla tüketici mesaja abone olabilir.
ApsaraMQ for RocketMQ, küme tüketimi ve yayın tüketimini destekler. Aynı tüketici kimliğini kullanan aboneler aynı kümeye ait olur. Küme tüketimi modunda, her mesajın kümedeki abonelerden yalnızca biri tarafından işlenmesi yeterlidir. Yayın tüketimi modunda, her mesaj kümedeki tüm abonelere iletilir ve mesajın kümedeki her abone tarafından en az bir kez tüketilmesi sağlanır.
-
Çeşitlendirilmiş Mesaj Türleri
Yaygın mesaj, sistemler arasında eşzamansız iş bağımsızlaştırma, yük kaydırma, günlük kaydı, ana makineler arasında büyük ölçekli önbellek senkronizasyonu ve gerçek zamanlı hesaplama ile analiz için kullanılır.
Sıralı mesajlar hem yayımlanma hem de tüketilme sırasına göre işlenir ve küresel ile parçalı sıralı mesajlar olarak ikiye ayrılır.
ApsaraMQ for RocketMQ, işlem tutarlılığını garanti etmek için X/Open XA olarak bilinen dağıtık işlem işlevi sunar.
Bir mesaj Message Queue sunucusuna gönderildikten sonra, Message Queue sunucusu mesajı mesaj gönderim zamanından (mevcut zaman) sonra belirtilen zaman noktasında (örneğin, 1 Ocak 2016 saat 15:00:00'da) gönderir.
Bir mesaj Message Queue sunucusuna gönderildikten sonra, Message Queue sunucusu mesajı mesaj gönderim zamanından (mevcut zaman) sonra belirtilen gecikme süresi noktasında (örneğin, 30 dakika sonra) gönderir.
-
Sistematik Bakım Araçları
ApsaraMQ for RocketMQ, sistem sorunlarını hızlı bir şekilde tespit etmenize ve çözmenize yardımcı olacak kapsamlı bakım araçları seti sunar.
Message Queue sunucusunda konu, mesaj kimliği veya mesaj anahtarına göre mesaj sorgulayın.
ApsaraMQ for RocketMQ, mesajın üreticiden Message Queue sunucusuna ve ardından son kullanıcıya kadar olan tüm süreçteki mesaj akışı dahil eksiksiz verileri kaydeder, bu verileri toplar ve analiz eder ve görsel tam bağlantı mesaj izi oluşturur.
ApsaraMQ for RocketMQ, tüketilen mesajları belirtilen zamanda yeniden oynatarak güçlü bir sorun giderme aracı olarak çalışır.
Her müşteri kimliği için tüketim gecikme süresi ve mesaj birikim miktarına göre izleme ve uyarı kuralları ayarlayarak sorunları zamanında tespit edebilirsiniz.
ApsaraMQ for RocketMQ, kontrol tipli standart bir HTTP RESTful Open API seti sunarak bir dizi kaynak yönetimi ve bakım işlevini uygulamanın yanı sıra kolay erişim sağlar.
Kullanım Senaryoları
-
Bağımsızlaştırma
-
Yük Kaydırma (Trafik Emilimi)
-
Dağıtık İşlemler
-
Gerçek Zamanlı Hesaplama
-
Büyük Ölçekli Önbellek Senkronizasyonu
-
Anlık Mesajlaşma
Bağımsızlaştırma
Sistemler arası gevşek bağlaşım, ölçeklenebilirliği ve güvenilirliği artırır ve modern uygulamalar için en iyi tasarım çözümüdür. Message Queue kullanarak, herhangi sayıda uygulama hizmeti bileşeni (sistemi) arasında sıfır mesaj kaybıyla mesaj gönderme, depolama ve alma işlemleri gerçekleştirebilirsiniz. Bu, bulut uygulama bileşenlerinin (sistemlerinin) çalışmasını basitleştirir ve daha yüksek maliyet etkinliği sağlar.
Yük Kaydırma (Trafik Emilimi)
Alibaba'nın Tmall 11-11 e-ticaret festivalinin gece yarısı işlem yoğunluğu, Bahar Bayramı Gala çevrimiçi kırmızı paket dağıtımı ve diğer büyük çevrimiçi etkinlikler gibi kitlesel etkinliklerde, harici istek hacmi sistemin işleme kapasitesini aştığında çok sayıda istek başarısız olabilir. Uygun koruma önlemleri olmadan, biriken istekler zaman aşımına uğrayıp otomatik kurtarılamadığında sistem çöker ve dış hizmetlere yönelik hizmet kapasitesi 0'a düşer. Bu durum kullanıcı deneyimini olumsuz ve önemli ölçüde etkiler.
Dağıtık İşlemler
Geleneksel işlem işleme modunda, birden fazla sistem veya uygulama bileşeni arasındaki iş süreçleri büyük bir işlem altında birleştirilir. Bu durum uzun yanıt sürelerine ve uzun iş bağlantılarına yol açarak sistem kullanılabilirliğini etkiler. Message Queue'nun dağıtık işlem mesajlarını tanıttıktan sonra, senkron işlenmesi gereken çekirdek bağlantı işlerini eşzamansız işlenebilen dal bağlantı işlerinden ayırabilirsiniz. Böylece büyük bir işlemi küçük bir işleme bölerek sistemler arası etkileşimi azaltırsınız.
Bu şekilde dağıtık sistemler arasında veri tutarlılığını sağlayabilir ve iş sistemlerini (alışveriş sepeti, puan ve diğerleri) birbirinden bağımsız hale getirebilirsiniz. Böylece en uygun mimari tasarımı gerçekleştirmiş olursunuz.
Gerçek Zamanlı Hesaplama
Veriler "akış" sırasında değer kazanır. Geleneksel veri analizi çoğunlukla toplu iş hesaplama modeline dayanır ve gerçek zamanlı veri analizi yapamaz. Alibaba Cloud Message Queue'yu başlıca hesaplama motorlarıyla (Spark, Storm, EMR, ARMS ve BeamRunner gibi) birleştirerek kolayca gerçek zamanlı iş verisi analizi yapabilirsiniz.
Büyük Ölçekli Önbellek Senkronizasyonu
Büyük etkinliklerin paralel oturumları veya geniş ölçekli bir istemci uygulaması için, istek yanıt süresini (RT) düşürmek ve kullanıcı deneyimini iyileştirmek amacıyla geniş ölçekli önbellek tasarımı uygulanır. Tmall'ın 11-11 promosyonunda, Shoutao uygulaması, Tmall uygulaması ve çeşitli özel mağazalarda müşterilere çok çeşitli ürünler sunulur ve her ürünün fiyatı promosyon ilerledikçe gerçek zamanlı dalgalanır. Ürün veritabanı sayfasına yapılan yoğun eşzamanlı erişimler uzun yanıt sürelerine neden olur ve merkezi önbellek bant genişliği darboğaz oluşturarak ürün fiyatı erişim taleplerini karşılayamaz hale gelir. Özel mağazalar için çoklu önbellek tasarımı, müşterilerin ürün fiyatına erişimini sağlamak amacıyla Message Queue kullanarak birden fazla önbellek arasında senkronizasyon sağlar.
IM
Alibaba bünyesinde hem TradeManager (anlık ticaret iletişimi uygulaması) hem de DingTalk (ofis iletişimi uygulaması) mesaj hizmetleri için Message Queue kullanır. Birebir sohbetler, grup sohbetleri ve DingTalk bildirimlerinde her etkileşim sırasında çok sayıda mesaj üretilir.
