FTP 协议(rfc939) 简单的实验(in Java)

Java代码:
FTPClient.java
package org;

import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.Writer;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.StringTokenizer;

public class FtpClient ...{

    public static final int DEFAULT_PORT = 1968;

    private static int print(Reader in) throws IOException ...{
        int c;
        int prev = 0, current = 0;
        int result = 0;
        int count = 0, k1 = 0, k2 = 0, k3 = 0;
        while (prev != ' ' && current != ' ') ...{
            prev = current;
            c = in.read();
            current = c;
            if (count < 3) ...{
                switch (count) ...{
                case 0:
                    k1 = current - '0';
                    break;
                case 1:
                    k2 = current - '0';
                    break;
                case 2:
                    k3 = current - '0';
                    break;
                }
            }
            count++;
            System.out.write(current);
        }
        result = k1 * 100 + k2 * 10 + k3;
        return result;
    }

    private static void printData(Reader in) throws IOException ...{
        int c = 0;

        while ((c = in.read()) != -1) ...{
            System.out.print((char) c);
        }
        System.out.println();
    }

    private static void inputCommand(Writer out, String command) throws IOException ...{
        out.write(command);
        out.write(" \r\n");
        out.flush();
    }

    public static void main(String[] args) ...{
        String hostname = "192.168.1.101";

        Socket commandConn = null;

        Socket dataConn = null;

        try ...{

            commandConn = new Socket(hostname, DEFAULT_PORT);

            Writer out = new OutputStreamWriter(commandConn.getOutputStream(),
                    "8859_1");

            InputStream raw = commandConn.getInputStream();
            BufferedInputStream buffer = new BufferedInputStream(raw);
            InputStreamReader commandIn = new InputStreamReader(buffer,
                    "8859_1");

            System.out.println("login in");
            int i = print(commandIn);// 220

            inputCommand(out, "USER winters");
            System.out.println("USER winters");
            i = print(commandIn);// 331

            inputCommand(out, "PASS 123456");
            System.out.println("PASS 123456");
            i = print(commandIn);// 230

            inputCommand(out, "SYST");
            System.out.println("SYST");
            i = print(commandIn);// 215

            inputCommand(out, "PWD");
            System.out.println("PWD");
            i = print(commandIn);// 257

            inputCommand(out, "TYPE A");
            System.out.println("TYPE A");
            i = print(commandIn);// 200

            inputCommand(out, "PASV");
            System.out.println("PASV");
           
            int port = getPortNumber(commandIn);
            dataConn = new Socket(hostname, port);
            BufferedInputStream dataBuffer = new BufferedInputStream(dataConn
                    .getInputStream());
            InputStreamReader dataIn = new InputStreamReader(dataBuffer,
                    "8859_1");

            System.out.println("Connected " + hostname + " on " + port);

            /** *//**
             * LIST
             */

            inputCommand(out, "LIST");
            System.out.println("LIST");
            System.out.print("commandIn : ");
            i = print(commandIn);// 150

            System.out.print("dataIn : ");
            printData(dataIn);// abc

            i = print(commandIn);// 226

            /** *//** ************************************* */

            inputCommand(out, "PASV");
            System.out.println("PASV");
            port = getPortNumber(commandIn);

            dataConn = new Socket(hostname, port);
            dataBuffer = new BufferedInputStream(dataConn.getInputStream());
            dataIn = new InputStreamReader(dataBuffer, "8859_1");

            System.out.println("Connected " + hostname + " on " + port);

            /** *//**
             * RETR
             */

            inputCommand(out, "RETR 1.txt");
            System.out.println("RETR 1.txt");

            System.out.print("commandIn : ");
            i = print(commandIn);// 150

            System.out.print("dataIn : ");
            printData(dataIn);// abc

            i = print(commandIn);// 226

        } catch (IOException e) ...{
            System.err.println(e);
        } finally ...{
            try ...{
                if (commandConn != null)
                    commandConn.close();
                if (dataConn != null)
                    dataConn.close();
            } catch (IOException e) ...{
                System.err.println(e);
            }
        }

    }

    private static int getPortNumber(InputStreamReader in) throws IOException ...{
        int c;
        int prev = 0, current = 0;
        boolean start = false;
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        while (prev != ' ' && current != ' ') ...{
            prev = current;
            c = in.read();
            current = c;

            if (prev == '(')
                start = true;
            if (current == ')')
                start = false;
            if (start)
                out.write(current);
            // System.out.println("==" + out.toString() + "==");
            System.out.write(current);
        }

        String ipWithPort = out.toString();
        StringTokenizer stk = new StringTokenizer(ipWithPort, ",");
        List list = new ArrayList();
        while (stk.hasMoreTokens()) ...{
            list.add(stk.nextToken());
        }
        String[] str = (String[]) list.toArray(new String[list.size()]);
        int a = Integer.parseInt(str[4]);
        int b = Integer.parseInt(str[5]);
        int port = a * 256 + b;
        // System.out.println("debug: port == " + port);
        return port;
    }
}

本文来自CSDN博客，转载请标明出处：http://blog.csdn.net/starshus/archive/2007/01/01/1471724.aspx