[JAVA]pošiljanje sporočil vsem klientom pri non blocking serverju

Najprej rabiš Selector objekt, pri kateremu potem registriraš kanale za pisanje. Ko registriraš kanal pri selektorju, mu lahko prilepiš tudi nek atačment, ki ti služi kot handler, ki ga boš klical kadar preverjaš stanje kanala (ni pa nujno).

Selector selector = Selector.open();
channel.register(selector, SelectionKey.OP_WRITE, handler);

Potem v zanki izvedeš select(), pridobiš ključe ready kanalov in obdelaš tiste ki so readable.

selector.select();
Set<SelectionKey> kljuci = selector.selectedKeys();
Iterator<SelectionKey> iter = kljuci.iterator();

while (iter.hasNext()) {
     SelectionKey kljuc = iter.next();
     iter.remove(); // ključ je treba ročno odstranit iz seta!
     // pregledamo tudi če je ključ še veljaven (lahko se je
     // razveljavil med branjem -> v prim. zaprtja vtičnice)
     if (kljuc.isValid() && kljuc.isWritable()) {
          // tukaj nerediš nekaj s kanalom 
          SelectableChannel kanal = kljuc.channel();
          // oz. z njegovim attachmentom
          Handler h = kljuc.attachment();
     }
}

Tako iteriraš skozi vse kanale, ki si jih prijavil kot writable.

V bistvu rabiš dve niti - ena se ukvarja z izbiranjem ready kanalov in branjem prihajajočih ter pisanjem odhajajočih podatkov, druga te podatke obdeluje in jih postavlja v vrsto za pisanje v socket, ter prvi nalaga updejatnje WRITE statusa kanalov. Vse kliente imaš pa zbrane na nekem seznamu.

Štos pravilnega delovanja pa je da te dve niti komunicirata asinhrono. Recimo ko prva (ki bere in piše v socket) dobi nek paket, ga da v obdelavo tadrugi - ampak tako da doda neko opravilo na seznam opravil. Druga nit periodično pregleduje seznam, obdela zahtevke in ko so podatki pripravljeni, naloži spremembo interesta v OP_WRITE pri prvi niti. Primer takega komuniciranja je recimo EventQueue.invokeLater(new Runnable()), ko v aktivni niti registriraš nek Runnable proces, ki se pa bo začel izvajat v event dispatch niti, ob tebi neznanem času. Metoda invokeLater() ne čaka na začetek izvajanja procesa, ampak ga le prijavi (schedule) in takoj vrne. Seznam opravil mora bit seveda sinhroniziran.

private void invokeLater(Runnable task) {
        
        synchronized(tasks) {
            tasks.add(task);
        }
    }

Podatke vsem klientom pa pošlješ tako da iteriraš skozi vse predmete, ki predstavljajo nek klient (uporaba attachmenta pri registraciji kanala je kot nalašč za to) in vsem nastaviš interest na OP_WRITE. Še eno bistvo pravilnega delovanje je menjavanje interesta - v grobem je tako ko nekaj uspešno zapišeš v socket, menjaš interest na OP_READ, medtem ko OP_WRITE zahtevaš le takrat ko se neki podatki pripravljeni. Tako da kanal večino časa preživi na čakanju za branje. Seznam vseh klientov rabi le nit ki pripravlja podatke, tako da sinhronizacija ni potrebna.

Mnja, upam da je kaj bolj jasno... NIO je rahlo zafrknjen in jst ne ravno blestim v razlaganju...

Z debuggerjem je zelo težko najti napake, ki pridejo do izraza šele pri sočasnem izvajanju več niti. In seveda, sprogramirati pravilno in robustno paralelno izvajanje ni tako trivialno, zato priporočam ogled izvorne kode kakšne knjižnice, ki je preverjena iz strani veliko uporabnikov, npr. apache mina.