[Java] Socket of inputstream probleem

[Mfpower]

Ik heb een client en een server geschreven in java. Deze communiceren met elkaar door middel van sockets. Nu is het de bedoeling dat de verbinding een tijd open blijft staan, waarbij de client zo nu en dan info in de vorm van chars of bytes naar de server stuurt.

Nu wil ik dat de server alleen reageert op het moment dat de client data verstuurt. Alleen het probleem is dat ik aan de serverkant continu moet checken of er data verstuurd is door de client. Ik krijg dus een lus (verbinding is inmiddels verkregen):

code:

while (true) {
  var = in.read() ;
  if (var != -1)
     doStuff() ;
}

Het probleem is dat een programma in een infinite lus laten lopen niet getuigd van enige efficientie. Wat ik eigenlijk wil is een of andere event die aangeroepen wordt op het moment dat er weer data in de readbuffer staat. Is zoiets dergelijks mogelijk?

[Robtimus]

Ik weet niet of het bij sockets net zo gaat, maar werkt het volgende niet?

Java:

while((var = in.read()) != -1) {
    doStuff();
}

Ik weet nml niet wat er gebeurt als er niets over de socket gestuurd wordt. Als ie blokkeert op de in.read() totdat er iets beschikbaar wordt gesteld zou het iig moeten werken.

[ Voor 19% gewijzigd door Robtimus op 30-09-2003 14:11 ]

[Mfpower]

IceManX: jouw code lijkt leuk. Maar als er niets geschreven wordt naar de buffer dan levert in.read() -1 op en dan komt ie niet in de while lus. Dat lijkt wel op wat ik wil. Maar ik wil op het moment dat er WEL over de socket geschreven wordt (na een lange tijd van idlen) dat er actie ondernomen wordt...

[.oisyn]

Blocking sockets, en dan een aparte leesthread aanmaken

[pjonk]

Mfpower schreef op 30 September 2003 @ 13:50:
Het probleem is dat een programma in een infinite lus laten lopen niet getuigd van enige efficientie. Wat ik eigenlijk wil is een of andere event die aangeroepen wordt op het moment dat er weer data in de readbuffer staat. Is zoiets dergelijks mogelijk?

Je zou het stukje code in een aparte thread moeten laten uitvoeren dan staat je programma ook niet te blocken.
Je zou bijv. in zo'n thread om een bepaalde interval kunnen gaan controleren of er data in de socket aanwezig is.

[Mfpower]

JonkieXL schreef op 30 September 2003 @ 14:17:
[...]

Je zou het stukje code in een aparte thread moeten laten uitvoeren dan staat je programma ook niet te blocken.
Je zou bijv. in zo'n thread om een bepaalde interval kunnen gaan controleren of er data in de socket aanwezig is.

Dat zou kunnen, maar dat is een verplaatsing van het probleem. In feite heb je dan nog steeds een infinite loop alleen dan met een interval. Daarbij kan ik me voorstellen dat als je niet direct uit begint te lezen een buffer overflow mogelijk is?

Ik kwam er achter dat de methode readline() het wel goed doet. Deze blijft net zo lang "hangen" tot er een lijn te lezen is (als ik met telnet naar m'n server connect en dan op <enter> druk dan reageert m'n server meteen).

Maar goed dat is alleen leuk voor ascii data met newlines... ik had andere plannen

[Mfpower]

.oisyn schreef op 30 September 2003 @ 14:15:
Blocking sockets, en dan een aparte leesthread aanmaken

Dat ken ik niet. Heb je info of een voorbeeld?

[.oisyn]

Socket.setSoTimeout ()

[ Voor 20% gewijzigd door .oisyn op 30-09-2003 14:34 ]

[Verwijderd]

Ik weet niet precies waarom je zo lastig doet maar read() blijft ook gewoon "hangen" tot dat er weer een byte beschikbaar is van de socket inputstream. Je krijgt dus geen loop die 100% cpu time gaat vreten... Sockets "blocken" gewoon totdat er data beschikbaar is.

Wil je een "socket readyness" systeem opzetten, dus dat je geen extra thread nodig hebt die blijft "hangen" tot er nieuwe data beschikbaar is maar dat je door middel van events krijgt te horen over er data is, dan moet je Java NIO gaan doen maar das wel wat lastigere dan het blocking sockets model...

Grtz Dark

[ Voor 5% gewijzigd door Verwijderd op 30-09-2003 15:37 ]

[Mfpower]

Ja probleem ondertussen verholpen. Door een of andere vage setting verbrak ie de verbinding telkens (zonder dat ik het doorhad) dus kreeg ik steeds een -1 in plaats van dat read() bleef hangen. Wat is Java NIO dan? Klinkt ook wel interessant.

[Glimi]

Java NIO is de Java New I/O api. Geïntroduceerd in 1.4. Lees hier meer
't is wat performanter dan java.io en vult deze aan met wat nuttige classes.

Zie op die pagina ook voorbeelden over hoe het te gebruiken.