BufferedReader br=new BufferedReader(new InputStreamReader(Socket.getInputStream());
BufferedWriter  bw=new BufferedWriter(new OutputStreamWriter(Socket.getOutputStream());

br.close();//close object read
bw.close();//close object write
socket.close();//close object socket

import java.net.*;
import java.io.*;
public class FTPClient
{
    Socket socket;//object of socket
    BufferedReader br;//object of read
    BufferedWriter bw;//object of write
    public static void main(String args[])throws IOException
    {
        FTPClient ftp =new FTPClient("127.0.0.1");
        ftp.getReply();
        ftp.sendCommand("user "+"anonymous");
        ftp.getReply();
        ftp.sendCommand("pass"+"anonymous");
        ftp.getReply();
        String com="";
        while (!com.equalsIgnoreCase("quit"))
        {
            System.out.println("enter your commands ,or enter Quit to exit");
            BufferedReader keyboard =new BufferedReader(new InputStreamReader(System.in));
            com=keyboard.readLine();
            ftp.sendCommand(com);
            ftp.getReply();
            System.out.println("==================");
            
        }
        ftp.Close();
    }
    public FTPClient(String address)
    {
        try{
            socket =new Socket(address,21);
            System.out.println("connection is established");
            br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
            bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        }
        catch(Exception e)
        {
            System.out.println(e.toString());
            
        }
        }
        public void Close() throws IOException
        {
            br.close();
            bw.close();
            socket.close();
            
                
        }
        public void getReply()throws IOException
        {
            int ch=0;
            String line="";
            while(br.ready())
            {
                line=br.readLine();
                System.out.println(line);
                
            }
        }
        public void sendCommand (String command )throws IOException
        {
            bw.write(command);
            bw.newLine();
            bw.flush();
        }
        
    }

while(br.ready())
{
line=br.readLine();
System.out.println(line);
                
}

While ((line=br.readLine())!=null)
{
System.out.println(line);
}

while (ch!=1)    {
            if(br.ready())
            {
            ch=br.read();
            System.out.println((char)ch);
            }
            else
            
            if(ch==10 &!br.ready())
            {
            try{
            Thread.sleep(3000);//can be change time "this 3 second "
            }
            catch (InterruptedException e){
            }
            if(!br.ready())
            {
            System.out.println("break");
            break;
            }
            else
            System.out.println("reconnected.....");
            }
            }

import java.net.*;
import java.io.*;
public class FTPClient
{
    Socket socket;//object of socket
    BufferedReader br;//object of read
    BufferedWriter bw;//object of write
    public static void main(String args[])throws IOException
    {
        FTPClient ftp =new FTPClient("127.0.0.1");
        ftp.getReply();
        ftp.sendCommand("user "+"anonymous");
        ftp.getReply();
        ftp.sendCommand("pass"+"anonymous");
        ftp.getReply();
        String com="";
        while (!com.equalsIgnoreCase("quit"))
        {
            System.out.println("enter your commands ,or enter Quit to exit");
            BufferedReader keyboard =new BufferedReader(new InputStreamReader(System.in));
            com=keyboard.readLine();
            ftp.sendCommand(com);
            ftp.getReply();
            System.out.println("==================");
            
        }
        ftp.Close();
    }
    public FTPClient(String address)
    {
        try{
            socket =new Socket(address,21);
            System.out.println("connection is established");
            br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
            bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        }
        catch(Exception e)
        {
            System.out.println(e.toString());
            
        }
        }
        public void Close() throws IOException
        {
            br.close();
            bw.close();
            socket.close();
            
                
        }
        public void getReply()throws IOException
        {
            int ch=0;
            String line="";
            /*while(br.ready())
            {
                line=br.readLine();
                System.out.println(line);
                
            }*/
                while (ch!=1)    {
            if(br.ready())
            {
            ch=br.read();
            System.out.println((char)ch);
            }
            else
            
            if(ch==10 &!br.ready())
            {
            try{
            Thread.sleep(300);
            }
            catch (InterruptedException e){
            }
            if(!br.ready())
            {
            System.out.println("break");
            break;
            }
            else
            System.out.println("reconnected.....");
            }
            }
        }
        public void sendCommand (String command )throws IOException
        {
            bw.write(command);
            bw.newLine();
            bw.flush();
        }
        
    }