当前位置: 首页 >> 程序设计 >> Java >> FTP协议Java实现
 

FTP协议Java实现

作者：      来源：http://blog.csdn.net/starshus     发表时间：2007-01-01     浏览次数：      字号：大  中  小

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;
    }
}

责任编辑 webmaster

 

相关链接

  • 开源的SIP协议库PJSIP
  • 开源协议比较(BSD,Apache,GPL...
  • TCP 协议中的名词解释
  • BT和eMule下载协议的比较和分析
  • FTP命令大全
  • TCP协议栈中的mss
  • ESMTP协议如何进行身份验证
  • Linux网络编程:加密通讯协议S...

    • 发表评论　 打印本文　 推荐本文　 加入收藏　 返回顶部　 关闭窗口
     
     
    最新文章
     

    精华文章  红黑树Java简单实现
    普通文章  算法—用栈实现递归
    精华文章  Google Android开发入门
    普通文章  Log4J 编程使用心得
    精华文章  Java 设计架构
    普通文章  Java对象池技术的原理及其实现
    普通文章  Java语言运算符和流程
    精华文章  Java: 在n 张扑克牌中找出顺子
    精华文章  Java范型浅析
    普通文章  【Java开源J2EE框架】 Spring Framework
    精华文章  Java EE 技术路线图
    普通文章  JAVA中的细节-算法篇(1)
    普通文章  Java 的Hashtable和HashMap
    普通文章  测试你的Java段位
    精华文章  p-unit: 开源性能测试工具

    推荐文章
     
    精华文章  红黑树Java简单实现
    精华文章  Google Android开发入门
    精华文章  Java 设计架构
    精华文章  Java: 在n 张扑克牌中找出顺子
    精华文章  Java范型浅析
    精华文章  Java EE 技术路线图
    精华文章  p-unit: 开源性能测试工具
    精华文章  菲波那切数列的JAVA算法
    精华文章  HTTP文件下载Java编程
    精华文章  Java 同步机制浅谈
    精华文章  Java写的屏幕放大镜
    精华文章  Java数据类型与sql类型基本映射
    精华文章  股票利润率计算器源代码
    精华文章  在Ubuntu搭建java开发环境
    精华文章  JAVA中浅复制与深复制
     
      热点文章
     

    精华文章  JAVA程序员面试宝典
    精华文章  Java jdbc数据库连接池...
    精华文章  Lucene全文检索应用示例...
    普通文章  SIP Servlet 概述及范例
    普通文章  Java中static的作用
    普通文章  J2EE开发之Eclipse集成...
    精华文章  Spring/Hibernate/Stru...
    精华文章  Java计时器编程
    普通文章  Eclipse 插件汇总
    精华文章  JSP+Servlet+JavaBean实...
    普通文章  冒泡排序算法的JAVA实现
    普通文章  Java华为面试题
    普通文章  简析JAVA的XML编程
    普通文章  Java文件操作实例
    普通文章  Java替换字符串的源代码

     
     
    评论更多>>
     
     
     
    发表
     
    姓名： QQ：
    性别： 男 女 MSN：
    E-mail： 主页：
    评分： 1 2 3 4 5
    评论内容：
    验证码：
      
  • 请遵守《互联网电子公告服务管理规定》及中华人民共和国其他各项有关法律法规。
  • 严禁发表危害国家安全、损害国家利益、破坏民族团结、破坏国家宗教政策、破坏社会稳定、侮辱、诽谤、教唆、淫秽等内容的评论 。
  • 用户需对自己在使用本站服务过程中的行为承担法律责任（直接或间接导致的）。
  • 本站管理员有权保留或删除评论内容。
  • 评论内容只代表网友个人观点，与本网站立场无关。
    •  
    Power by phpcms 2.4