Ako realizovať prácu s sieťou bez použitia Netty, pričom zachováme reaktívny model spracovania dát?

Na implementáciu sieťovej interakcie s reaktívnym modelom, vynechávajúc Netty, je možné použiť iné reaktívne knižnice a rámce, napríklad:

• Project Reactor s použitím TcpClient a TcpServer z reactor-netty (ak úplne vylúčime Netty, môžu sa použiť iné reaktívne knižnice).
• RxJava spolu s Java NIO (Non-blocking IO) na asynchrónne spracovanie sieťových udalostí.
• Vert.x — reaktívny rámec, ktorý môže fungovať na rôznych transportoch, vrátane TCP/HTTP, a podporuje reaktívne prúdy.

Príklad s použitím Java NIO a RxJava (zjednodušený):

// Používame Selector z NIO pre neblokujúce IO
// a RxJava pre reaktívne spracovanie udalostí

// Pseudokód demonštrujúci myšlienku:
Selector selector = Selector.open();
// Registrujeme kanály a spracovávame udalosti v reaktívnom prúde
Observable<Event> networkEvents = Observable.create(emitter -> {
    while (!emitter.isDisposed()) {
        selector.select();
        Set<SelectionKey> keys = selector.selectedKeys();
        for (SelectionKey key : keys) {
            // spracovanie udalostí
            emitter.onNext(new Event(key));
        }
        keys.clear();
    }
});

networkEvents.subscribe(event -> {
    // reaktívne spracovanie udalostí
});

Týmto spôsobom je možné vytvoriť reaktívny systém spracovania sieťových dát bez priameho použitia Netty, s využitím Java NIO a reaktívnych knižníc.