Blocco quando creo ObjectInputStream

[linux_r]

Salve ragazzi a volte quando mi collego al server questo codice si blocca sulla riga commentata, ho fatto anche il debug ma non succede nulla , praticamente si ferma su quella riga e non va più avanti. Sapreste aiutarmi ?

public void connect(Credenziali login)
            throws java.net.ConnectException,
            IOException {
        Properties prop = new Properties();


        try (FileInputStream fis = new FileInputStream("settings.properties")) {
            prop.load(fis);
        }
        String addressIp = prop.getProperty("serverAddress");


        this.address = InetAddress.getByName(addressIp);
        this.socket = new Socket(address.getHostAddress(), this.serverPort);
        String percorso = "//Users//Linux//Documents//NetBeansProjects//jCallRememberServer//database.properties";
        String indirizzoRisorsa = "//" + addressIp + percorso;
   


        try (FileInputStream inputStreamRisorsa = new FileInputStream(new File(indirizzoRisorsa))) {
            Properties propRisorsaRemota = new Properties();
            propRisorsaRemota.load(inputStreamRisorsa);
            prop.setProperty("orarioMattinaInizio",propRisorsaRemota.getProperty("orarioMattinaInizio"));
            prop.setProperty("orarioMattinaFine", propRisorsaRemota.getProperty("orarioMattinaFine"));
            prop.setProperty("orarioPomeriggioInizio", propRisorsaRemota.getProperty("orarioPomeriggioInizio"));
            prop.setProperty("orarioPomeriggioFine", propRisorsaRemota.getProperty("orarioPomeriggioFine"));
            try (FileOutputStream fos = new FileOutputStream("settings.properties")) {
                prop.store(fos, null);
            }
        }
        Boolean isConnect;
        this.os = this.socket.getOutputStream();
        this.is = this.socket.getInputStream();
        this.oos = new ObjectOutputStream(this.os);
        this.ois = new ObjectInputStream(this.is); //si blocca qui
        oos.writeObject(login);
        oos.flush();
        


        isConnect = ois.readBoolean();
        if (!isConnect) {
            throw new java.net.ConnectException("Username o Password"
                    + " inesatte!");
        } else {
            
            this.user_and_pass = login;
            this.chatSocket = new Socket(address.getHostAddress(), 40001);
            OutputStream oschat = chatSocket.getOutputStream();
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(oschat));
            bw.write(login.getUsername() + "\n");
            bw.flush();
            
        }
    }

Per poter poi far funzionare tutto devo chiudere il server e avviarlo di nuovo

[LeleFT]

Una possibile causa che mi viene in mente è dovuta all'ordine di apertura degli stream.
Quando si ha a che fare con connessioni di rete, è essenziale fare attenzione all'ordine di apertura degli stream: il client ed il server li devono aprire in ordine inverso l'uno dall'altro.

Quindi, nel tuo client stai aprendo, nell'ordine, prima l'OutputStream e poi l'InputStream:

this.os = this.socket.getOutputStream();
this.is = this.socket.getInputStream();

Bene: il server deve fare esattamente il contrario (cioè, aprire prima l'InputStream e poi l'OutputStream) altrimenti 9 volte su 10 il client si pianterà.

Verifica questa cosa.


Ciao.

[andbin]

Io credo, se ben ricordo, che il problema è dovuto all'ordine degli ObjectXXXStream. In questo post c'era lo stesso problema e avevo risposto nel post seguente.

[linux_r]

QUesto è il server ma mi pare che sta cosa sia gia fatta.

/**
     * Costruttore di classe. Prende come argomento l'oggetto socket su cui il
     * client richiederà operazioni.
     *
     * @param socket
     * @throws IOException
     */
    public ServerWorker(Socket socket) throws IOException {
        this.socket = socket;
        this.worker = new Thread(this);
        this.is = this.socket.getInputStream();
        this.os = this.socket.getOutputStream();
        this.ois = new ObjectInputStream(is);
        this.oos = new ObjectOutputStream(this.os);
        this.lock = new ReentrantLock();
        this.condition = lock.newCondition();
    }

[LeleFT]

Io credo, se ben ricordo, che il problema è dovuto all'ordine degli ObjectXXXStream. In questo post c'era lo stesso problema e avevo risposto nel post seguente.

Sì, corretto... erano gli ObjectXXXStreams e non gli Input/Output Stream della socket...


Ciao.