hallo forum,

hab 2 programme. Einer ist "watcher" und soll nur abfragen können ob mein 2-tes Programm "Server" läuft. Wenn nicht soll der "watcher" eine entsprechende Meldung geben. Die beiden sollen gewissermassen komunizieren können. Wie ist es am Besten das Problemm zu lösen?
Für jede Hilfe bin ich sehr dankbar...

Gruß

[sparrow]

Laufen die beiden Programme auf dem selben Rechner, oder läuft der Server auf einem anderen Rechner als der Watcher?

Wenn letzteres der Fall ist, richte auf dem Server einen Socket ein, auf den er lauscht.
Vom Client aus öffnest du dann eine Verbindung zum Server und sendest eine Zeichenkette. z. B. "ON". Gleichzeitig setzt du den Time-Out der Verbindung auf 10 Sekunden.
Der Server lauscht ja auf den Port, bei der eingehenden Verbindung öffnest du einen Thread der die eingehende Zeichenkette prüft, ist die Zeichenkette "ON" antwortet der Server: "YES"

Was passieren kann:
1. Der Server läuft nicht, dann kommt es beim Aufbau bereits zu einem Fehler (Connection refused)
2. Der Server antwortet nicht, dann wirft der Socket ebenfalls einen Fehler (Connection Timed Out)
3. Der Server antwortet, dann brauchst du nur noch prüfen ob der Servr die Zeichenkette "YES" antwortet.

Wie das ganze funktioniert ist recht gut beschrieben in "Java ist auch eine Insel", und zwar in diesem Kapitel.

Gruß
Sparrow

Es klingt sehr bedacht das Ganze. Ich mache mich dann an die Arbeit. Wenn fertig, schreibe ich dann zurück ob es geklappt hat.

Gruß und schönen Dank

Hallo sparrow,
hab mich Heute mit deinem Vorschlag beschäftigt und nur teilweise erfolg gehabt. Hab folgenden Code eingebaut:

PHP-Code:

public class Client extends Thread{
    public Client() {
    }
    public static void main( String args[] ) {
        new Client().start();
    }    
    public void run() {
        try{
            Socket server = new Socket( "localhost", 3141 );
            InputStream in = server.getInputStream();
            OutputStream out = server.getOutputStream();
            int antwort=0;
            while(true){
             out.write(1);             
                antwort = in.read();
                if (antwort == 1)
                 System.out.println("Antwort vom Server ist: Ich lebe! :-)");
                else 
                 System.out.println("Keine Rückmeldung vom Server!!!!!");
                Thread.sleep(1000);
            }
        }catch(Exception w){
            System.out.println(w.getLocalizedMessage());
        }
        
    }
}

public class EchoServer extends Thread{
    public static void main( String args[] ) throws IOException {
        new EchoServer().start();
    }
    
    public void run() {
        try{
        ServerSocket server = new ServerSocket( 3141 );        
        while ( true ) {
            Socket client = server.accept();
            InputStream  in  = client.getInputStream();
            OutputStream out = client.getOutputStream();
            int antwort = in.read();
            out.write( antwort );
            Thread.sleep(100);
            client.close();
        }
        }catch (Exception e){
            System.out.println(e.getLocalizedMessage());
        }
    }
} 


Allerdings läuft dies höchstens einmal gut durch, danach ist schluss. Entweder Connection refused, oder meine Fehlermeldung oder socket write Error...

Was soll ich an dem Code verbessern?

Danke im voraus

[sparrow]

Also eins vorweg, wir bauen hier ja keinen reinen Echo-Server. Ansonsten könnten wir den Server einfach anpingen, aber wir wollen ja zusätzlich noch wissen ob die Application einwandfrei funktioniert.

Ich glaube das Problem liegt auf der Serverseite.
Deshalb meinte ich ja, du sollst jede Anfrage in einem extra Thread behandeln.

Ich gehe bei meinen Server-Programmen immer wie folgt vor:

Ich initialisiere eine Thread, ebenso wie du, in dem ich in einer while-schleife immer wieder folgedes ausführe:

PHP-Code:

    public void run() {
        int cnt = 0;
        try {
            servSocket = new ServerSocket(12816);
        } catch (IOException e) {
            System.out.println("Error!\nCan't open the socket!");
            System.out.println(e.getMessage());
            System.out.println("  -ABORTING-");
            System.exit(1);
        }
        while (!stopThread) {
            try {
                Socket socket = servSocket.accept();
                new ClientCon(socket, cnt).start();
                cnt++;
            } catch (IOException e1) {
                // TODO Auto-generated catch block
                // e1.printStackTrace();
                System.out.println(e1.getMessage());
            }
        }
        
    } 


Wie du sheist wird der Socket an eine neue Instanz einer Klasse namens ClientCon übergeben, zusammen mit einer hochzählenden Nummer. Die ist aber nur da, damit jeder Thread eine ID hat, find ich ganz gut, so kann ich sehen wie oft schon eine Verbindung aufgebaut wurde.

PHP-Code:

public class ClientCon extends Thread {
    
    Socket socket;
    int cnt;
    InputStream in;
    OutputStream out;
    
    public ClientCon(Socket socket, int cnt) {
        this.socket = socket;
        this.cnt = cnt;
    }
    
    public void run() {
        System.out.println("Server: Verbindung hergestellt: " + cnt);
        try {
            in = socket.getInputStream();
            out = socket.getOutputStream();
            StringBuffer buf = new StringBuffer();
            int c;
            while ((c = in.read()) != -1) {
                if ((char) c == '%') {
                    parser(buf);
                    buf = new StringBuffer();
                }

                buf.append((char) c);
            }
        } catch (IOException e) {
            System.out.println("Fehler beim anlegen der Verbindung füer: " + cnt);
        }
        System.out.println("Verbindung durch Client getrennt: " +cnt);
    } 


Das ist viel Code der überflüssig ist, aber er zeigt, wie der Socket in einem weiteren Thread weiterbehandelt wird.

--------------

Bei dir scheint das Problem zu sein, dass der Server ja einen Moment braucht um zu reagieren, in diesem Augenblick, plus die Zeit die der Server auch noch wartet (sleep(100)) ist der Server nicht zu erreichen.


Gruß
Sparrow

Danke für deine Hilfe Sparrow,

Das mit Anpingen vom Server gefällt mir schon, allerdings wenn wir damit nicht feststellen können ob der Server immer noch funktioniert, nutzt das ja nicht sehr viel.

was ist denn eigentlich parser(buf); Und der obere Abschnitt von deinem Code

PHP-Code:

public void run() { 
        int cnt = 0; 
        try { 
            servSocket = new ServerSocket(12816); 
        } catch (IOException e) { 
            System.out.println("Error!\nCan't open the socket!"); 
            System.out.println(e.getMessage()); 
            System.out.println("  -ABORTING-"); 
            System.exit(1); 
        } 
        while (!stopThread) { 
            try { 
                Socket socket = servSocket.accept(); 
                new ClientCon(socket, cnt).start(); 
                cnt++; 
            } catch (IOException e1) { 
                System.out.println(e1.getMessage()); 
            } 
        }          
    } 


soll ja zum Client oder zum Server gehören? Sorry für manche Fragen die dir vielleicht einfach erscheinen, bin aber relativ neu in dieser Welt.

[sparrow]

Sorry, das mit dem Parser kannst du vergessen.
Ich hatte eigentlich gedacht, ich hab alles rausgenommen was Programmspezifisch ist.
Hinter der Methode verbirgt sich eine einfache überprüfung, was der Client gesendet hat, und wie der Server darauf reagiert.

Alle Codeteile gehören zum Server.
Es geht hauptsächlich darum zu zeigen, dass mit dem eingehen eines neuen Sockets ein neuer Thread geöffnet wird.

Sehr gut ist das ganze Erklärt im Handbuch der Java-Programmierung.
Die HTML-Version kannst du kostenlos unter http://www.javabuch.de herunterladen.
Das Buch ist wirklich klasse, dort gibt es in Kapitel 45.3 die Erklärung wie man einen eigenen Webserver programmiert. Natürlich recht einfach gehalten.
Es geht auch weniger darum HTML-Seiten ausliefern zu können, aber dafür ist sehr gut beschrieben wie der ServerSocket lauscht und warum man die Verarbeitug in einen extra Thread leisten soll.
Überhaupt ist das Javabuch mein absoluter Favorit, und das Kapitel Netzwerkprogrammierung solltest du dir anschauen, es ist wirklich sehr gut beschrieben.

Gruß
Sparrow