Bir grup, aynı mantığı paylaşarak belirli bir mesaj türünü işleyen üretici veya tüketici örneklerini tanımlar. ApsaraMQ for RocketMQ kullanarak mesaj üretmeden veya tüketmeden önce, grupları ApsaraMQ for RocketMQ konsolunda oluşturmanız gerekir.
Sınırlamalar
Her örnek için en fazla 1.000 grup oluşturabilirsiniz. Kota sınırları içinde kalmak için kullanılmayan grupları yeniden kullanın veya silin. Bu kotayı artırmak için ApsaraMQ for RocketMQ teknik destek ekibiyle iletişime geçin.
Bir grup, farklı örnekler arasında kullanılamaz.
-
ApsaraMQ for RocketMQ mesaj tüketimi için HTTP ve TCP protokollerini destekler. Farklı gruplar farklı protokoller kullanabilir ancak aynı gruptaki tüm tüketicilerin aynı protokolü kullanması gerekir.
Bir grup içinde karışık protokollerin kullanılması tüketim hatalarına, mesajların yinelenmesine veya mesaj kaybına neden olabilir.
Bir grubun protokol değişikliğinin etkili olması yaklaşık 1 ila 2 saat sürer.
Gerçek protokol, konsolda görüntülenenden farklıysa konsol verileri yanlış olabilir ancak mesajlaşma işlevselliği etkilenmez. Görüntülenen protokolü güncellemek için ApsaraMQ for RocketMQ teknik destek ekibiyle iletişime geçin.
Her tüketici için bir grup kimliği gereklidir; üreticiler için ise isteğe bağlıdır.
Grup kimlikleri için adlandırma kuralları
Bir grup kimliği 2 ila 64 karakter uzunluğunda olmalı ve harf, rakam, tire (-) ve alt çizgi (_) içerebilir. Önerilen ön ek: GID_ veya GID-.
Örneğin bir ad alanı varsa grup kimliği o örnek içinde benzersiz olmalı ve mevcut herhangi bir grup kimliği veya konu adıyla aynı olmamalıdır. Farklı örneklerdeki grup kimlikleri aynı olabilir.
Örneğin bir ad alanı yoksa grup kimliği Alibaba Cloud hesabınızdaki tüm örnekler ve bölgeler genelinde benzersiz olmalıdır. Mevcut herhangi bir grup kimliği veya konu adıyla aynı olmamalıdır.
Bir örneğin ad alanına sahip olup olmadığını kontrol etmek için Message Queue for Apache RocketMQ konsolundaki Instance Details sayfasına gidin ve Basic Information bölümünü görüntüleyin.
Tüketici grubu oluşturun
ApsaraMQ for RocketMQ konsoluna giriş yapın. Sol gezinme bölmesinde Instances seçeneğine tıklayın.
Üst gezinme çubuğunda China (Hangzhou) gibi bir bölge seçin. Örnekler sayfasında yönetmek istediğiniz örneğin adına tıklayın.
Sol gezinme bölmesinde Groups seçeneğine tıklayın.
-
Groups sayfasında istemci SDK'nız için bir protokol seçin ve Create Group seçeneğine tıklayın.
ApsaraMQ for RocketMQ istemci SDK'ları için TCP ve HTTP protokollerini destekler.
Açılan panelde Group ID ve Description alanlarını ayarlayın ve ardından OK seçeneğine tıklayın.
Bir grubu silin
Bir grubu sildikten sonra bu grup kimliğiyle tanımlanan tüketici örnekleri mesaj almaz. Grup kaynakları kalıcı olarak silinir ve geri yüklenemez.
Instances sayfasında yönetmek istediğiniz örneğin adına tıklayın. Açılan sayfanın sol gezinme bölmesinde Groups seçeneğine tıklayın.
Grup listesinde yönetmek istediğiniz grubu bulun, Actions sütunundaki More seçeneğine tıklayın ve açılır listeden Delete seçeneğini belirleyin.
Görüntülenen ileti kutusunda OK seçeneğine tıklayın.
Bir grubun ayrıntılarını görüntüleyin
Instances sayfasında yönetmek istediğiniz örneğin adına tıklayın. Açılan sayfanın sol gezinme bölmesinde Groups seçeneğine tıklayın.
Grup listesinde hedef grubu bulun ve Grup Ayrıntıları sayfasını açmak için kimliğine veya Actions sütunundaki Details seçeneğine tıklayın.
Diğer işlemler
Groups sayfasında aşağıdaki işlemleri de gerçekleştirebilirsiniz:
Sol gezinme bölmesinde Groups seçeneğine tıklayın.
Grup listesinde yönetmek istediğiniz grubu bulun, Actions sütunundaki More seçeneğine tıklayın ve açılır listeden aşağıdaki işlemlerden birini seçin:
Quick Access: Birden çok programlama dili için ApsaraMQ for RocketMQ SDK başvurularını görüntüleyin.
Reset Consumer Offset: Tüketici ofsetini sıfırlayarak birikmiş veya istenmeyen mesajları atlayın ve yeni bir ofsetten tüketmeye başlayın. Daha önceki mesajların tüketilip tüketilmediğine bakılmaksızın belirli bir zaman noktasından itibaren mesajları da tüketebilirsiniz. Daha fazla bilgi için bkz. Tüketici ofsetlerini sıfırlama.
Cloud Monitor: Grubun üretim ve tüketim izleme verilerini görüntüleyin.
Dashboard: Grubun tüketim ölçümlerini görüntüleyin.
Başvurular
Ayrıca şu API işlemlerini çağırarak grupları yönetebilirsiniz:
OnsGroupCreate: Bir grup oluşturur.
OnsGroupDelete: Bir grubu siler.
OnsGroupList: Bir örnekteki tüm grupları sorgular.
OnsGroupSubDetail: Bir grubun abone olduğu konuları sorgular.
OnsGroupConsumerUpdate: Bir grup için okuma ve yazma izinlerini yapılandırır.