Dead Letter Queue Stratejileri: Dayanıklı Olay-Güdümlü Sistemler için Production-Ready Kalıplar

class DayanıklıMesajİşlemcisi {
  async backoffIleİşle(mesaj: Message, maxRetry = 5) {
    let retryCount = 0;
    let sonHata;

    while (retryCount < maxRetry) {
      try {
        return await this.işle(mesaj);
      } catch (hata) {
        sonHata = hata;
        retryCount++;

        // Thundering herd'i önlemek için jitter ekle
        const temelGecikme = Math.pow(2, retryCount - 1) * 1000;
        const jitter = Math.random() * 1000;
        const gecikme = temelGecikme + jitter;

        await this.bekle(gecikme);

        // Retry bağlamıyla mesajı zenginleştir
        mesaj.metadata = {
          ...mesaj.metadata,
          retryCount,
          sonHata: hata.message,
          retryZamani: new Date().toISOString(),
          backoffGecikme: gecikme
        };
      }
    }

    // Max retry aşıldı - tam bağlamla DLQ'ya gönder
    await this.dlqyaGonder(mesaj, sonHata, retryCount);
  }
}

class CircuitBreakerDLQ {
  private hatalar = new Map<string, { sayı: number, sonHata: Date }>();
  private devreState: 'KAPALI' | 'AÇIK' | 'YARIM_AÇIK' = 'KAPALI';

  async mesajIşle(mesaj: Message) {
    const servisKey = this.servisKeyiÇıkar(mesaj);

    if (this.devreAçıkMı(servisKey)) {
      // Deneme bile yapma - direkt DLQ'ya circuit breaker sebebiyle
      return this.dlqyaGonder(mesaj, new Error('Circuit breaker açık'), {
        devreState: this.devreState,
        hataCount: this.hatalar.get(servisKey)?.sayı || 0
      });
    }

    try {
      const sonuç = await this.timeoutIleİşle(mesaj, 30000);
      this.başarıKaydet(servisKey);
      return sonuç;
    } catch (hata) {
      this.hataKaydet(servisKey);

      if (this.devreAçılmalıMı(servisKey)) {
        this.devreAç(servisKey);
      }

      throw hata; // Normal retry mantığının halletmesine bırak
    }
  }
}

class DLQMonitoring {
  private metrikler = {
    // Temel metrikler
    dlqDerinlik: new Gauge('dlq_depth'),
    dlqOran: new Counter('dlq_messages_total'),

    // Gelişmiş metrikler
    dlqMesajYaş: new Histogram('dlq_message_age_seconds'),
    hataKalıpları: new Counter('dlq_error_patterns', ['error_type', 'message_type']),
    retryBaşarıOranı: new Gauge('dlq_retry_success_rate'),

    // Business metrikler
    gelirEtkisi: new Gauge('dlq_revenue_impact_dollars'),
    müşteriEtkisi: new Counter('dlq_customer_impact', ['severity'])
  };
}

class MLDLQRecovery {
  async analizeEtveKurtar() {
    const dlqMesajları = await this.dlqMesajlarınıGetir();

    // Hata kalıplarına göre grupla
    const hataGrupları = this.hataKalıplarınaGöreGrupla(dlqMesajları);

    for (const [kalıp, mesajlar] of hataGrupları.entries()) {
      // Bilinen bir düzeltmemiz var mı kontrol et
      const düzeltme = await this.mlModel.düzeltmeTahminEt(kalıp);

      if (düzeltme.confidence > 0.8) {
        await this.otomatikDüzeltmeUygula(mesajlar, düzeltme);
      } else {
        await this.jiraTicketOluştur(kalıp, mesajlar, düzeltme);
      }
    }
  }
}