Socket

[supergiox]

Salve a tutti, ho un problema con i socket...
Ho creato due classi (Server e Client) da utilizzare eventualmente in altri programmi.
Con il server apparentemente non ho problemi e riesco a ricevere messaggi di prova che invio con telnet, il client invece mi genera diverse eccezioni, tra cui "java.net.SocketException: Broken pipe"

Vi posto il codice del server:

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Server{
	ServerSocket socket;
	Socket connection = null;
	DataOutputStream out;
	DataInputStream in;
	String message;
	
	Server(int port){
		try {
			socket = new ServerSocket(port);
			System.err.println("In listening...");
			connection = socket.accept();
			System.err.println("Connessione avvenuta con " + connection.getInetAddress().getHostName());
			in = new DataInputStream(connection.getInputStream());  
		    out = new DataOutputStream(connection.getOutputStream());
			out.flush();
		} catch (IOException e) {
			e.printStackTrace();
		}}
	
	
	String receive(){
		String msg="";
		try {
			msg = (String)in.readLine();
		} catch (IOException e) {
			e.printStackTrace();
		}
		return msg;}
	
	void send(String msg)
	{
		try{
			out.writeChars(msg);
			out.flush();
		}
		catch(IOException ioException){
			ioException.printStackTrace();
		}}
	
	
	void close(){
		try {
			in.close();
			out.close();
			socket.close();
		} catch (IOException e) {
			e.printStackTrace();
		}}
	
	
	public static void main(String args[]) throws InterruptedException, IOException
	{
		
		String ric="";
		Server server = new Server(8888);
		System.err.println("\nCONNESSO!");
		server.send("Siamo collegati!\n");
		while(true){
			if(ric.equals("") || ric==null || ric.equals("chiudi"))
			break;
			ric=server.receive();
			System.out.println("Ho ricevuto:"+ric);
			}
		System.err.println("Chiudo la connessione");
		server.close();
		}
		
}

e del client:

import java.net.*;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class Client{
	Socket socket;
	DataOutputStream out;
	DataInputStream in;
 	
	Client(String address, int port){
		try {
			socket = new Socket(address, port);
			System.err.println("Connesso a "+address+" alla porta "+port);
			in = new DataInputStream(socket.getInputStream());  
		    out = new DataOutputStream(socket.getOutputStream());
			out.flush();
			
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			System.err.println("Connessione rifiutata");
		}}
	
	
	String receive(){
	String msg="";
	try {
		msg=(String)in.readLine();
	} catch (IOException e) {
		e.printStackTrace();
	}return msg;
	}
	
	void send(String msg)
	{
		try{
			out.write(2);
			out.flush();
		}
		catch(IOException ioException){
			ioException.printStackTrace();
		}}
	
	void close(){
		try {
			in.close();
			out.close();
			socket.close();
		} catch (IOException e) {
			e.printStackTrace();}}
	
	
	
	
	public static void main(String args[]) throws InterruptedException
	{
		Client client = new Client("localhost", 8888);
		Thread.sleep(2000);
		client.send("ciaoo");
		Thread.sleep(2000);
		client.send("come");
		Thread.sleep(2000);
		client.send("stai??");
		Thread.sleep(2000);
		client.send("chiudi");
		client.close();
	}
}

Dove può essere il problema?
Grazie per l'attenzione, ciao!

[bstefano79]

il prblema sembra sia questa parte di codice, nel Server

if(ric.equals("") || ric==null || ric.equals("chiudi"))
break;

appena il Client si apre il Server si chiude

[bstefano79]

l'attesa in lettura devi farla prima del controllo

while(true){
	ric=server.receive();
             if(ric.equals("") || ric==null || ric.equals("chiudi"))
	break;
             etc etc

così il primo messaggio sembra leggerlo poi da un nullpointer (il messaggio risulta comunque incomprensibile) lo sapevi che il metodo readLine() dell'oggetto DataInputStream è deprecato?

[LeleFT]

if(ric.equals("") || ric==null || ric.equals("chiudi"))

Questa riga di codice è logicamente errata.
Cosa succede se "ric" è nullo? Il primo test fa scatenare una eccezione e il programma termina con errore.

Le condizioni vanno messe nell'ordine corretto (e magari è bene anche usare le parentesi):

if((ric == null) || ric.equals("") || ric.equals("chiudi"))

Altra buona regola da seguire è quella di invertire variabile e costante nei test. L'istruzione sarebbe stata formalmente corretta se fosse stata scritta in questo modo:

if("".equals(ric) || (ric == null) || "chiudi".equals(ric))

Non avrebbe mai potuto sollevare eccezioni.


Ciao.

[bstefano79]

infartti è stata la seconda cosa che ho notato, il null pointer era proprio perchè ris era null