import org.apache.commons.net.telnet.*;   
  
import java.io.*;   
import java.net.SocketException;   
import java.util.StringTokenizer;   
  
public class TmhTelnet implements TelnetNotificationHandler {   
  
    private static TelnetClient tc = null;   
    private static InputStream instr;   
    private static PrintWriter out;
    public static void main(String args[]) throws IOException{ 
        TmhTelnet telnet = new TmhTelnet("127.0.0.1",23);  
        ReadInformation readInfo = new ReadInformation("command.txt",instr,out);
        ReadFileThread rfthread = new ReadFileThread(readInfo);
        ReadTelnetThead rtthread = new ReadTelnetThead(readInfo);
        Thread rtt = new Thread(rtthread);
        rtt.start();
        Thread rft = new Thread(rfthread);
        rft.start();
        System.out.println("return");
        
    }   
    public TmhTelnet(String host, int port) {   
        intconnect(host,port);
    }   
  
    private boolean intconnect(String host, int port) {   
        try {   
            tc = new TelnetClient();   
            TerminalTypeOptionHandler ttopt = new TerminalTypeOptionHandler(   
                    "VT100", false, false, true, false);   
            EchoOptionHandler echoopt = new EchoOptionHandler(true, false,   
                    true, false);   
            SuppressGAOptionHandler gaopt = new SuppressGAOptionHandler(true,   
                    true, true, true);   
  
            tc.addOptionHandler(ttopt);   
            tc.addOptionHandler(echoopt);   
            tc.addOptionHandler(gaopt); 
            tc.connect(host, port);   
            instr = tc.getInputStream();  
            out = new PrintWriter(tc.getOutputStream());   
            return true;   
        } catch (Exception e) {   
            e.printStackTrace();   
            try {   
                tc.disconnect();   
            } catch (IOException e1) {   
                // TODO Auto-generated catch block   
                e1.printStackTrace();   
            }   
            return false;   
        }          
    }   
       
    public void receivedNegotiation(int negotiation_code, int option_code) {   
        String command = null;   
        if (negotiation_code == TelnetNotificationHandler.RECEIVED_DO) {   
            command = "DO";   
        } else if (negotiation_code == TelnetNotificationHandler.RECEIVED_DONT) {   
            command = "DONT";   
        } else if (negotiation_code == TelnetNotificationHandler.RECEIVED_WILL) {   
            command = "WILL";   
        } else if (negotiation_code == TelnetNotificationHandler.RECEIVED_WONT) {   
            command = "WONT";   
        }   
        System.out.println("Received " + command + " for option code "  
                + option_code);   
    }   
} 

public class ReadFileThread implements Runnable {
    private ReadInformation rf = null;
    public ReadFileThread(ReadInformation rf){
        this.rf = rf;
        
    }

    public void run() {
        while(true){
            rf.readFile();
        }
        
    }
}

public class ReadTelnetThead implements Runnable{
    private ReadInformation rf = null;
    public ReadTelnetThead(ReadInformation rf){
        this.rf = rf;
        
    }

    public void run() {
        while(true){
            rf.readTelnet();
        }
        
    }
    

}