✔ Sockets, multithreaded und persistent

[tha_specializt]

Also, ich möchte mich zuallererst entschuldigen, und zwar für den Fall dass meine Antwort tatsächlich schon beantwortet wurde, in dem Fall bitte möglichst freundlich zur Lösung verweisen, danke.

Problemstellung:

Eine Java-Klasse soll auf einem Server als Daemon unbegrenzt lange laufen, auf eingehende Verbindungen warten, diese in Threads einteilen und somit alle gleichzeitig / entsprechend der Thread-Queue bedienen, bei keinen eingehenden Daten ein Keep-Alive-Signal erwarten und danach X ms schlafen gehen (Thread.currentThread.sleep() ?), beim nächsten Durchlauf wieder auf das Signal warten.

Der Daemon (ich nenne es einfach mal so, bezeichnet ab jetzt diese Klasse) soll auf keinen Fall die Sockets beenden, sondern einfach so lange offenhalten wie Keep-Alive-Signale eingehen

Bisher erreicht:

Daemon hört auf eingehende Verbindungen und wartet auf ein Keep-Alive-Signal, schläft dann und erwartet selbiges erneut, ABER: ich kann selbst mit Anleitungen von Universitäten nicht erreichen, dass mehrere Verbindungen bedient werden. Im Howto stand, es würde über diesen Weg möglich sein, alle clients zu bedienen und für jeden einen seperaten Thread zu eröffnen. Dem ist aber nicht so! Immer wenn ich Thread.currentThread.getId() ausgeben lasse, dann erscheint jedesmal die ID (oder der Name, auch bereits getestet) der allerersten Verbindung, neue Verbindungen werden auf der Clientseite anscheinend akzeptiert (keine Fehlermeldungen), aber auf der Serverseite passiert nichts. Bin ich einfach zu blöd, oder schafft es nedmal eine Uni, mehrere Verbindungen zu behandeln

Ich bitte den Code-Wirrwar zu entschuldigen, aber ich versuche mit demselben Prinzip nun schon tagelang herum, der ursprüngliche Code sah viel einfacher und logischer aus

Server-Seite:

class client implements Runnable {
    private Vector handler = new Vector();
    private Vector threadsundsockets = new Vector();    
    private int id;
    private String nachricht;
    
    public client(Socket sock, int id) {
        this.handler.addElement(this.threadsundsockets);
        Vector beide = (Vector)this.handler.elementAt(id);
        beide.addElement(sock);
        beide.addElement(sock.toString());
        this.id = id;
  }
    
    
   
    
    public void run() {
        try {
            Vector beide = (Vector)this.handler.elementAt(this.id);
            Socket aktuellersocket = (Socket)beide.elementAt(0);
            Thread.currentThread().setName((String)beide.elementAt(1));
            aktuellersocket.setSoTimeout(5000);
            aktuellersocket.setKeepAlive(true);
            essentials meins = new essentials(aktuellersocket);
            //int i = 0;
            while(aktuellersocket.isClosed() == false) {
                //i++;
            
                
                if(meins.empfangen().equals("KEEPALIVE") == false) {
                   aktuellersocket.close(); }
                else {
                    System.out.println("Wir haben eine positive Antwort von Thread \""+Thread.currentThread().getName()+
                            "\" und legen uns jetzt schlafen...");
                    
                    Thread.currentThread().yield();
                     }
                    
            }
        } catch(Exception e) {e.printStackTrace(); }
        }
    public void stop() throws IOException {
        //this.socket.close();
        Thread.currentThread().interrupt();
    }
}


public class Server {
    
      
    
   public static void main(String args[]) {
    boolean benutzertreffer=false;

        try {
         
         ServerSocket ssocket = new ServerSocket(60000);         
         
       
        int i = 0;
         while(true) {
            
             Socket socket = ssocket.accept();
             ssocket.setReuseAddress(false);
             
             if(socket.isConnected()) {
                 client meiner = new client(socket, i);
                 meiner.run();
                 continue;
             } else {
                 System.out.println("Socket ist nicht konnektiert, daemon wird also nicht gestartet!");
             }
             i++;
             
              
        }
         
    
     }
      catch(Exception e) {e.printStackTrace();
      }
   }

Client-Seite:

this.socket = new Socket("localhost", 60000);
                                this.socket.setSoTimeout(5000);
                                this.socket.setKeepAlive(true);
                                essentials meins2 = new essentials(this.socket);
                                while(true) {
                                    meins2.senden("KEEPALIVE");
                                    Thread.currentThread().yield();
                                }

Die Klasse "essentials" ist nichts weiter als InputStream.read() und OutputStream.write() innerhalb von schleifen, so wird zb. bei InputStream.read() solange ein byte eingelesen, bis die letzten 4 bytes gecastet ein "STOP" ergeben ... nicht weltbewegendes.

Die seltsame Handhabung der Threads mittels Vektoren usw. tut nichts zur Sache, das stellt nur meinen letzten Versuch dar, das Ergebnis war das gleiche:

1. eingehende Verbindung klappt wunderbar, 2. klappt auf der Client-Seite anscheinend auch, aber am Server tut sich nichts.

 

[tha_specializt]

Lösung:

implements Runnable

durch

extends Thread

ersetzen und den Thread per

start()

starten