OctopusMQ

Distribuovaná fronta zpráv a key-value úložiště

#messaging #distribuovaný #kubernetes

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.

Hlavní vlastnosti

Hlavní vlastnosti
  • Prioritní fronta zpráv - Až 32 konfigurovatelných úrovní priority pro jemné řízení pořadí doručování, takže urgentní práce je vždy zpracována přednostně.
  • 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í související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í.
  • TTL všude - Automatické vypršení platnosti zpráv ve frontě i uložených hodnot udržuje data aktuální a samočisticí, bez ruční údržby.
  • Provozní řízení - Vytváření, změna velikosti, pozastavení a obnovení front i úprava členství v clusteru bez výpadku.
  • Správa z příkazové řádky - Samostatný nástroj příkazové řádky obsluhuje fronty i key-value úložiště, kontroluje stav a provádí datové operace napříč více prostředími, s TLS pro každý kontext — k dispozici pro Linux, macOS i Windows.
  • Bezpečné již z principu - Klientská spojení zabezpečená TLS a kontejnery se zvýšeným zabezpečením, které běží pod neprivilegovaným uživatelem se souborovým systémem jen pro čtení a minimem oprávnění a jsou dodávány se soupisem komponent (SBOM) pro transparentnost dodavatelského řetězce.
  • Vestavěný monitoring - Nativní metriky Prometheus a trasování OpenTelemetry spolu s Kubernetes sondami liveness, readiness a startup pro snadné začlenění do moderních monitorovacích systémů.

Proč OctopusMQ?

Proč OctopusMQ?

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í. Ve spojení s nástrojem příkazové řádky, vestavěným monitoringem a kontejnery se zvýšeným zabezpečením se OctopusMQ snadno provozuje a sleduje i v produkčním nasazení.