ServerSocket: Exceptions und Timeout Probleme

[Guest]

Hallo,


anbei ein Versuch eines Mini-Servers. Man verbindet sich mit ihm
und kann einen Text hinschicken, erhält ihn dann zurück.

Der "Server" hat folgende Schwachstellen:

1. Kommt es zu einem Timeout, wird die Exception ausgelöst,
im Catch-Part kann ich aber kein: client.close() machen,
der Compiler beschwert sich, dass client möglicherweise uninitialisiert ist,
bzw. kann garnicht die Variable "sehen". Ohne client.close bleiben
Clients bei einem Timeout aber einfach als "offen" hängen, z.B. Telnet.

2. Bei einem Timeout und einer daraus folgenden Exception
wird meine While-Schleife unterbrochen, den Catch-Part kann ich
aber auch nicht in die While-Schleife packen, da dies einen Compiler-Fehler
ergibt, da es sich dann mit dem try beisst.


Was kann ich tun?


Vielen Dank!


Thomas

public class mySocketServer extends Thread {
    
    boolean Terminated=false;
    
    @Override
    public void run() {
    
    ServerSocket sserver;  
    BufferedReader in;
    PrintWriter out;
    
   
    try{

    sserver = new ServerSocket(1234, 10, InetAddress.getByName("127.0.0.1"));
    
    while(!Terminated) {
        Socket client = sserver.accept();
        client.setSoTimeout(2000);

        in  = new BufferedReader(new InputStreamReader(client.getInputStream()));
        out = new PrintWriter(client.getOutputStream());
        
        String message = in.readLine();
        out.write(message+"\0");
        out.flush();
        System.out.println(message);
        in.close();
        out.close();
        client.close();
    }
    }catch(IOException e) 
     {
        System.out.println("IO-Exception: "+e);
        
     }
    
    
    return;
    }

 

[Guest]

Ergänzung zu 2. : Das hat dann zur Folge, dass sich nach dem Timeout eines Clients (->Exception) dann kein weiterer Client mehr mit dem "Server" verbinden kann, was ja nicht im Sinne des Erfinders ist...

 

[lhein]

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class MySocketServer extends Thread 
{
    ServerSocket sserver;
    BufferedReader in;
    PrintWriter out;
    boolean terminated=false;
   
    public void stopServer()
    {
        terminated = true;
    }
    
    @Override
    public void run() 
    {
        try 
        {
            sserver = new ServerSocket(1234, 10, InetAddress.getByName("127.0.0.1"));
        }
        catch(IOException e)
        {
            System.out.println("IO-Exception: "+e);
            terminated = true;
        }

        Socket client = null;
    
        while(!terminated) 
        {
            try 
            {
                client = sserver.accept();
                client.setSoTimeout(2000);

                in  = new BufferedReader(new InputStreamReader(client.getInputStream()));
                out = new PrintWriter(client.getOutputStream());
       
                String message = in.readLine();
                out.write(message+"\0");
                System.out.println(message);
            } 
            catch(IOException e) 
            {
                System.out.println("IO-Exception: "+e);
            } 
            finally 
            {
                try
                {
                    in.close();
                    out.close();
                    client.close();
                }
                catch(IOException ex)
                {
                    System.out.println("IO-Exception: "+ex);
                }
            }
        }
     }
}

Ich habs mal n bisl umgestellt. Nicht geprüft und so würd ich es sicher auch nicht machen.
Kleiner Hinweis: Dein Server kann immer nur einen Client gleichzeitig behandeln.

lr

 

[Guest]

Ja, jetzt funktioniert 2).

Hat noch jemand eine Idee, wie ich es schaffe, in einer Timeout-exception noch ein client.close machen zu können?

 

[lhein]

Welche Exception wirft er denn genau?

 

[Guest]

Die 2. Exceptions-Möglichkeit von oben wird ausgelöst.
Baut man nun in deinen neuen Code noch ein client.close() in die 2. Exception ein, dann klappts. Vielen Dank!!!

  while(!terminated) 
        { 
            try 
            { 
                client = sserver.accept(); 
                client.setSoTimeout(2000); 

                in  = new BufferedReader(new InputStreamReader(client.getInputStream())); 
                out = new PrintWriter(client.getOutputStream()); 
        
                String message = in.readLine(); 
                out.write(message+"\0"); 
                System.out.println(message); 
            } 
            catch(IOException e) 
            {   
                System.out.println("IO-Exception2: "+e); 
                try{
                in.close();
                out.close();
                client.close();
                }catch(IOException e1) {}
                
            } 
            finally 
            { 
                try 
                { 
                    in.close(); 
                    out.close(); 
                    client.close(); 
                } 
                catch(IOException ex) 
                { 
                    System.out.println("IO-Exception3: "+ex); 
                } 
            } 
        }

 

[lhein]

Deine Änderung ist so nicht gut. Finde bitte genau die Zeile heraus, wo die Exception geworfen wird, bzw. poste mal den StackTrace hier.

 

[Guest]

Bei einem Timeout passiert das hier:
IO-Exception2: java.net.SocketTimeoutException: Read timed out

Was meinst Du genau mit: "Deine Änderung ist so nicht gut. " ?

 

[lhein]

Packe mal unter:

System.out.println("IO-Exception2: "+e);

die Zeile:

e.printStackTrace();

Und dann poste mal was da steht.

lr

 

[Guest]

Hallo,

da bekomme ich das hier:


IO-Exception2: java.net.SocketTimeoutException: Read timed out
java.net.SocketTimeoutException: Read timed out
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.read(SocketInputStream.java:129)
at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:264)
at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:306)
at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:158)
at java.io.InputStreamReader.read(InputStreamReader.java:167)
at java.io.BufferedReader.fill(BufferedReader.java:136)
at java.io.BufferedReader.readLine(BufferedReader.java:299)
at java.io.BufferedReader.readLine(BufferedReader.java:362)
at java_myserver.mySocketServer.run(mySocketServer.java:51)

 

[lhein]

Also wird die Exception anscheinend hier geworfen:

String message = in.readLine();

Es könnte sein, daß der Versuch, "in" zu schliessen (in.close()) eine Exception auslöst.

Probier mal folgendes:

while(!terminated)
        {
            try
            {
                client = sserver.accept();
                client.setSoTimeout(2000);

                in  = new BufferedReader(new InputStreamReader(client.getInputStream()));
                out = new PrintWriter(client.getOutputStream());
       
                String message = in.readLine();
                out.write(message+"\0");
                System.out.println(message);
            }
            catch(IOException e)
            {   
                System.out.println("IO-Exception2: "+e);
            }
            finally
            {
                try
                {
                    in.close();
                }
                catch(IOException ioex)
                {
                    System.out.println("in schon geschlossen");
                }

                try
                {
                    out.close();
                    client.close();
                }
                catch(IOException ex)
                {
                    System.out.println("IO-Exception3: "+ex);
                }
            }
        }