TCP server + multi-client – Java – Fórum – Programujte.com

Cau,

plánuju si zkusit udělat TCP server/client, ale narazil jsem na problém, jak vlastně od klienta stále číst

klient se připoji, server mu odesle zpravu a potom potrebuju, aby klient stale byl pripravenej cist od serveru a to sami na strane serveru

v C# to nemám problém udělat, ale tady nějak nevim jak nastavit po připojení aby se stale od klienta četlo, doku rucně neukončim spojení nebo se klient neodpojí

a to vsechny aby probíhalo asynchronně... celkem se mi příčí vytvářet pro každýho klienta vlákno, sice to je jen takovej test, ale pokud by se pripojilo 1000 klientu, tak ten způsob pomoci co klient to vlakno není nejlepší a mám dojem, že by ani JVM nepojmul tolik vláken na app

vyštoural jsem pár novinek z JDK1.7 jako třeba NIO (AsynchronousServerSocketChannel nebo AsynchronousSocketChannel), ale ten problém kterej jsem tady zminoval nevim jak  vyresit :/

EDIT: chci zkusit takovej chat, kde si uzivatele budou moct posilat zpravy, ukaze to seznam pripojenych apod. (pripadne par prikazu jako kick, ban apod....)

muzes mit treba thread poll a predavat jim jen sockety na kterejch se neco stalo

mimochodem na jeden proces je limit socketu 1024 (vcetne stdin/out/err...)

to se lehko řekne :)

ale i ten ThreadPool nevim jak bych do toho zakomponoval

když se mi připojí klient, tak se začne provádět čtení (async) 

                    socketChannel.read(buffer, buffer, new CompletionHandler<Integer, ByteBuffer>() {
                        @Override
                        public void completed(Integer result, ByteBuffer buffer) {
                            buffer.flip();
                            String msgReceived = Charset.defaultCharset().decode(buffer).toString();
                            System.out.println("Msg: " + msgReceived);
                        }

                        @Override
                        public void failed(Throwable exc, ByteBuffer buffer) {
                        }
                    });

mezitim server nasloucha pro dalsiho klienta.. problem je, ze jakmile odeslu neco serveru z klienta, tak se provede funkce completed a tim to cteni konci.. a ja nevim jak od toho klienta cteni nechal stale jakoby zapnuty

idealni by byl nejakej priklad, protoze vytvarek vlakno pro kazdyho klienta nehodlam

verim ze to bude neco trivialniho, ale nemuzu na to prijit :D

#3 ingiraxo
tento kod Ti prisiel pod ruku? http://inetjava.sourceforge.net/lectures/part1_sockets/InetJava-1.9-Chat-Client-Server-Example.html

ne, ale to je to, co nechci - co klient, to vlákno.. hlavně ten kód je skoro 11let starej a ja to spíš chci řešit přes novější nio2, kterej podporuje asyc volání