Netzwerk-Thread

[H3llGhost]

Hallo Leute,

ich habe folgenden "Server"-Code:

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

public class ChatServer extends Thread {

       protected Socket socket = null;
       public static int port;

       public static void main(String args[]) {

              port = 4711;

              // Socket bereitstellen, an dem "gelauscht" wird
              try {
                  ServerSocket listen = new ServerSocket(port);

                  while(true) {
                              ChatServer aClient = new ChatServer(listen.accept());
                  }
              } catch (IOException ioe) {
                  System.err.println("Fehler: "+ioe.toString());
              }
       }

       public ChatServer(Socket socket) {
              this.socket = socket;
              start();
       }

       public void run() {
       try {
            InputStreamReader  isr = new InputStreamReader(socket.getInputStream());
            BufferedReader in = new BufferedReader(isr);
            while (true)
            {
             if (in.readLine() != "") System.out.println(in.readLine());
             //DataOutputStream os = new DataOutputStream(socket.getOutputStream());
             //MessageVerteilen(os);
             //socket.close(); // das ist neu
            }
           } catch (IOException e) {
            System.err.println("Fehler: "+e.toString());
           }
       }

       public void MessageVerteilen(DataOutputStream out) throws IOException {
              out.writeBytes("Alles OK");
              out.flush();
       }
} // Ende der Klasse

Der Client-Code ist folgender:

import java.net.*;
import java.io.*;
class ChatClient
{
  public static void main( String[] args ) throws Exception
  {
    Console eingabeTastatur = System.console();
    Socket server = new Socket( "localhost", 4711 );
    InputStreamReader  in  = new InputStreamReader(server.getInputStream());
    BufferedReader datenstromEinlesen = new BufferedReader(in);
    OutputStreamWriter out = new OutputStreamWriter(server.getOutputStream());
    PrintWriter pw = new PrintWriter(out, true);

    System.out.print("Geben Sie die erste Zahl ein:");
    String zahl1 = eingabeTastatur.readLine();
    pw.println(zahl1);
    System.out.print("Geben Sie die zweite Zahl ein:");
    String zahl2 = eingabeTastatur.readLine();
    pw.println(zahl2);
  }
}

Wenn ich den Server einschalte und dann die Client starte und dort eine Eingabe mache kommt die erste Eingabe garnichts an. Erst bei der zweiten und dann kommt auch ein Fehler.

12
Fehler: java.net.SocketException: Connection reset

Kann mir jemand helfen?
Danke im Voraus!

 

[anfänger15]

so

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

public class ChatServer extends Thread {

       protected Socket socket = null;
       public static int port;

       public static void main(String args[]) {

              port = 4711;

              // Socket bereitstellen, an dem "gelauscht" wird
              try {
                  ServerSocket listen = new ServerSocket(port);

                  while(true) {
                              ChatServer aClient = new ChatServer(listen.accept());
                  }
              } catch (IOException ioe) {
                  System.err.println("Fehler: "+ioe.toString());
              }
       }

       public ChatServer(Socket socket) {
              this.socket = socket;
              start();
       }

       public void run() {
       try {
            InputStreamReader  isr = new InputStreamReader(socket.getInputStream());
            BufferedReader in = new BufferedReader(isr);
            String read;
            while ((read =in.readLine()) != null)
            {
            System.out.println(read);
             //DataOutputStream os = new DataOutputStream(socket.getOutputStream());
             //MessageVerteilen(os);
             //socket.close(); // das ist neu
            }
             socket.close();
           } catch (IOException e) {
            System.err.println("Fehler: "+e.toString());
           }
          
       }

       public void MessageVerteilen(DataOutputStream out) throws IOException {
              out.writeBytes("Alles OK");
              out.flush();
       }
} // Ende der Klasse

import java.net.*;
import java.io.*;
class ChatClient
{
  public static void main( String[] args ) throws Exception
  {
    BufferedReader eingabeTastatur = new BufferedReader(new InputStreamReader(System.in));
    Socket server = new Socket( "localhost", 4711 );
    InputStreamReader  in  = new InputStreamReader(server.getInputStream());
    BufferedReader datenstromEinlesen = new BufferedReader(in);
    OutputStreamWriter out = new OutputStreamWriter(server.getOutputStream());
    PrintWriter pw = new PrintWriter(out, true);


    System.out.print("Geben Sie die erste Zahl ein:");
    String zahl1 = eingabeTastatur.readLine();
    pw.println(zahl1);
    System.out.print("Geben Sie die zweite Zahl ein:");
    String zahl2 = eingabeTastatur.readLine();
    pw.println(zahl2);
    
    pw.flush();
    pw.close();
    in.close();
    server.close();
  }
}

Du darfst im Server nicht 2mal readLine aufrufen, denn so testet er zuerst ob das was bei "erste Zahl" eingegeben wurde null ist und wenn das nicht der Fall ist liest er nochmal " das was bei zweite Zahl" eingegeben wurde und zeigt nur das 2 auf der Konsole an.

 

[H3llGhost]

Danke erstmal für deine Hilfe!

Jetzt habe ich den Code in der Server.java wie folgt angepasst:

[...]
       public void run() {
       try {
            InputStreamReader  isr = new InputStreamReader(socket.getInputStream());
            BufferedReader in = new BufferedReader(isr);
            while (true)
            {
             String tmp = in.readLine();
             if (tmp != "") System.out.println(tmp);
             //DataOutputStream os = new DataOutputStream(socket.getOutputStream());
             //MessageVerteilen(os);
             //socket.close(); // das ist neu
            }
            socket.close();
           } catch (IOException e) {
            System.err.println("Fehler: "+e.toString());
           }
       }
[...]

Aber beim Kompilieren kommt folgender Fehler:

ChatServer.java:43:13: unreachable statement
socket.close();
^

 

[masta // thomas]

Das liegt daran, dass deine (Endlos)Schleife niemals unterbrochen wird.

 

[H3llGhost]

Wie würde ich die am Sinnvollsten unterbrechen?

 

[masta // thomas]

Du könntest deine Schleife z.B. so umbauen:

String tmp;
while((tmp = in.readLine()) != null)
{
    if(!tmp.equals(""))
        System.out.println(tmp);
}

 

[anfänger15]

Wie würde ich die am Sinnvollsten unterbrechen?

ich hab dir das doch schon in dem von mir geposteten Code gemacht. So sollte es auch gehen.

 

[H3llGhost]

Sorry ...
Hatte ich überlesen ...

Jetzt funktioniert es wie ich es mir erhofft hatte.
Wie kann ich jede Client-Connection mit einer eigenen ID am besten Versehen?
Ein Array bestehend aus IP und ID?

Wäre über Vorschläge erfreut ...