[Java] stream in rete

[fedetallo]

Salve, ho un piccolo quesito da proporvi: ho creato una piccola rete domestica composta da due pc e ho fatto un programmino d test che sfrutta i socket x trasferire 1 file. Il file viene letto da un oggetto FileInputStream e scritto direttam nell'oggetto d tipo OutputStream ottenuto dal socket. È poi presente un ciclo while che fino a qnd nn viene raggiunta la fine del file scrive ogni byte letto nel flusso d output del socket. Il processo ricevente è analogo: legge dall'input del socket e scrive su file. Se i due programmi li faccio eseguire sulla stessa macchina funziona tutto bene, ma se lo faccio sulle due macchine trasferisce solo alcuni byte e poi tutto si blocca. Devo riavviare il pc server (quello che invia il file) xchè altrimenti i due pc non si vedono nemmeno più in risorse d rete. Cosa mi consigliate d fare? Devo sfruttare qualche classe di I/O particolare? Grazie, Fede

[fedetallo]

x intenderci, il codice del server è il seguente

ServerSocket server = new ServerSocket(1984);
socket = server.accept();
in = new FileInputStream("file.txt");
out = socket.getOutputStream();
int b = in.read();

while(b != -1)
{
   out.write(b);
   b = in.read();
}
out.write(-1);

mentre quello del client

socket = new Socket("192.168.0.1",1984);
out = new FileOutputStream("c:\\file.txt");
in = socket.getInputStream();
int b;
while((b = in.read()) != -1) out.write(b);

[LeleFT]

Mi sembra strano che ti dia di questi problemi... io ho utilizzato esattamente lo stesso meccanismo per implementare il trasferimento file nella mia chat e funziona senza problemi...


Ciao.

[fedetallo]

ma hai esato le stess classi di I/O oppure ad esempio hai usato il datainputstream, ecc...?

[LeleFT]

Beh... dato che si tratta di una chat, che deve trasferire dati eterogenei (messaggi testuali, informazioni di settaggio tra server e client, parti di file e flag vari) non ho usato proprio un semplice OutputStream, ma mi sono appoggiato ad un ObjectInputStream, ma il meccanismo è lo stesso.
In fin dei conti c'è un Messaggio (che è un oggetto) che viaggia nella rete che, all'interno, contiene una parte del file che deve essere trasferita.


Ciao.

[fedetallo]

si, ho capito. forse io sbaglio xchè utilizzo invece direttamente gli outputstream... beh, ora provo. grazie!

[fedetallo]

ho provato utilizzando i DataInputStream e DataOutputStream ma nn è cambiato nulla. sembra quasi che la rete s intasi, xchè subito dopo nn, sebbene i processi vengano chiusi la rete rimane cm bloccata. eppure nn ho mai avuto problemi nel trasferimento normale d file, quindi il problema nn risiende nella rete stessa ma nel programma... cm fare???

[LeleFT]

Prova a postare tutto il codice...


Ciao.

[robyp]

Hai provato a bufferizzare lo stream che leggi?

BufferedInputStream in = new BufferedInputStream(socket.
getInputStream());

o

BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

Nel caso di file bibari è meglio che usi il primo modo.

poi alla fine fai un in.close() e socket.close()?

[fedetallo]

non ho bufferizzato ma ho provato ad usare i DataInputStream e DataOutputStream... leggevo e scrivevo tramite i metodi readByte() e writeByte().

per quanto riguarda la chiusura dei socket e dei flussi di I/O è tutto ok.

ho provato a mettere un pò di println nel codice e quello ke ho dedotto è ke il problema risiede probabilmente nel client. legge solo il primo carattere e poi si blocca sulla seconda read

in = new DataInputStream(socket.getInputStream());
byte b = in.readByte();
boolean done = false;

while(!done)
{
  try{b = in.readByte();}
  catch(Exception e) {System.out.println(e.getMessage());done = true;}
}

lui praticamente esegue la read fuori dal ciclo, ma non la prima dentro il ciclo. il server invece continua a scrivere e si blocca a circa 8000 byte... probabilmente a quel punto il buffer è pieno, il server rimane in attesa che il client legga i byte e rimane bloccato. difatti nno lancia eccezioni e sono costretto a chiuderlo manualmente. non viene quindi eseguita la chiusura del socket e di conseguenza la rete si blocca.

il problema è ora individuare la causa della non lettura del client!!!