ApsaraMQ for RocketMQ:Tüketim Yeniden Denemesi

ApsaraMQ for RocketMQ mesaj onay mekanizmasını ve tüketim yeniden deneme ilkelerini anlamak, aşağıdaki sorunları analiz etmenize yardımcı olabilir:

• Mesaj işlemenin eksiksizliğinin nasıl garanti edileceği: Yeniden deneme ilkesini bilmek, her mesajın tamamen işlendiğini sağlayan, göz ardı edilen mesajları ve tutarsız iş durumlarını önleyen tüketici mantığı tasarlamanıza yardımcı olur.

• Sistem arızaları sırasında mesaj durumunun nasıl kurtarılacağı: Bu, sistem anormallikleri (örneğin çökme) sırasında devam eden mesaj durumlarının nasıl geri yüklendiğini ve durum tutarsızlığı olup olmayacağını netleştirir.

Yeniden Deneme Tetikleyicileri

• Tüketim hatası; buna bir başarısızlık durumu döndürmek veya beklenmeyen bir istisna fırlatmak dahildir.

• Mesaj işleme zaman aşımı; buna PushConsumer'deki kuyruk zaman aşımı dahildir.

Ana Yeniden Deneme Davranışları

• Yeniden deneme durum makinesi: Yeniden deneme sırasında mesaj durumlarını ve geçişlerini kontrol eder.

• Yeniden deneme aralığı: Bir tüketim hatasından (veya zaman aşımından) mesajın yeniden tüketilmeye hazır hale gelmesine kadar geçen süredir.

• Maksimum yeniden deneme sayısı: Bir mesajın yeniden denenebileceği en fazla sayıdır.

Mesaj yeniden deneme ilkesi farkları

Ayrıntılı yeniden deneme ilkeleri için bkz. PushConsumer tüketim yeniden deneme ilkesi ve SimpleConsumer tüketim yeniden deneme ilkesi.

Yeniden Deneme Durum Makinesi

Örnek: Yukarıdaki diyagramda bir mesajın Ready durumunda 5 saniye kaldığını ve işlenmesinin 6 saniye sürdüğünü varsayalım.

Her yeniden deneme döngüsü Ready → Inflight → WaitingRetry sırasını izler. Yeniden deneme aralığı, bir başarısızlıktan (veya zaman aşımından) mesajın tekrar Ready durumuna gelmesine kadar geçen süredir. İki tüketim girişimi arasındaki gerçek süre ayrıca işleme süresini ve Ready süresini de içerir. Örneğin:

• saniyede mesaj Ready durumuna girer.

• Tüketici işleme hızı nedeniyle tüketim 5. saniyede başlar. 6 saniye sonra (11. saniyede) bir istisna oluşur ve istemci başarısızlık döndürür.

• Yeniden deneme hemen başlayamaz; yeniden deneme aralığının beklenmesi gerekir.

• saniyede mesaj tekrar Ready durumuna gelir.

• İstemci 5 saniye sonra yeniden tüketmeye başlar.

Böylece iki tüketim girişimi arasındaki gerçek aralık şudur: işleme süresi + yeniden deneme aralığı + Ready süresi = 21 sn.

Yeniden Deneme Aralıkları

• Sırasız mesajlar (non-ordered messages): Yeniden deneme aralığı aşağıda gösterildiği gibi adımlı zaman yaklaşımını kullanır:

  Yeniden deneme denemesi	Yeniden deneme aralığı	Yeniden deneme denemesi	Yeniden deneme aralığı
  1	10 saniye	9	7 dakika
  2	30 saniye	10	8 dakika
  3	1 dakika	11	9 dakika
  4	2 dakika	12	10 dakika
  5	3 dakika	13	20 dakika
  6	4 dakika	14	30 dakika
  7	5 dakika	15	1 saat
  8	6 dakika	16	2 saat

  Not

  Yeniden deneme denemeleri 16'yı aşarsa sonraki tüm yeniden denemeler 2 saatlik bir aralık kullanır.

• Sıralı mesajlar: Sabit bir yeniden deneme aralığı kullanın. Belirli değerler için bkz. Parametre sınırları.

Maksimum Yeniden Deneme Sayısı

• Varsayılan değer: 16.

• Maksimum: 1.000.

PushConsumer için maksimum yeniden deneme sayısı tüketici grubu meta verileri tarafından kontrol edilir. Değiştirmek için bkz. Maksimum yeniden deneme sayısını değiştirin.

Örneğin maksimum yeniden deneme sayısı 3 ise mesaj en fazla 4 kez iletilir: bir kez orijinal olarak ve üç kez yeniden deneme yoluyla.

Kullanım Örneği

PushConsumer'da yeniden denemeyi tetiklemek için basitçe bir tüketim başarısızlığı durum kodu döndürün. Beklenmeyen istisnalar SDK tarafından otomatik olarak yakalanır.

SimpleConsumer simpleConsumer = null;
        // Consumption example: Use PushConsumer to consume normal messages. Return an error on failure to trigger retry.
        MessageListener messageListener = new MessageListener() {
            @Override
            public ConsumeResult consume(MessageView messageView) {
                System.out.println(messageView);
                // Return FAILURE to trigger automatic retry until the maximum retry count is reached.
                return ConsumeResult.FAILURE;
            }
        };
            

Tüketim Yeniden Deneme Günlüklerini Görüntüleyin

Sıralı mesajlar için PushConsumer yeniden denemeleri istemci tarafında gerçekleştirir. Sunucu ayrıntılı yeniden deneme günlüklerine erişemez. Mesaj izleme sıralı bir mesaj için teslimat başarısızlığını gösteriyorsa maksimum yeniden deneme sayısı ve istemci bilgileri için tüketici istemci günlüklerini kontrol edin.

İstemci günlük yolunu görmek için bkz. Günlük yapılandırması.

Tüketim hatası ayrıntılarını hızlıca bulmak için istemci günlüklerinde şu anahtar sözcükleri arayın:

Message listener raised an exception while consuming messages
Failed to consume fifo message finally, run out of attempt times

Yeniden Deneme Durum Makinesi

PushConsumer'dan farklı olarak SimpleConsumer önceden tahsis edilmiş bir yeniden deneme aralığı kullanır. Bir mesajı getirirken tüketici InvisibleDuration parametresini ayarlar; bu, izin verilen maksimum işleme süresidir. Başarısızlık durumunda sonraki yeniden deneme aralığı ek yapılandırmaya gerek kalmadan bu değeri yeniden kullanır.

InvisibleDuration önceden tahsis edildiğinden gerçek işleme süresinden önemli ölçüde farklı olabilir. Bunu API aracılığıyla değiştirebilirsiniz.

Örneğin başlangıçta işleme süresini 20 ms olarak ayarlarsanız ancak gerçek işleme bunu aşarsa erken yeniden denemeleri önlemek için InvisibleDuration süresini uzatın.

Aşağıda gösterildiği gibi yeni InvisibleDuration değeri hemen etkili olur — görünmezlik zamanlayıcısını API çağrısı anından itibaren yeniden başlatır.

Yeniden Deneme Aralığı

Yeniden deneme aralığı = InvisibleDuration − Gerçek işleme süresi

SimpleConsumer yeniden deneme aralıklarını InvisibleDuration aracılığıyla kontrol eder. Örneğin InvisibleDuration 30 ms ise ve işleme 10 ms sonra başarısız olursa sonraki yeniden deneme 20 ms sonra gerçekleşir. İşleme 30 ms içinde bitmez ve sonuç döndürülmezse mesaj zaman aşımına uğrar ve hemen yeniden denenir (0 ms aralık).

Maksimum Yeniden Deneme Sayısı

• Varsayılan değer: 16.

• Maksimum: 1.000.

SimpleConsumer için maksimum yeniden deneme sayısı oluşturma sırasında tüketici grubu meta verileri tarafından kontrol edilir. Değiştirmek için bkz. Maksimum yeniden deneme sayısını değiştirin.

Örneğin maksimum yeniden deneme sayısı 3 ise mesaj en fazla 4 kez iletilir: bir kez orijinal olarak ve üç kez yeniden deneme yoluyla.

Kullanım Örneği

SimpleConsumer'da yeniden denemeyi tetiklemek için sadece bekleyin.

 // Consumption example: Use SimpleConsumer to consume normal messages. To trigger retry, remain silent and let the message time out. The server will automatically retry.
        List<MessageView> messageViewList = null;
        try {
            messageViewList = simpleConsumer.receive(10, Duration.ofSeconds(30));
            messageViewList.forEach(messageView -> {
                System.out.println(messageView);
                // On failure, ignore the message. It will become visible again and be retried.
            });
        } catch (ClientException e) {
            // If pull fails due to throttling or other system issues, retry the receive request.
            e.printStackTrace();
        }

gRPC SDK

• OpenAPI aracılığıyla değiştirin: Tüketici grubunu güncelleyin

• Konsol aracılığıyla değiştirin:

  Ayara erişmek için:

  1. Instances sayfasında hedef örnek adına tıklayın.

  2. Soldaki gezinme bölmesinde Groups öğesine tıklayın. Groups sayfasında Create Group öğesine tıklayın.

  Create Group iletişim kutusunda Group ID (1–60 karakter), Delivery Order (Concurrent Delivery veya Ordered Delivery) ve Description değerlerini ayarlayın. Gelişmiş Ayarlar'ı genişleterek yeniden deneme ilkesini Exponential Backoff olarak yapılandırın, Maximum Retry Count değerini ayarlayın (varsayılan: 16) ve Retain Dead-letter Messages seçeneğini açın/kapatın (varsayılan: kapalı; kapalıysa yeniden deneme sayısını aşan mesajlar atılır).

Remoting SDK

• Remoting SDK parametresi aracılığıyla değiştirin: Tüketicinin maxReconsumeTimes özelliğini ayarlayın.

Makul Şekilde Yeniden Deneyin — Hız Sınırlaması İçin Yeniden Denemeyi Kullanmayın

Senaryolar bölümünde belirtildiği gibi mesaj yeniden denemesi nadir görülen iş başarısızlıkları için uygundur; hız sınırlaması gibi sistematik veya sürekli başarısızlıklar için değil.

• Yanlış örnek:

  Tüketim hızı hız sınırlamasını tetiklerse başarısızlık döndürün ve yeniden denemeyi bekleyin.

• Doğru örnek:

  Tüketim hızı hız sınırlamasını tetiklerse mesaj getirmeyi geciktirin ve daha sonra tüketin.

Mesaj Tüketimi Zaman Aşımı Nasıl Ayarlanır?

consumer.setConsumeTimeout(15); // Unit: minutes. Range: 1–180 minutes