Socket Kommunikation in beide Richtungen

[bizkit]

Hallo,

ich habe folgendes Problem:
Das Programm besteht aus einem Server und Client.

Client verbindet sich mit dem Server. Der Client sendet einen String (String wird von der Tastatur eingelesen) an den Server und der Server gibt einen Antwortstring auf diese Anfrage zurück.

PROBLEM: der Server gibt den eingelesenen String nicht zurück, erst wenn ich die Verbindung durch den "STOP" butten beende, dann gibt er das Eingelesen aus mit einer Fehlermeldung: java.net.SocketException: Connection reset

Könnte mir jemand helfen das Problem zu beheben?
Der Client bzw Server sollte die Abfrage von der Tastaur ohne den "STOP" Button zurück geben und ohne Fehlermeldung.

hier sind die Quellcodes:
SERVER:

import java.net.*;
import java.io.*;
import java.util.*;

public class SimpleEchoServer {
	
	  public static void main(String args[]) 
	  {
	    
	    try {
	    	while(true)
	    	{
	      System.out.println("Warte auf Verbindung auf Port 7013..2."); 

	      ServerSocket echod = new ServerSocket(7013);
	      System.out.println("Vor accept()");
	      Socket socket = echod.accept();
	     
	      System.out.println("Verbindung hergestellt");
	      InputStream in = socket.getInputStream();
	      OutputStream out = socket.getOutputStream();
	      	      
	      int c;
	      while ((c = in.read()) != -1 ) {
	    	  	System.out.print((char)c);
	    	  	out.write((char)c);
    	  }      
	      System.out.println("Verbindung beenden");
	      socket.close();
	      echod.close(); 
	    }
	    } catch (IOException e) {
	      System.err.println(e.toString());
	      System.exit(1);
	    }
	  }
	}

CLIENT:

import java.net.*;
import java.io.*;

public class SimpleEchoClient {

	public static void main(String args[])
	  {
	  System.out.println("HALLO");
	    if (args.length != 1) {
	      System.err.println("Usage: java Listing 7013 <host>");
	      System.exit(1);
	    }
	    try {
	  	// String hostname = args[0]; 
	    //  int portnr = new Integer(args[1]).intValue();
			Socket sock = new Socket(args[0], 7013);		
	   //   Socket sock = new Socket(hostname, portnr);	
	    	InputStream in = sock.getInputStream();
	    	OutputStream out = sock.getOutputStream();
	    	    	
	    	BufferedReader conin = new BufferedReader(new InputStreamReader(System.in));
	    	System.out.println("Gebe was ein!");
	    	
	    	String line;
	    	line = conin.readLine();
	    	out.write(line.getBytes());
	    	
	    	BufferedReader buffin = new BufferedReader(new InputStreamReader(in)); 
	    	String ausgText = buffin.readLine();
	    	System.out.println(ausgText);
	    
	    	System.out.println("BLOCK4");
	     
	    	in.close();
	    	sock.close();   
	    } catch (IOException e) {
	      System.err.println(e.toString());
	      System.exit(1);
	    }
	  }
	}

 

[diggaa1984]

ich rate mal ins blaue und tippe darauf, dass du die Inhalte die du senden möchtest auch flushen musst, damit sie nicht erst ewig zwischengepuffert werden, siehe OutputStream#flush

 

[SlaterB]

dazu darauf achten, auch einen Zeilenumbruch zu senden, wenn der später mit readLine() gelesen werden soll,

readLine() liefert immer die Zeile ohne Zeilenumbruch, den manuell anhängen, \n

 

[bizkit]

es muss irgendwie ohne flush() gehen.

in der Vorlesung hat der Professor das Programm ohne flush() laufen gehabt.
nur kann ich mich leider nicht mehr erinnern wie.

 

[SlaterB]

siehe auch mein Posting zuvor,

mag sein dass nach paar ms eh gesendet wird, verlassen würde ich mich aber nicht drauf,
meiner Erfahrung nach ist flush() manchmal der entscheidende fehlende Schritt,
nimm das lieber auf, statt es aus zweifelhaften Gründen einzusparen

 

[bizkit]

und wie mache ich das mit flush() ?

 

[diggaa1984]

Einfach nach write aufrufen. Beim Server kannst dir dann überlegen, ob es in die while-Schleife oder besser dahinter kann. Kommt drauf an welches Verhalten erwünscht ist.

 

[bizkit]

es funktionier nicht.

oder ich habe was falsch gemacht
hier sind die aktuellen codes:

SERVER:

import java.net.*;
import java.io.*;
import java.util.*;

public class SimpleEchoServer {
	
	  public static void main(String args[]) 
	  {
	    
	    try {
	    	while(true)
	    	{
	      System.out.println("Warte auf Verbindung auf Port 7013..2."); 

	      ServerSocket echod = new ServerSocket(7013);
	      System.out.println("Vor accept()");
	      Socket socket = echod.accept();
	     
	      System.out.println("Verbindung hergestellt");
	      InputStream in = socket.getInputStream();
	      OutputStream out = socket.getOutputStream();
	      	      
	      int c;
	      while ((c = in.read()) != -1 ) {
	    	  	System.out.print((char)c);
	    	  	out.write((char)c);
	    	  //	out.flush();
	      }      
	    
	      out.flush();
	      
	      socket.close();
	      echod.close(); 
	    
	    	}
	    } catch (IOException e) {
	      System.err.println(e.toString());
	      System.exit(1);
	    }
	  }
	}

CLIENT:

import java.net.*;
import java.io.*;

public class SimpleEchoClient {

	public static void main(String args[])
	  {
	  System.out.println("HALLO");
	    if (args.length != 1) {
	      System.err.println("Usage: java Listing 7013 <host>");
	      System.exit(1);
	    }
	    try {
	  	// String hostname = args[0]; 
	    //  int portnr = new Integer(args[1]).intValue();
			Socket sock = new Socket(args[0], 7013);		
	   //   Socket sock = new Socket(hostname, portnr);	
	    	InputStream in = sock.getInputStream();
	    	
	    	
	    	
	    	OutputStream out = sock.getOutputStream();
	    	    	
	    	BufferedReader conin = new BufferedReader(new InputStreamReader(System.in));
	    	System.out.println("Gebe was ein!");
	    	
	    	String line;
	    	line = conin.readLine();
	    	out.write(line.getBytes());
	    	out.flush();
	    	
	    	BufferedReader buffin = new BufferedReader(new InputStreamReader(in)); 
	    	String ausgText = buffin.readLine();
	    	System.out.println(ausgText);
	    	     
	    	in.close();
	    	sock.close();   
	    } catch (IOException e) {
	      System.err.println(e.toString());
	      System.exit(1);
	    }
	  }
	}

 

[SlaterB]

zwei Tipps wurden gegeben, einer eingebaut, einer nicht (auch keine Rücfrage),
Ergebnis ist verdient

 

[bizkit]

ehrlich gesagt, weiß ich auch nicht wie ich das mit readLine() mache.

ich habe gehofft, dass es ohne gehen würde, da es mir peinlich ist, sowas zufragen

 

[SlaterB]

funktioniert es wenn du
> line = conin.readLine();
mit
> line = conin.readLine()+"\n";
ersetzt?

 

[diggaa1984]

EDIT: schieb auf der Serverseite auch ein "\n" als letztes in den Outputstream, damit der Client beim Auslesen des Echos auch ein Ende findet (da du dort auch readLine verwendest)

 

[bizkit]

es funktioniert

danke für die hilfe:toll: