자바의 수동 ftp - 왜 스트림이 준비되지 않았습니까?

Question

또 다른 자바 문제 ... 패시브 모드를 통해 서버에 연결해야하는 클라이언트가 있습니다. 잘 작동하는 것처럼 보입니다. IP 주소와 포트를 얻고 passivesocket이 준비가되었다고 말합니다.

하지만 passivesocket.getInputStream 전혀 준비가되지 않습니다 - 그래서 내가 읽을 수 없으며 LIST 응답을 가져 오지 않습니다. 왜, 어떤 제안을 알아낼 수 없습니까?

public synchronized void getPasvCon() throws IOException, InterruptedException { 

     // Commands abholen 


     // IP Adresse holen 
Thread.sleep(200); 
     String pasv = commands.lastElement(); 
     String ipAndPort = pasv.substring(pasv.indexOf("(") + 1, 
       pasv.indexOf(")")); 

     StringTokenizer getIp = new StringTokenizer(ipAndPort); 

     // holt die IP 
     String ipNew = ""; // IP für den neuen Socket 
     for (int i = 0; i < 4; i++) { 
      if (i < 3) { 
       ipNew += (getIp.nextToken(",") + "."); 
      } else { 
       ipNew += (getIp.nextToken(",")); 

      } 
     } 


     Integer portTemp1 = new Integer(getIp.nextToken(",")); 
     Integer portTemp2 = new Integer (getIp.nextToken(",")); 
     portNew = (portTemp1 << 8)+ portTemp2; 

System.out.println(">>>>> " + ipNew + ":" + portNew);  


     try { 

      pasvSocket = new Socket(ipNew, portNew); 
      System.out.println("Socket verbunden: "+ pasvSocket.isConnected()); 

     } catch (UnknownHostException e) { 
      System.out.println("Host unbekannt"); 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 

     try { 
      fromPasvServer = new BufferedReader(new InputStreamReader(
        pasvSocket.getInputStream())); 
      Thread.sleep(2000); 
      System.out.println("Streams bereit: " + fromPasvServer.ready() + " | "); 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
     try { 
      writePasvCommands = new PrintWriter(pasvSocket.getOutputStream(), 
        true); 

     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 


Thread.sleep(3000); 
     Thread pasvKonsole = new Thread(new PasvKonsole(this)); 

     pasvKonsole.start(); 

    } 

    public void LIST() throws IOException { 
    writeCommands.print("LIST\n"); 
    writeCommands.flush(); 

    } 


    public void run() { 
     try { 
      connect(); 

    //  getStatus(); 

     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
     try { 
      USER(); 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
     PASS(); 


     try { 
      Thread.sleep(2000); 
      PASV(); 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } catch (InterruptedException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 


import java.io.IOException; 


public class PasvKonsole extends Thread { 
    Client client; 
    public PasvKonsole(Client client) { 
     this.client = client; 
    } 

    public void run() { 
     System.out.println("========= PasvKonsole started"); 

    while(true) { 

     try { 

      String lineP = client.fromPasvServer.readLine(); 
       System.out.println("***" + lineP); 
       System.out.println("Ich bin da und tue auch was"); 
     } catch (IOException e) {} 

    }  
    } 
} 

Answer 1

Thread.Sleep이 추가되었습니다.