Probleme bei senden eines Strings übers Netzwerk

[PaP]

Hallo zusammen,

ich habe mich vor einigen Tagen schon einmal wegen eines Problems mit dem Senden eines Strings über das Netzwerk zu Wort gemeldet. Ich habe heute angefangen, neue Dinge in mein kleines primitives Chat Programm einzubauen und habe nun ein Problem.

Ich habe einen Client und einen Server und möchte vom Client aus eine Anweisung an den Server geben, den Befehl "dir" auszuführen und das was die Konsole anzeigt wieder an den Client zurück zu schicken.


Das ist der Teil des Programms um den es geht

  public void run()
  {
  try
  {
   Scanner eingabe = new Scanner(System.in);
   
   String connect[] = Configuration.Hosts();
   String portString = connect[2];
   String hostString = connect[0];
   String sportString = connect[1];
   int port = Integer.parseInt(portString);
   int sport = Integer.parseInt(sportString);
   
   ServerSocket serversocket = new ServerSocket(port);
   Socket socket = serversocket.accept();
   System.out.println("PatChatClient hat sich angemeldet");
   BufferedReader br = new BufferedReader(
   new InputStreamReader(socket.getInputStream()));
   String body;

   do {
        body = br.readLine();
        System.out.println(body);
        if(body.equals("dir"))
        {
          Socket ssocket = new Socket(hostString, sport);
          PrintWriter pw = new PrintWriter(ssocket.getOutputStream());
          Process p = Runtime.getRuntime().exec( "cmd /c dir" );
          BufferedReader in = new BufferedReader(
          new InputStreamReader(p.getInputStream()) );
          for ( String s; (s = in.readLine()) != null; )
          {
          System.out.println(s);
          pw.println("test");
          pw.flush();
          }

        }
      }while (body != null);

   socket.close();
  }
  catch(IOException e)
  {
   System.out.println("PatChatClient hat die Verbindung getrennt");
   System.err.println(e.toString());
  }
  }
}

Der dir Befehl wird ohne Probleme ausgeführt und die Ausgabe wird in dem String "s" gespeichert. Damit ich sicher gehen kann, dass der Befehl ausgeführt wurde, habe ich den String im Serverfenster ausgeben lassen, was auch ohne Probleme klappt. Jedoch möchte ich den String "s" wieder zurück an den Client schicken, aber das klappt irgendwie nicht.

Würde mich freuen wenn mir jemand erklären könnte was ich falsch gemacht habe.

Ich freue mich schon auf Antworten

Mit freundlichen Grüßen

PaP

 

[Michael...]

Warum öffnest Du in der while Schleife ein neues Socket (ssocket)? Die Ausgabe des Prozesses soll doch sicher über die bereits exisitierende Socketverbindung übertragen werden.
Würd sagen hier fehlt's noch ein bisschen am Verständis. Fang doch einfach mal mit einem Client und einem Server an, der das empfangene Wort einfach wieder an den Client zurückschickt.

 

[PaP]

Ich verwende verschiedene Ports. Über Port 1000 sendet der Client die Daten an den Server und über Port 1001 schickt der Server die Daten an den Client. Im Prinzip habe ich nicht wirklich einen Client und einen Server sonder habe Client und Server in einem und starte das Programm 2 mal.

Hier hast du das vollständige Programm

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

public class Chatter {
public static class Thread1 extends Thread
{
  public void run()
  {
   try
   {
    BufferedReader input = new BufferedReader(new InputStreamReader(System.in));
    Scanner eingabe = new Scanner(System.in);
    String body;
    
    String connect[] = Configuration.Hosts();
    String hostString = connect[0];
    String portString = connect[1];

    int port = Integer.parseInt(portString);
    System.out.print("Connecting to "+ hostString);
    
    
    try {
        sleep(3000);
      } catch (InterruptedException e) {
        throw new RuntimeException(e);
      }

      System.out.print(".");
      
      
    try {
        sleep(3000);
      } catch (InterruptedException e) {
        throw new RuntimeException(e);
      }

      System.out.print(".");
      
    try {
        sleep(3000);
      } catch (InterruptedException e) {
        throw new RuntimeException(e);
      }

      System.out.println(".");
      
    try {
        sleep(1000);
      } catch (InterruptedException e) {
        throw new RuntimeException(e);
      }
      

    Socket socket = new Socket(hostString, port);
    PrintWriter pw = new PrintWriter(socket.getOutputStream());

    System.out.println("Erfolgreich mit Chatpartner verbunden");

    do
    {
     System.out.print("");
     body = input.readLine();
     pw.println(body);
     pw.flush();
    }while(body != null);

    socket.close();
   }
   catch(IOException e)
   {
     System.out.println("Es ist ein Fehler aufgetreten!");
     System.err.println(e.toString());
   }
  }
}
public static class Thread2 extends Thread
{
  public void run()
  {
  try
  {
   Scanner eingabe = new Scanner(System.in);
   
   String connect[] = Configuration.Hosts();
   String portString = connect[2];
   String hostString = connect[0];
   String sportString = connect[1];
   int port = Integer.parseInt(portString);
   int sport = Integer.parseInt(sportString);
   
   ServerSocket serversocket = new ServerSocket(port);
   Socket socket = serversocket.accept();
   System.out.println("PatChatClient hat sich angemeldet");
   BufferedReader br = new BufferedReader(
   new InputStreamReader(socket.getInputStream()));
   String body;

   do {
        body = br.readLine();
        System.out.println(body);
        if(body.equals("dir"))
        {
          Socket ssocket = new Socket(hostString, sport);
          PrintWriter pw = new PrintWriter(ssocket.getOutputStream());
          Process p = Runtime.getRuntime().exec( "cmd /c dir" );
          BufferedReader in = new BufferedReader(
          new InputStreamReader(p.getInputStream()) );
          for ( String s; (s = in.readLine()) != null; )
          {
          System.out.println(s);
          pw.println("test");
          pw.flush();
          }

        }
      }while (body != null);

   socket.close();
  }
  catch(IOException e)
  {
   System.out.println("PatChatClient hat die Verbindung getrennt");
   System.err.println(e.toString());
  }
  }
}


public static class Configuration
{
  public static String[] Hosts()
  {
    String connect[] = new String[3];
  
    try {
    BufferedReader in = new BufferedReader(new FileReader("config.txt"));
    String hostString = null;
    hostString = in.readLine();
    String portString = null;
    portString = in.readLine();
    String sportString = null;
    sportString = in.readLine();

    //String connect[] = new String[2];

    connect[0] = hostString;
    connect[1] = portString;
    connect[2] = sportString;
    return connect;


  } catch (IOException e) {
    e.printStackTrace();
  }
   return connect;
  }

}



public static void main(String[] args)
{
 new Thread2().start();
 new Thread1().start();
}
}

Die Ports und den Host bezieht er sich aus der config.txt

127.0.0.1
1000
1001

Nicht wundern wenn einiges etwas verwirrend ist und in deinen Augen wenig Sinn ergibt. Ich habe Java erst vor ca 8 Wochen über die Schule angefangen zu lernen und habe zuvor noch nie programmiert

 

[Michael...]

Ich verwende verschiedene Ports. Über Port 1000 sendet der Client die Daten an den Server und über Port 1001 schickt der Server die Daten an den Client.

Das halte ich für nicht sinnvoll. Warum nicht eine Verbindung für die Kommunikation nutzen?
off topic: Nur als Hinweis für evtl. zukünftige Produktiveinsätze Deine gewählten Ports fallen in den Bereich der standardisierten Ports - lieber Ports im höherstelligen Bereich benutzen
Liste der standardisierten Ports ? Wikipedia

Abgesehen davon bleibt immer noch die sinnhaftigkeit des

ssocket

es wird (vom Server?) eine Verbindung erstellt, an die der Inhalt der Prozessausgabe geschickt wird. Aber hängt da überhaupt jemand dran? Besitzt der Client ein ServerSocket welches auf diesem Port Verbindungen annehmen kann?

 

[PaP]

Das mit den Ports werde ich mir merken.


Diese Programm kann sowohl Senden als auch Empfangen. Da ich das ganze nur über den localhost teste, verwende ich für unterschiedliche Ports für Empfang und Versand der Daten, ansonsten sich das Programm ja mit sich selbst verbinden und da nur eine Verbindung zugelassen wird, wäre das sinnlos.

Aus diesem Grund nutzt das Programm1 diese Portvergabe

127.0.0.1 <- Host
1000 <- Port des anderen Programm
1001 <- eigener Port

und das Programm2 diese

127.0.0.1
1001
1000

Diese Daten werden von der Methode Hosts() der Klasse Configuration aus einer Textdatei gelesen und in einem Array an die Servermethode bzw Client Methode übermittelt (Methode run() der Klassen Thread1 und Thread2). Was mir gerade einfällt... Der Programm öffnet einen Socket zum senden von Daten an das andere Programm und nutzt Dabei zB Port 1000. Der Part, wo die Ausgabe des Befehls Dir ausgegeb werden soll öffnet jedoch ebenfalls einen Socket mit Port 1000. Vielleich blockieren die sich. Ich probier das eben aus



EDIT#1 Jo lag daran