Bir ephemeral abone ekleyin, bu yüzden birden fazla pod bir sohbete hizmet edebilir

Featurekamo-shared-library
Shiked
4 Eylül 2026 20:02 UTC
Yazar
Kamo
Commit
6c253b6

Kalıcı bir push tüketici tam olarak ONE abone olduğunu kabul eder. Aynı adı bağlamak için ikinci pod [SUB-Kredi2] ile reddedildi Tüketici zaten bir abonelike bağlıdır ve hiçbir şey yeniden çalışmaz. ChatSessionSubscriptionManager, sohbet seansı GUID'den sonra dayanıklı olarak isim veriyor, bu yüzden iki ile Bir sohbete bağlı olan medya hizmetleri, öncelikle sessiz bir şekilde kendi başına ve her üyeye sahip olacaktır. WebSocket diğer pod'a inen hiçbir şey almamıştı – hiçbir mesaj, okumamak yok, hayır Üye eklemiş olaylar, hata yok. Bu tek mülk, MediaService'nın neden bir tane için kilitlenmiş olduğu çoğaltma ve bunun neden bir rollover yerine toplam bir sohbet. AboneEphemeral() bunun yerine isimsiz bir tüketici yaratır. Kont-pod kimliği çarpıtmak için yok Yukarıda, her pod her mesajı alır ve kendi STOMP müşterilerine hayranlar - hangi şey bu In-heap simple broker gerektirir. FiltreSubject ayarlamak için öğrenilen kalıcı yolu tutar (an) Boş filtre tüm akışı tüketiyor ve SIGKILLed'in SIGKILLed olduğu bir inaktifThreshold ekliyor. Tanımlama olmadan tüketicisini sonsuza dek akışta bırakmaz. Mevcut çağrıcılar için hiçbir davranış değişikliği: abone() istenmiştir ve teslimat döngüsü her ikisi de Yol kullanımı şimdi tek bir yöntemdir, böylece sürüklenmezler. Ephemeral tüketiciler hiçbir şey abone edilmedikçe yayınlanan mesajları yeniden oynatmıyor. Ne yapmadı? dayanıklı olanlar - her ikisi de TeslimatPolicy kullanıyor. Yeni - bu bir regresyon değildir.

Tüm değişiklikler

Kargoyu gördüğünüz gibi?

İş alanınızda bu güncellemelerden her biri otomatik olarak. Ücretsiz başlayın ve haftadan sonra büyümesini izleyin.

Sonsuza Kadar Ücretsiz BaşlangıçFırsatları Görüntüle