|
Vytvářejte odolné, škálovatelné systémy v TypeScriptu
Node.js je rychlý a flexibilní, ale budování spolehlivých distribuovaných systémů vyžaduje ověřené vzory. noex přináší prověřené koncepty z Erlang/OTP do TypeScriptu, abyste se mohli soustředit na byznys logiku místo infrastruktury.
GenServer, Supervisor, Registry - koncepty, které pohání WhatsApp, Discord a miliony telekomunikačních systémů po celém světě. Nyní dostupné ve vašem TypeScript kódu.
Přijměte filozofii 'nech to spadnout'. Procesy selhávají elegantně a supervisoři je automaticky restartují. Žádné kaskádové selhání, které by položilo celou aplikaci.
Stejný kód, který běží na jednom stroji, škáluje přes celý cluster. Transparentní lokace zpráv znamená, že při škálování nic nepřepisujete.
Vestavěný webový dashboard a terminálové UI vám ukáže přesně, co se děje. Sledujte stavy procesů, propustnost zpráv a chyby v reálném čase bez jakékoli konfigurace.
Podívejte se, jaké problémy noex řeší
Běžné problémy, které zpomalují vývoj a způsobují produkční incidenty
Sdílený měnitelný stav vede k nepředvídatelným chybám
Jedna chyba může shodit celou aplikaci
Distribuované systémy jsou obtížné na správné nastavení
noex tyto problémy řeší
Osvědčené vzory z Erlang/OTP, přepracované pro TypeScript
Stavové procesy bez race conditions. Sekvenční zpracování zpráv garantuje konzistenci.
Automatický restart při selhání. Filozofie 'nech to spadnout' s chytrými strategiemi obnovy.
Vyhledávání procesů podle jména. Najděte procesy pomocí názvu místo správy referencí.
Abstrakce vyšší úrovně pro běžné konkurenční scénáře
Explicitní konečné automaty s typovanými stavy a přechody. Ideální pro workflows a protokoly.
Jednoduchý kontejner stavu, když potřebujete jen stav, ne celý proces. Funkcionální aktualizace s get/update.
Supervisované asynchronní operace s řízením konkurence. Spouštějte fire-and-forget úlohy nebo čekejte na výsledky.
Kompletní správa životního cyklu pro produkčně připravené aplikace
Konzistentní startup sekvence s health checky. Spouštějte, zastavujte a monitorujte aplikaci pomocí jednotného API.
Automatické zpracování SIGINT/SIGTERM pro Docker a Kubernetes. Vaše procesy se korektně ukončí.
prepStop hooky dají službám čas na dokončení prací. Konfigurovatelné timeouty zabrání zaseknutým shutdownům.
const MyApp = Application.create({
async start(config) {
const supervisor = await Supervisor.start({
strategy: 'one_for_one',
children: [
{ id: 'db', start: () => DatabasePool.start(config.dbUrl) },
{ id: 'api', start: () => ApiServer.start(config.port) }
]
});
return supervisor;
},
async prepStop(supervisor) {
// Stop accepting new requests
},
async stop(supervisor) {
// Final cleanup
}
});
await Application.start(MyApp, {
name: 'my-service',
config: { port: 3000, dbUrl: 'postgres://...' }
});
// Handles SIGINT/SIGTERM automaticallyProdukčně připravené utility, které bezproblémově spolupracují s vašimi procesy
In-memory cache s TTL a automatickým čištěním
Publish/subscribe messaging mezi procesy
Token bucket rate limiting pro API a zdroje
Erlang Term Storage - rychlé in-memory key-value úložiště s pattern matchingem
Monitorujte své procesy v reálném čase bez jakékoli konfigurace
┌─ Process Tree ────────────────┐ ┌─ Stats Table ─────────────────────────────────────┐│ ▼ supervisor:main │ │ ID │ Status │ Msgs │ Mem │ Up ││ ├─ ● counter (running) │ │─────────────────┼─────────┼──────┼────────┼───────││ ├─ ● cache (running) │ │ counter │ running │ 1.2k │ 2.4 MB │ 01:23 ││ ├─ ● rate-limiter (running) │ │ cache │ running │ 847 │ 12 MB │ 01:23 ││ └─ ● event-bus (running) │ │ rate-limiter │ running │ 156 │ 1.1 MB │ 01:23 ││ │ │ event-bus │ running │ 2.1k │ 3.2 MB │ 01:23 │└───────────────────────────────┘ └───────────────────────────────────────────────────┘┌─ Memory ──────────────────────┐ ┌─ Event Log ───────────────────────────────────────┐│ ████████░░░░░ │ │ [12:34:56] ✓ GenServer started: counter ││ 67% / 256MB │ │ [12:34:57] ✓ GenServer started: cache ││ │ │ [12:34:58] ℹ Supervisor: main (4 children) │└───────────────────────────────┘ └───────────────────────────────────────────────────┘ [q]uit [r]efresh [?]help [1-3]layout │ Processes: 4 │ Up: 00:01:23npx @hamicek/noex dashboardWebové rozhraní pro vzdálený monitoring
Interaktivní terminálový dashboard s klávesovou navigací
CPU, paměť a propustnost zpráv v reálném čase
Události s časovými razítky a úrovní závažnosti
Škálujte napříč stroji s transparentní lokací. Vaše procesy fungují stejně na jednom stroji i na stovkách.
Uzly se automaticky objevují pomocí mDNS nebo seed nodů. Žádný centrální koordinátor není potřeba.
Registrujte a vyhledávejte procesy napříč všemi uzly podle jména. Jedno API pro lokální i vzdálené procesy.
Posílejte zprávy procesům bez ohledu na jejich fyzické umístění. Runtime se postará o routování.
// Register a process globally
await GlobalRegistry.register('user:session:123', pid);
// Find it from any node in the cluster
const pid = await GlobalRegistry.whereis('user:session:123');
// Send a message - works across nodes
await GenServer.call(pid, { type: 'get_data' });Stejné API pro lokální i vzdálené procesy
Prozkoumejte reálné příklady a uvidíte noex v akci
import { GenServer, Supervisor, Registry } from class=class="hl-string">"hl-string">'@hamicek/noex';
class Counter extends GenServer {
init() {
return 0;
}
handleCall(msg: { type: class=class="hl-string">"hl-string">'get' }) {
return this.state;
}
handleCast(msg: { type: class=class="hl-string">"hl-string">'increment' } | { type: class=class="hl-string">"hl-string">'decrement' }) {
if (msg.type === class=class="hl-string">"hl-string">'increment') {
this.state++;
} else {
this.state--;
}
}
}
class=class="hl-string">"hl-comment">// Start the counter
const counter = await Counter.start();
class=class="hl-string">"hl-comment">// Interact with it
await counter.cast({ type: class=class="hl-string">"hl-string">'increment' });
await counter.cast({ type: class=class="hl-string">"hl-string">'increment' });
const value = await counter.call({ type: class=class="hl-string">"hl-string">'get' });
console.log(class=class="hl-string">"hl-string">'Counter value:', value); Začněte za pár minut jednoduchou instalací přes npm
$ npm install @hamicek/noex npm install @hamicek/noeximport { GenServer } from '@hamicek/noex'await Counter.start()import { GenServer } from class=class="hl-string">"hl-string">'@hamicek/noex';
class Counter extends GenServer {
init() { return 0; }
handleCast(msg: class=class="hl-string">"hl-string">'inc') {
this.state++;
}
}
const counter = await Counter.start(); Líbí se vám noex? Pomozte nám pokračovat ve vývoji