OctopusMQ

OctopusMQ je distribuovaná fronta zpráv a key-value úložiště navržené pro kritické systémy vyžadující maximální dostupnost, silnou konzistenci a předvídatelný výkon. Díky konsenzuálnímu replikačnímu protokolu zajišťuje, že žádná zpráva není ztracena — ani při výpadku uzlů nebo rozdělení sítě.

Kombinací fronty zpráv a úložiště v jednom systému snižuje OctopusMQ složitost infrastruktury a zároveň poskytuje spolehlivost a propustnost potřebnou pro rozsáhlé real-time úlohy, jako je správa chytrých sítí, orchestrace IoT zařízení a průmyslové zpracování dat.

• Prioritní fronta zpráv - Až 32 úrovní priority s vestavěnou prevencí hladovění, která zajišťuje, že zprávy s nižší prioritou budou nakonec doručeny i při vysoké zátěži
• Seskupování zpráv podle klíče - Související zprávy jsou automaticky doručeny společně stejnému konzumentovi, čímž je zaručeno uspořádané zpracování korelovaných workflow, jako jsou sekvence příkazů pro zařízení
• Distribuované key-value úložiště - Plně replikované key-value úložiště s podporou TTL a exkluzivním zamykáním klíčů, sdílející stejnou spolehlivou infrastrukturu jako fronta zpráv
• Doručení alespoň jednou - Zprávy odebrané konzumentem jsou automaticky vráceny do fronty, pokud se konzument odpojí bez potvrzení, čímž je zabráněno ztrátě zpráv bez nutnosti manuálního zásahu
• Deduplikace unikátních klíčů - Zajišťuje, že ve frontě existuje pouze nejnovější zpráva s daným identifikátorem, ideální pro vzory aktualizace stavu, kde záleží pouze na nejnovější hodnotě
• Maximální dostupnost - Konsenzuální replikace napříč více uzly zajišťuje nepřetržitý provoz a automatickou volbu lídra při výpadcích
• Nativní pro Kubernetes - Plná integrace s Kubernetes StatefulSety pro automatickou správu členství v clusteru, směrování s ohledem na lídra a plynulé škálování
• Dávkové operace - Optimalizované dávkové operace pro vkládání a odebírání zpráv ve scénářích s vysokou propustností

OctopusMQ kombinuje funkčnost fronty zpráv a key-value úložiště do jednoho systému s garantovanou dostupností. Jeho unikátní schopnost seskupování podle klíčů jej činí obzvláště vhodným pro scénáře, kdy musí být související zprávy zpracovány společně stejným konzumentem — vzor běžný při správě zařízení, orchestraci úloh a distribuovaném zpracování. Nativní nasazení v Kubernetes zajišťuje bezproblémový provoz v moderních cloudových prostředích s minimální provozní režií.