Nel server java.io.StreamCorruptedException: invalid type code: AC

[linux_r]

Si verifica l'eccezione del titolo alla riga indicata nel commento del codice

package jcallremember.server;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.sql.SQLException;
import java.util.logging.Level;
import java.util.logging.Logger;
import jcallremember.libreria.Credenziali;
import jcallremember.libreria.Operazioni;
import jcallremember.libreria.ClienteDB;
/**
 *
 * @author Pasquale Caloriger
 * Questa Classe implementa un thread Server che fornisce servizi al client
 */
public class ServerWorker implements Runnable{
    private final Socket socket;
    private final Thread worker;
    private  Credenziali login;
    private final InputStream is;
    private final OutputStream os;
    public ServerWorker(Socket socket) throws IOException{
        this.socket=socket;
        this.worker=new Thread(this);
        this.is=this.socket.getInputStream();
        this.os=this.socket.getOutputStream();
    }
    public void start(){
        this.worker.start();
    }
    @Override
    public void run() {
        //Nella prima fase il thread worker legge i dati di login che il client 
        //invia
        if (socket.isConnected()) {
            try {
                ObjectInputStream ois = new ObjectInputStream(is);
                //legge l'oggetto Credenziali inviato dal client
                this.login=(Credenziali)ois.readObject();
                ObjectOutputStream oos=new ObjectOutputStream(this.os);
                //invia al client true se il login è corretto , false
                //altrimenti
                oos.writeBoolean(Database.getInstance().isLoginCorrect(login));
                oos.flush();
                //si mette in attesa di richieste da parte del client
                while(true){
                    //aspetto di leggere un oggetto Operazioni(enum)
                    Operazioni op=(Operazioni)ois.readObject(); //si verifica l'eccezione
                    switch(op){
                        case INSERIMENTO:
                            ClienteDB cliente=(ClienteDB)ois.readObject();
                            Boolean isOk=Database.getInstance().insertCliente(cliente,
                                    login.getUsername());
                            oos.writeBoolean(isOk);
                            oos.flush();                            
                            break;
                        case DOWNLOAD:
                            Object [][]  appuntamenti=Database.getInstance().
                                    downloadAppuntamentiOperatore(this.login);
                            oos.writeObject(appuntamenti);
                            oos.flush();
                            break;
                            
                        
                    }
                }
                   
                    
                
            } catch (IOException | ClassNotFoundException | SQLException ex) {
                Logger.getLogger(ServerWorker.class.getName()).
                        log(Level.SEVERE, null, ex);
            }
            
        }
    }
    
}

[andbin]

Si verifica l'eccezione del titolo alla riga indicata nel commento del codice

Nel client crei più volte un nuovo ObjectOutputStream per comunicare sullo stesso output stream del socket? Se sì, il problema è lì.

[linux_r]

si.. in metodi diversi

[linux_r]

ma è possibile inviare un enum su un socket?? perchè quando lo invio col metodo wirtieObject il server mi da questa eccezione:
Exception in thread "Thread-4" java.lang.ClassCastException: java.lang.String cannot be cast to jcallremember.libreria.Operazioni
Dove Operazioni è una enum.
Server:
Operazioni op = (Operazioni) ois.readObject();

Client
Operazioni obj=Operazioni.DOWNLOAD;
oos.writeObject(obj);
oos.flush();

[andbin]

si.. in metodi diversi

La serializzazione degli oggetti utilizza un "protocollo" ben preciso, che prevede un piccolo header di 4 byte iniziali per "marcare" lo stream per la serializzazione.
In sostanza è sbagliato "appendere" oggetti sullo stesso stream con un nuovo ObjectOutputStream.

ma è possibile inviare un enum su un socket??

Le enum sono serializzabili ma il trattamento è più particolare. Con altre classi, quando deserializzi ottieni un nuovo oggetto. Con le enum no, perché il concetto è quello di avere un numero fisso e preciso di istanze, che sono poi le costanti della enum.

perchè quando lo invio col metodo wirtieObject il server mi da questa eccezione:
Exception in thread "Thread-4" java.lang.ClassCastException: java.lang.String cannot be cast to jcallremember.libreria.Operazioni

Server:
Operazioni op = (Operazioni) ois.readObject();

Client
Operazioni obj=Operazioni.DOWNLOAD;
oos.writeObject(obj);
oos.flush();

Non è che stai aspettando il dato al momento sbagliato?

[linux_r]

Allora praticaamente avrei bisogno di creare due oggetti objectinputstream e quindi due objectoutputstream sugli stessi inputstream e outputstream! è fattibile sta cosa?

[andbin]

Allora praticaamente avrei bisogno di creare due oggetti objectinputstream e quindi due objectoutputstream sugli stessi inputstream e outputstream! è fattibile sta cosa?

Uno stesso oggetto InputStream vuoi incapsularlo in due distinti ObjectInputStream?? E per quale motivo?

[linux_r]

Nessun motivo particolare. Mi chiedevo se era una cosa fattibile tutto qui!

[andbin]

Nessun motivo particolare. Mi chiedevo se era una cosa fattibile tutto qui!

In generale è bene evitare che lo stesso oggetto di I/O sia usato da più wrapper. Poi per ObjectInputStream sicuramente è da evitare. Il costruttore di ObjectInputStream la prima cosa che fa è leggere l'header della serializzazione (che è una sequenza ben precisa di pochi byte). Se 2 ObjectInputStream cercano di leggerlo dallo stesso stream ...... beh, immagina tu.

[linux_r]

ma in modo sincronizzato la cosa sarebbe fattibile?