Java - errore java.net.SocketException: Connection reset

Forum - Java - errore java.net.SocketException: Connection reset

thebonni90 (Normal User)
Rookie

Messaggi: 22
Iscritto: 01/01/2011

Postato alle 21:35
Domenica, 05/06/2011

Salve ragazzi
ho fatto un semplice programmino formato da server e client dove il server gestisce le risorse invece il
client richiede le risorse però ho la seguente ecc ...
java.net.SocketException: Connection reset
    at java.net.SocketInputStream.read(Unknown Source)
    at java.net.SocketInputStream.read(Unknown Source)
    at java.io.ObjectInputStream$PeekInputStream.peek(Unknown Source)
    at java.io.ObjectInputStream$BlockDataInputStream.peek(Unknown Source)
    at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source)
    at java.io.ObjectInputStream.readObject0(Unknown Source)
    at java.io.ObjectInputStream.readObject(Unknown Source)
    at contSkel.run(contSkel.java:35)
codice dello skeleton con anche il protocollo

Codice sorgente - presumibilmente Java

/* SKELETON
 * Protocolllo
 * RICHISTA                                                             RISPOSTA
 *  "RIC" <Integer>     --------------> <risorsa>|<giaAssegnata>|<InterruptedException>
 *      "RIL" <Integer><risorsa> -------->      "OK"|<risorsaErrata>|<NoRisorsa>
 *      la NPE sarà lo stab a sollevarla
 */
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
 
 
public class contSkel extends Thread{
        //CAMPI
        private Socket s;
        private ObjectInputStream in;
        private ObjectOutputStream out;
        private GestoreImpl gest;
        //COSTRUTTORE
        public contSkel(Socket s,GestoreImpl gest)throws NullPointerException,IOException{
                if(s==null||gest==null)throw new NullPointerException();
                        this.s=s;
                        this.gest=gest;
                        //Apriamo i 2 stream
                        out= new ObjectOutputStream(s.getOutputStream());
                        in = new ObjectInputStream(s.getInputStream());
        }
        //METODI
        public void run(){
                try{
                        String op;
                        while(true){//ciclo infinito
                                //leggo una stringa dello stream
                                 op =(String)in.readObject();
                                 if(op.equals("RIC")){
                                         int tmp = ((Integer)in.readObject()).intValue();
                                         try{
                                                 Risorsa ris1= gest.richiedi(tmp);
                                                 out.writeObject(ris1);
                                         }catch(giaAssegnata e){out.writeObject(e);}
                                         catch(InterruptedException e){out.writeObject(e);}
                                        }
                                 else 
                                 {
                                         //allora è un rilascia
                                        
                                                int tmp = ((Integer)in.readObject()).intValue();
                                                Risorsa tmpris= (Risorsa)in.readObject();
                                                try{
                                                gest.rilascia(tmp, tmpris);
                                                }catch(risorsaErrata e){out.writeObject(e);}
                                                 catch(NoRisorsa e){out.writeObject(e);}
                                 }
                        }//end while
                        //end primo try                 
                }catch(IOException e){e.printStackTrace();}
                 catch(ClassNotFoundException e){e.printStackTrace();}
                finally{
                        try{
                                s.close();
                        }catch(IOException e){;}
                }
                
        }
}

codeice dello stub

Codice sorgente - presumibilmente Java

/*
 * Protocolllo
 * RICHISTA                                                             RISPOSTA
 *  "RIC" <Integer>     --------------> <risorsa>|<giaAssegnata>|<InterruptedException>
 *      "RIL" <Integer><risorsa> -------->      "OK"|<risorsaErrata>|<NoRisorsa>
 *      la NPE sarà lo stab a sollevarla
 */
 
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;
 
 
public class gestoreStub implements GestoreRisorse {
        //CAMPI
        private Socket s;
        private ObjectOutputStream out;
        private ObjectInputStream in;
        //COSTRUTTORE
        public gestoreStub()throws IOException{
                InetAddress a = InetAddress.getByName(null);
                s= new Socket (a,11112);
                out = new ObjectOutputStream (s.getOutputStream());
                in= new ObjectInputStream (s.getInputStream());
        }
        //METODI
        
        public Risorsa richiedi(int u) throws giaAssegnata, InterruptedException,
                        IOException {
                Object tmp = null;
                out.writeObject("RIC");
                out.writeObject(new Integer (u));
                try{
                        tmp= in.readObject();
                }catch(ClassNotFoundException e){throw new IOException();}//sic nel protocollo non è previsto
                if(tmp instanceof giaAssegnata)throw new giaAssegnata();
                else if(tmp instanceof InterruptedException )throw (InterruptedException )tmp;//cast e poi rialzo eccezione
                else return (Risorsa)tmp;//ritorna la risorsa
        }
 
        public void rilascia(int u, Risorsa r) throws risorsaErrata, NoRisorsa,
                        NullPointerException, IOException {
                Object tmp;
                if(r==null)throw new NullPointerException();
                out.writeObject("RIL");
                out.writeObject(new Integer(u));
                out.writeObject(r);
                try{
                        tmp = in.readObject();
                }catch(ClassNotFoundException e){throw new IOException();//sic non è previsto nel protocollo
                }
                if(tmp instanceof risorsaErrata)throw (risorsaErrata)tmp;
                else if(tmp instanceof NoRisorsa)throw (NoRisorsa)tmp;
                else return;
        }
}//end class

grazie a tt

se serve alleggo tutto il codice intero 8-)