JAVA - simpel client/server applicatie

[T.I.M]

Ik ben bezig met het maken van een applicatie die zowel server als client is.
Het client gedeelte werkt allemaal goed. Nu ben ik bezig om het server gedeelte te implementeren.

De methode serviceSocket.accept(); is blocking: hij wacht op een client die verbinding wilt maken met deze server en dan gaat hij verder.

Omdat mijn applicatie meer is dan alleen een server loopt mijn applicatie vast. Ik kan niets meer doen in mijn applicatie omdat hij oneindig lang wacht op een client.

Oftewel hoe zorg ik ervoor dat er wel continu geluisterd wordt naar clients maar dat er ook nog processor tijd over is om andere dingen te doen?

code:

 clientSocket = serviceSocket.accept();                                      // Create a socket object from the ServerSocket
            serviceInputStream = new DataInputStream(clientSocket.getInputStream());    // to listen and accept connections
            serviceOutputStream = new DataOutputStream(clientSocket.getOutputStream());

Als ik de code in een thread zet... en ga slapen (bijv. 200ms) dan werkt het programma.
Alleen mis ik clients die in de slaaptijd verbinding willen maken.... Hierdoor mis ik cruciale berichten.

[ Voor 9% gewijzigd door T.I.M op 19-11-2007 16:09 ]

[Janoz]

Threads

[Swaptor]

Threads zijn jouw vrienden.

[TeeDee]

Als ik het nu zo schets:

code:

- Client gedeelte
- Server Applicatie
      - Server Thread
      - Server Interface (met bijv. een 'Start Server', 'Stop Server' knop)

Edit: blegh... zijn ze me weer voor

[ Voor 12% gewijzigd door TeeDee op 19-11-2007 16:09 ]

[T.I.M]

Swaptor schreef op maandag 19 november 2007 @ 16:07:
Threads zijn jouw vrienden.

Als ik de code in een thread zet... en ga slapen (bijv. 200ms) dan werkt het programma.
Alleen mis ik clients die in de slaaptijd verbinding willen maken.... Hierdoor mis ik cruciale berichten.

[voodooless]

Niet alleen voor de accept() zul je een thread moeten maken, maar doorgaans ook voor iedere client.

Het kan trouwens ook gewoon zonder, maar dan moet je gebruik maken van non-blocking io, dat kan handig met bijvoorbeeld een lib als xscocket.

[T.I.M]

voodooless schreef op maandag 19 november 2007 @ 16:09:
Niet alleen voor de accept() zul je een thread moeten maken, maar doorgaans ook voor iedere client.

Het kan trouwens ook gewoon zonder, maar dan moet je gebruik maken van non-blocking io, dat kan handig met bijvoorbeeld een lib als xscocket.

Er maakt maar 1 client per tijdseenheid verbinding met de server. De server die ik maak hoeft dus maar 1 client tegelijk af te kunnen handelen.

[qless]

Server klasse (extends Thread)

code:

    public void run() {
        run = true;
        while (run) {
            try {
                new ServerThread(serverSocket.accept()).start();
                Thread.sleep(sleep);
            } catch (Exception e) {
            }
        }
    } //run

ServerThread is dan per client de Thread die het werkt doet.

[TeeDee]

Dat maakt dan toch niet uit?
Of je voor 1 client nu een nieuwe thread maakt of voor 200 clients. Die nieuwe thread zal je over het algemeen moeten maken.

[voodooless]

T.I.M schreef op maandag 19 november 2007 @ 16:09:
Als ik de code in een thread zet... en ga slapen (bijv. 200ms) dan werkt het programma.
Alleen mis ik clients die in de slaaptijd verbinding willen maken.... Hierdoor mis ik cruciale berichten.

Waarom werkt 't alleen als je slaapt En waarom zou je willen slapen

[Alarmnummer]

qless schreef op maandag 19 november 2007 @ 16:18:
Server klasse (extends Thread)

code:

    public void run() {
        run = true;
        while (run) {
            try {
                new ServerThread(serverSocket.accept()).start();
                Thread.sleep(sleep);
            } catch (Exception e) {
            }
        }
    } //run

ServerThread is dan per client de Thread die het werkt doet.

Zou je de declaratie van die run boolean eens kunnen laten zien?

[Gerco]

T.I.M schreef op maandag 19 november 2007 @ 16:09:
Als ik de code in een thread zet... en ga slapen (bijv. 200ms) dan werkt het programma.
Alleen mis ik clients die in de slaaptijd verbinding willen maken....

Aangezien accept() blocking is, hoef je helemaal niet te slapen. Als dat weglaat, zal het ws prima werken.

[ Voor 4% gewijzigd door Gerco op 20-11-2007 08:57 ]

[CyBeR]

T.I.M schreef op maandag 19 november 2007 @ 16:09:
[...]


Als ik de code in een thread zet... en ga slapen (bijv. 200ms) dan werkt het programma.
Alleen mis ik clients die in de slaaptijd verbinding willen maken.... Hierdoor mis ik cruciale berichten.

Je moet in je tweede thread ook niet slapen maar die blocking call aanroepen.

[Confusion]

T.I.M schreef op maandag 19 november 2007 @ 16:12:
Er maakt maar 1 client per tijdseenheid verbinding met de server. De server die ik maak hoeft dus maar 1 client tegelijk af te kunnen handelen.

Dat is misschien nu zo, maar blijft dat altijd zo? Ik zou de verbinding door een aparte thread laten afhandelen als ik jou was, dan ben je voorbereid op de toekomst. Met bijvoorbeeld een ThreadPoolExecutor is dat ook een fluitje van een cent. Dan begin je met een Executors.singleThreadPoolExecutor (of hoe dat ding ook exact mag heten; ben te lui om het op te zoeken) en kan je die altijd vervangen door eentje met meerdere threads.

[voodooless]

Iets zegt me dat de Thread is gestart met run() i.p.v start() ...

[T.I.M]

Bedankt voor alle reacties.

Ik dacht dat ik in een thread moest gaan slapen (als de thread niets meer te doen heeft) om zo andere threads de ruimte te geven om ook processertijd te kunnen krijgen.
Blijkbaar is dit in JAVA onderwater al goed geregeld.

Nu heb ik de server kant van de applicatie in een aparte thread gezet. En werkt de applicatie.
en in de run functie ga ik luisteren naar clients.

code:

public class Service implements Runnable {

public void run () { // code die uitgevoerd wordt als de thread gestart is....... }

public void main() {
(new Thread(new Service())).start();
}

Nu nog even mijn applicatie uitbreiden zodat ik data verkregen in deze thread kan communiceren naar de rest van het programma... in iedergeval allemaal erg bedankt