Jak lze realizovat práci sítě bez použití Netty a přitom zachovat reaktivní model zpracování dat?

Pro implementaci síťové interakce s reaktivním modelem, vynechávající Netty, lze použít jiné reaktivní knihovny a frameworky, například:

• Project Reactor s použitím TcpClient a TcpServer z reactor-netty (pokud úplně vyloučíme Netty, lze použít jiné reaktivní knihovny).
• RxJava spolu s Java NIO (non-blocking IO) pro asynchronní zpracování síťových událostí.
• Vert.x — reaktivní framework, který může pracovat na různých transportních vrstvách, včetně TCP/HTTP, a podporuje reaktivní proudy.

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

// Použití NIO Selector pro non-blokující IO
// a RxJava pro reaktivní zpracování událostí

// Pseudokód demonstrující myšlenku:
Selector selector = Selector.open();
// Registrujeme kanály a zpracováváme události v reaktivním proudu
Observable<Event> networkEvents = Observable.create(emitter -> {
    while (!emitter.isDisposed()) {
        selector.select();
        Set<SelectionKey> keys = selector.selectedKeys();
        for (SelectionKey key : keys) {
            // zpracování událostí
            emitter.onNext(new Event(key));
        }
        keys.clear();
    }
});

networkEvents.subscribe(event -> {
    // reaktivní zpracování událostí
});

Tímto způsobem lze postavit reaktivní zpracování síťových dat bez přímého použití Netty, s využitím Java NIO a reaktivních knihoven.