Kako realizovati rad sa mrežom bez korišćenja Netty-ja, uz očuvanje reaktivnog modela obrade podataka?

Za implementaciju mrežne interakcije sa reaktivnim modelom, izbegavajući Netty, mogu se koristiti druge reaktivne biblioteke i okviri, na primer:

• Project Reactor sa TcpClient i TcpServer iz reactor-netty (ako potpuno isključimo Netty, mogu se koristiti druge reaktivne biblioteke).
• RxJava zajedno sa Java NIO (Non-blocking IO) za asinhrono procesiranje mrežnih događaja.
• Vert.x — reaktivni okvir koji može raditi na različitim transportima, uključujući TCP/HTTP, i podržava reaktivne tokove.

Primer sa korišćenjem Java NIO i RxJava (pojednostavljeno):

// Koristimo Selector od NIO za neblokirajući IO
// i RxJava za reaktivno procesiranje događaja

// Pseudokod koji demonstrira ideju:
Selector selector = Selector.open();
// Registrujemo kanale i obrađujemo događaje u reaktivnom toku
Observable<Event> networkEvents = Observable.create(emitter -> {
    while (!emitter.isDisposed()) {
        selector.select();
        Set<SelectionKey> keys = selector.selectedKeys();
        for (SelectionKey key : keys) {
            // obrada događaja
            emitter.onNext(new Event(key));
        }
        keys.clear();
    }
});

networkEvents.subscribe(event -> {
    // reaktivna obrada događaja
});

Na ovaj način, može se izgraditi reaktivni sistem za obradu mrežnih podataka bez direktnog korišćenja Netty, koristeći Java NIO i reaktivne biblioteke.