[JAVA] XMLEncoder: inviare più oggetti codificati in XML su di un socket

[riccardocioria]

Ragazzi, ciao a tutti.
Ho un problema, ho bisogno di inviare più oggetti su di una socket attrav erso al serializzazione in XML. In pratica ho un client che riceve oggetti di tipo Libro li serializza in XML e li invia al server, il quale, li deserializza e invia una risposta al client.
Da quanto ho capito ad ogni oggetto dovrei chiudere l'oggetto XMLEncoder e quindi il relativo XMLDecoder nel server con conseguente chiusura del socket, mi pare veramente assurdo. E' possibile che non si possa tenere aperta la socket e inviare diversi oggetti in diversi tempi utilizzando il metodo flush() dell'encoder??? Sono tre ore che sbatto la testa, ma purtroppo il server mi rimane bloccato sulla readObject() finchè il client non fa la close sull encoder...

Vi posto il codice:

SERVER:

package server;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
	public Server(int port) {
		try {
			ServerSocket serverSocket = new ServerSocket(port);
			while (true) {
				System.out.println("In attesa su " + port);
				Socket socket = serverSocket.accept();
				System.out.println("Ricevuta connessione: "
						+ socket.getInetAddress() + ":" +
						socket.getPort());
				(new ClientHandler(socket)).start();
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

SERVER: HANDLER per ogni client

package server;

import java.beans.XMLDecoder;
import java.beans.XMLEncoder;
import java.io.BufferedWriter;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;

import libro.Libro;


public class ClientHandler extends Thread {
	Socket socket;
	public ClientHandler(Socket socket) { 
		this.socket = socket; 
	}


	public void run()  {
		XMLDecoder decoder = null;
		BufferedWriter writer = null;
		
		try {

			// creazione degli stream di lettura/scrittura di oggetti dal socket
			
			writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
			decoder = new XMLDecoder(socket.getInputStream());
			while (true) {
				try {
					
					Libro l = (Libro)decoder.readObject();	//riga incriminata				// la connessione è stata chiusa fine ciclo
					if (l == null) break;
					
					double costo_medio = l.getCosto() / l.getNumPagine();
					
					// salvo su un file lo stato dell'oggetto
					OutputStream file = new FileOutputStream("c:\\people.xml");
					XMLEncoder fwriter = new XMLEncoder(file);
					
					writer.write(l.getNumPagine() + "::" + costo_medio);
					writer.newLine();
					writer.flush();
					fwriter.writeObject(l);
					
					fwriter.close();
					file.close();
				}
				catch (Exception e) {
					writer.write("Eccezione " + e.getLocalizedMessage());
					writer.newLine();
					writer.flush();
				}

			}
		} catch (IOException e) {
			e.printStackTrace();
		}
		finally {
			try {
				if (decoder != null) decoder.close();
				if (writer != null) writer.close();
				if (socket != null) socket.close();
			}
			catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

CLIENT:

package client;

import java.beans.Expression;
import java.beans.Statement;
import java.beans.XMLEncoder;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;

import libro.Libro;


public class Client {
	/**
	 * @param host indirizzo del server 
	 * @param port porta di ascolto del server
	 * @throws UnknownHostException
	 * @throws IOException
	 */
	public Client(String host, int port) throws UnknownHostException, IOException {
		BufferedReader keyboardReader = null;
		BufferedReader reader = null;
		
		XMLEncoder encoder = null;
		
		Socket socket = null;

		System.out.println("Connessione al server: " + host + ":" + port + " ...");
		//creazione del socket
		try {
			socket = new Socket(host, port);
			System.out.println("Connessoo!");
			//creazione degli stream di lettura (tastiera, socket) e scrittura sul socket
			keyboardReader = new BufferedReader(new InputStreamReader(System.in));
			// creazione degli stream di lettura/scrittura di oggetti dal socket
			
			
			
			//writer = new ObjectOutputStream(socket.getOutputStream());
			InputStream is = socket.getInputStream();
			reader = new BufferedReader(new InputStreamReader(is));
			encoder = new XMLEncoder(socket.getOutputStream());
			while (true) {
				//Serializzazione e invio
				
				Libro l = new Libro();
				System.out.println("Client: >>> Inserisci l'autore: ");
				l.setAutore(keyboardReader.readLine());
				System.out.println("Client: >>> Inserisci il titolo: ");
				l.setTitolo(keyboardReader.readLine());
				System.out.println("Client: >>> Inserisci il numero di pagine: ");
				l.setNumPagine(Integer.parseInt(keyboardReader.readLine()));
				System.out.println("Client: >>> Inserisci il costo: ");
				l.setCosto(Integer.parseInt(keyboardReader.readLine()));

				// scrittura del nome del file sul socket
				Object[] arg = {"a", "b"};
				encoder.writeExpression(new Expression("obj","obj",null));
				encoder.writeObject(l);
				encoder.writeExpression(new Expression("/obj","/obj",null));
				encoder.flush();

				// Ricezione e Deserializzazione
				String libro = reader.readLine();
				String[] info = libro.split("::");
				System.out.println(l);
				System.out.println("Num. di pagine: " + info[0] + "\nCosto medio per pagina: " + info[1]);
			}
		}
		catch (Exception e) {
			e.printStackTrace();
		}
		finally {
			// le risorse vengono rilasciate
			if (keyboardReader != null) keyboardReader.close();
			if (reader != null) reader.close();
			if (encoder != null) encoder.close();
			if (socket != null) socket.close();
		}
	}
}