import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Stack;
import java.util.StringTokenizer;
public class Client extends Thread {
// Verbindungsvariablen
final String user = "user";
final String pass = "pass";
public String host = "localhost";
int port = 21;
// PASV
int portNew;
String ipNew = "";
public Stack<String> commands = new Stack<String>();
boolean lastCommand = false;
// Sockets
Socket serverSocket;
Socket pasvSocket;
PrintWriter writeCommands;
BufferedReader fromServer;
PrintWriter writePasvCommands;
BufferedReader fromPasvServer;
// Baut die Verbindung auf
public void connect() throws IOException {
try {
serverSocket = new Socket(host, port);
System.out.println("Baue Verbindung auf ...");
fromServer = new BufferedReader(new InputStreamReader(
serverSocket.getInputStream()));
writeCommands = new PrintWriter(serverSocket.getOutputStream(),
true);
} catch (UnknownHostException e) {
System.out.println("Host unbekannt!");
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void USER() throws IOException {
writeCommands.print("USER " + user + "\n");
writeCommands.flush();
}
public void PASS() {
writeCommands.print("PASS " + pass +"\n");
writeCommands.flush();
}
public void NOOP() {
writeCommands.print("NOOP\n");
writeCommands.flush();
}
public void getStatus() {
Thread konsole = new Thread(new Konsole(this));
konsole.start();
}
// PASV anschalten
public void PASV() throws IOException, InterruptedException {
writeCommands.print("PASV\n");
writeCommands.flush();
getPasvCon();
}
public synchronized void getPasvCon() throws IOException, InterruptedException {
System.out.println("!!!!!!");
// Commands abholen
// IP Adresse holen
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;
try {
pasvSocket = new Socket(ipNew, portNew);
} 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()));
} 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();
}
}
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 {
PASV();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public Client() throws IOException {
}
public static void main(String[] args) throws IOException, InterruptedException {
Client test = new Client();
Thread client = new Thread(test);
client.start();
Thread.sleep(300);
Thread konsole = new Thread(new Konsole(test));
konsole.setDaemon(true);
konsole.start();
Disrupter disrupt = new Disrupter(test);
disrupt.start();
}
}
