[Java] Socket

[ally]

...stavo cercando di implementare un server in grado di instaurare una piccola comunicazione con piu' client...questo server di base dovrebbe riuscire non solo a mandare e ricevere messaggi ma anche oggetti di natura diversa...il codice di partenza da me usato è :

public class ObjectServer {
	
	public static void main(String args[]) throws Exception {
		
		ServerSocket ssock = new ServerSocket(1234);
		File file = new File("C:/test.mpg");
		
		while (true) {
			System.out.println("Listening");
			Socket sock = ssock.accept();
			ObjectOutputStream ostream = new ObjectOutputStream(sock.getOutputStream());
			ostream.writeObject(file);
			ostream.close();
			sock.close();
		}
	}
}

public class ObjectClient {
	
	public static void main(String[] args) throws Exception {
		
		Socket sock = new Socket("localhost", 1234);
		ObjectInputStream ois = new ObjectInputStream(sock.getInputStream());
		Object object = ois.readObject();
		
		if(object == File.class)
			System.out.println("is file");
		
		if(object == String.class)
			System.out.println("is string");
		
		System.out.println(object.getClass());
		
		ois.close();
		sock.close();
	}
}

...e fin qua tutto bene...il server per ogni richiesta che riceve risponde inviando un oggetto che il client riesce ad identificare e in un secondo momento gestirà...il problema ora è far si che il client risponda al server dopo aver ricevuto la risposta e che si instauri così una sorta di dialogo che preveda inoltre un comando di chiusura della comunicazione...

...grazie...ciao...

[kingv]

Puoi gestire anche in InputStream lato server e un OutputStream lato client, quello che scrivi da una parte lo leggi dall'altra.

[ally]

Originariamente inviato da kingv

Puoi gestire anche in InputStream lato server e un OutputStream lato client, quello che scrivi da una parte lo leggi dall'altra.

...o relativo objectstream giusto?...vorrei dialogare usando questo stream...

...ciao...

[ally]

...ho agganciato i due stream ai metodi ed ho modificato il tutto per inserirlo in un while infinito...ma nell'invio dal client al server si verifica un "Exception in thread "main" java.net.SocketException: Software caused connection abort: socket write error"...

public class ObjectServer {
	
	public static void main(String args[]) throws Exception {
		
		boolean alwaysTrue = true;
		ServerSocket ssock = new ServerSocket(1234);
		ObjectInputStream ois = null;
		Socket sock = null;
		
		while (alwaysTrue) {
			
			sock = ssock.accept();
			ObjectOutputStream ostream = new ObjectOutputStream(sock.getOutputStream());
			ostream.writeObject("server send");
			ostream.close();
			
			if(!sock.isClosed())
			{
				ois = new ObjectInputStream(sock.getInputStream());
				Object object = ois.readObject();
				System.out.println("server recive : "+object.getClass());
			}
		}
		sock.close();
	}
}

public class ObjectClient {
	
	public static void main(String[] args) throws Exception {
		
		boolean alwaysTrue = true;
		
		Socket sock = new Socket("localhost", 1234);
		ObjectInputStream ois = null;
		
		while(alwaysTrue){
			
			ois = new ObjectInputStream(sock.getInputStream());
			Object object = ois.readObject();
			System.out.println("client recive : "+object.getClass());
			
			ObjectOutputStream ostream = new ObjectOutputStream(sock.getOutputStream());
			ostream.writeObject("client send");
			ostream.close();
			
		}
		
		ois.close();
		sock.close();
	}
}

...vorrei sapere se questa strada è giusta o esistono approcci piu' intelligenti per inviare oggetti di diversa natura tramite socket...

...ciao...

[ally]

...trovato soluzione al mio cruccio...

public class ObjectServer {
	
	public static void main(String[] arg) {
		
		MessageData messagge;
		
		try{
			ServerSocket socketConnection = new ServerSocket(1234);
			while (true) {
				System.out.println("Server Waiting");
				Socket pipe = socketConnection.accept();
				System.out.println(pipe.getInetAddress());
				System.out.println(pipe.getRemoteSocketAddress());
				ObjectInputStream serverInputStream = new ObjectInputStream(pipe.getInputStream());
				ObjectOutputStream serverOutputStream = new ObjectOutputStream(pipe.getOutputStream());
				messagge = (MessageData)serverInputStream.readObject();
				messagge.setRequest("resp file");
				messagge.setObject(new File("c:/test.mpg"));
				serverOutputStream.writeObject(messagge);
				serverInputStream.close();
				serverOutputStream.close();
			}
		}catch(Exception e){
			System.out.println(e); 
		}
	}
}

public class ObjectClient {
	
	public static void main(String[] arg) {
		try {
			MessageData message = new MessageData();
			message.setRequest("req file");
			message.setObject(new File("c:/test.mpg"));
			Socket socketConnection = new Socket("localhost", 1234);
			ObjectOutputStream clientOutputStream = new ObjectOutputStream(socketConnection.getOutputStream());
			ObjectInputStream clientInputStream = new ObjectInputStream(socketConnection.getInputStream());
			clientOutputStream.writeObject(message);
			message = (MessageData)clientInputStream.readObject();
			System.out.println("request : " + message.getRequest());
			File file = (File) message.getObject();
		    System.out.println(file.length());
		    System.out.println(file.getName());
		    System.out.println(file.getParentFile());
			clientOutputStream.close();
			clientInputStream.close();
		}catch(Exception e){
			System.out.println(e); 
		}
	}
}

...resta ancora valida la domanda su eventuali soluzioni piu' idonee a risolvere questo problema...

...grazie ciao...

[kingv]

l'approccio che usi puo' funzionare, ma se il tuo scopo è passare oggetti java e in generale usare un approccio a oggetti alla programmazione di rete puoi usare RMI che è da anni stabile e maturo.

[ally]

Originariamente inviato da kingv

l'approccio che usi puo' funzionare, ma se il tuo scopo è passare oggetti java e in generale usare un approccio a oggetti alla programmazione di rete puoi usare RMI che è da anni stabile e maturo.

...ottimo grazie...ora cerco info in proposito...

...ciao...

[banryu79]

A proposito di RMI c'è un tutorial di PGI-Bis: qui.
Non è un tutorial da zero su RMI ma può esserti utile, segnalare non nuoce

[ally]

...tutorial molto interessante...ho cominciato pero' con qualche guida un po' piu' semplice per prendere mano con il package...ho trovato un esempio su html.it...dopo aver avviato l'rmiregistry al lancio del server si scatena un class not found...

java.rmi.ServerException: RemoteException occurred in server thread; nested exception is: 
	java.rmi.UnmarshalException: error unmarshalling arguments; nested exception is: 
	java.lang.ClassNotFoundException: sample.ISquareRoot

...ecco le classe interessate...

package sample;

import java.rmi.Remote;
import java.rmi.RemoteException;

public interface ISquareRoot extends Remote
{
	double calculateSquareRoot(double aNumber) throws RemoteException;
}

package sample;

import java.net.MalformedURLException;
import java.rmi.server.UnicastRemoteObject;
import java.rmi.Naming;
import java.rmi.RemoteException;


public class RMISquareRootServer extends UnicastRemoteObject
implements ISquareRoot
{
	public RMISquareRootServer()throws RemoteException
	{

	}

	public double calculateSquareRoot(double aNumber)
	{
		return Math.sqrt( aNumber);
	}

	public static void main(String[] args)
	{
		try
		{
			ISquareRoot server = new RMISquareRootServer();
			Naming.rebind("//localhost/RMISquareRoot",server);
		}
		catch (RemoteException e){e.printStackTrace( );}
		catch (MalformedURLException e) {e.printStackTrace( );}
	}
}

package sample;

import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.net.MalformedURLException;

public class RMISquareRootClient
{
	public static void main(String[] args) {
		int x = Integer.parseInt(args[0]);

		try
		{
			ISquareRoot squareServer =
				(ISquareRoot) Naming.lookup ("rmi://localhost/RMISquareRoot");

			double result = squareServer.calculateSquareRoot(x) ;
			System.out.println(result);
		}
		catch(NotBoundException e)
		{
			e.printStackTrace( );
		}
		catch(RemoteException e)
		{
			e.printStackTrace( );
		}
		catch(MalformedURLException e)
		{
			e.printStackTrace( );
		}
	}
}

...qualche idea?...

...grazie ciao...

[kingv]

ti manca qualche property da settare, ti consiglio questo link :
http://java.sun.com/docs/books/tutor...i/running.html