Streams mit Sockets

[Paddel]

Mahlzeit mein Prob is das ich gerade en Chat Client mache. Der Server besitzt einen ServerSocket :
" int port = 50000;
private ServerSocket socket;
static private HashMap< String, Socket> teilnehmer = new HashMap<String, Socket>();
BufferedReader is = null;
DataOutputStream os = null;
Socket s = null;"
Bei einer neuen Verbindung gibt es en neuen Thread:
" Server(Socket s){
this.s = s;
this.run();
}
@Override
public void run() {
StringTokenizer tokenizer = null;

try {
is = new BufferedReader(new InputStreamReader(s.getInputStream()));
os = new DataOutputStream(s.getOutputStream());"

mein Client sieht nich gross anders aus:
" Socket s = null;


BufferedReader is = null;
DataOutputStream os = null;....
System.out.println("Start des CLients");
s = new Socket("127.0.0.1", 50000);
is = new BufferedReader(new InputStreamReader(s.getInputStream()));
os = new DataOutputStream(s.getOutputStream());..."
Vom Client mit os.writeBytes zu senden klappt super. Wenn ich aber vom Server zum Client senden will mit:"
os.writeBytes("OK");

und das mit dem Client empfangen will mit:"
String request = is.readLine();" klappt das nicht und es kommt die Exception:
"java.net.SocketException: Software caused connection abort: socket write error"

Kann mir da mal jemand elfen.
Danke und Gruss

 

[musiKk]

Urks. Bitte

-Tags verwenden, damit mans ordentlich lesen kann.

 

[Paddel]

OK kleines ähnliches Beispiel was au nicht klappt:

package test;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
	Socket socket;
		ServerSocket serverSocket;
		BufferedReader is;
		 DataOutputStream os;
		public Server() throws IOException {
			serverSocket = new ServerSocket(100); 

		}
		public void senden() throws IOException{
			socket = serverSocket.accept();
		    is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		    os = new DataOutputStream(socket.getOutputStream());
		    
		    os.writeBytes("TEST");
		    System.out.println(is.readLine());
		    
		}
		public static void main(String[] args) throws IOException {
			Server server = new Server();
			Client client = new Client();
			server.senden();
			client.empfangen();
		}
}
und:

public class Client {
		Socket socket = null;
		BufferedReader is;
		 DataOutputStream os;
		public Client() throws UnknownHostException, IOException {
			socket = new Socket("127.0.0.1", 100);
		    is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		    os = new DataOutputStream(socket.getOutputStream());
		}
		public void empfangen() {
			
			try {
				System.out.println(is.readLine());
				os.writeBytes("Test2");
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
}

DAs sollte ja eigentlich Test und Test2 ausgeben und da verstehe ich meinen Fehler nicht so ganz...

 

[Schandro]

Er wartet unendlich lange in Zeile 25.
Du rufst beim server in.readLine() auf bevor du client.senden() aufrufst.

 

[musiKk]

Genau. Bei solchen Geschichten kommst Du nicht drum herum, das mit verschiedenen Threads zu lösen. Irgendwas blockiert sonst immer. Ob nun accept() oder read*()...

 

[Paddel]

hab das nun mal umgeschrieben:

package test;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class Server extends Thread{
	Socket socket;
		ServerSocket serverSocket;
		BufferedReader is;
		 DataOutputStream os;
		public Server() throws IOException {
			serverSocket = new ServerSocket(100); 

		}
		public void senden() throws IOException{

		    
		}
		@Override
		public void run() {
		
			try {
				socket = serverSocket.accept();
			    is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			    os = new DataOutputStream(socket.getOutputStream());
			    
			    os.writeBytes("TEST");
			    System.out.println(is.readLine());
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}
		public static void main(String[] args) throws IOException {
			Thread t1= new Server();
			Thread t2 = new Client();
			t1.start();
			t2.start();
		}
}

die 2te

package test;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client extends Thread{
		Socket socket = null;
		BufferedReader is;
		 DataOutputStream os;
		public Client() throws UnknownHostException, IOException {
			socket = new Socket("127.0.0.1", 100);
		    is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		    os = new DataOutputStream(socket.getOutputStream());
		}
		public void empfangen() {
			
		
		}
		@Override
		public void run() {
			try {
				os.writeBytes("Test2");
				System.out.println(is.readLine());
			
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
}

Jetzt laufen die beiden doch parallel, sprich beide senden was Thread 1 sendet Thread 2 auch und dann können beide das doch auch empfangen?

 

[musiKk]

readLine() benötigt \n, \r oder \r\n. Du lieferst nichts davon, darum hängen die beiden Methoden.
Fehlendes Flushen ist übrigens auch immer mal noch ein Fehler, wenngleich hier nicht (zumindest nicht bei mir).

 

[Paddel]

es fehlte das \n am Ende um readLine zu lesen.... Danke trotzdem für die Hilfe!