当前位置:首页 > 开发 > 编程语言 > 编程 > 正文

FTP帮助类

发表于: 2015-03-26   作者:caixu52110   来源:转载   浏览次数:
ftp
摘要: import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; im
import java.io.File;  
import java.io.FileInputStream;  
import java.io.FileNotFoundException;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
  
import org.apache.commons.net.ftp.FTP;  
import org.apache.commons.net.ftp.FTPClient;  
import org.apache.commons.net.ftp.FTPClientConfig;  
import org.apache.commons.net.ftp.FTPFile;  
import org.apache.commons.net.ftp.FTPReply;  
  
public class ftpTest {  
    /** 
     * 获得连接-FTP方式 
     * @param hostname FTP服务器地址 
     * @param port FTP服务器端口 
     * @param username FTP登录用户名 
     * @param password FTP登录密码 
     * @return FTPClient 
     */  
    public FTPClient getConnectionFTP(String hostName, int port, String userName, String passWord) {  
        //创建FTPClient对象  
        FTPClient ftp = new FTPClient();  
        try {  
            //连接FTP服务器  
            ftp.connect(hostName, port);  
            //下面三行代码必须要,而且不能改变编码格式,否则不能正确下载中文文件  
            ftp.setControlEncoding("GBK");  
            FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);  
            conf.setServerLanguageCode("zh");  
            //登录ftp  
            ftp.login(userName, passWord);  
            if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {  
                ftp.disconnect();  
                System.out.println("连接服务器失败");  
            }  
            System.out.println("登陆服务器成功");  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
        return ftp;  
    }  
      
    /** 
     * 关闭连接-FTP方式 
     * @param ftp FTPClient对象 
     * @return boolean 
     */  
    public boolean closeFTP(FTPClient ftp) {  
        if (ftp.isConnected()) {  
            try {  
                ftp.disconnect();  
                System.out.println("ftp已经关闭");  
                return true;  
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }  
        return false;  
    }  
      
    /** 
     * 上传文件-FTP方式 
     * @param ftp FTPClient对象 
     * @param path FTP服务器上传地址 
     * @param filename 本地文件路径 
     * @param inputStream 输入流 
     * @return boolean 
     */  
    public boolean uploadFile(FTPClient ftp, String path, String fileName, InputStream inputStream) {  
        boolean success = false;  
        try {  
            ftp.changeWorkingDirectory(path);//转移到指定FTP服务器目录  
            FTPFile[] fs = ftp.listFiles();//得到目录的相应文件列表  
            fileName = ftpTest.changeName(fileName, fs);  
            fileName = new String(fileName.getBytes("GBK"),"ISO-8859-1");  
            path = new String(path.getBytes("GBK"), "ISO-8859-1");  
            //转到指定上传目录  
            ftp.changeWorkingDirectory(path);  
            //将上传文件存储到指定目录  
            ftp.setFileType(FTP.BINARY_FILE_TYPE);  
            //如果缺省该句 传输txt正常 但图片和其他格式的文件传输出现乱码  
            ftp.storeFile(fileName, inputStream);  
            //关闭输入流  
            inputStream.close();  
            //退出ftp  
            ftp.logout();  
            //表示上传成功  
            success = true;  
            System.out.println("上传成功。。。。。。");  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
        return success;  
    }  
  
    /** 
     * 删除文件-FTP方式 
     * @param ftp FTPClient对象 
     * @param path FTP服务器上传地址 
     * @param filename FTP服务器上要删除的文件名 
     * @return 
     */  
    public boolean deleteFile(FTPClient ftp, String path, String fileName) {  
        boolean success = false;  
        try {  
            ftp.changeWorkingDirectory(path);//转移到指定FTP服务器目录  
            fileName = new String(fileName.getBytes("GBK"), "ISO-8859-1");  
            path = new String(path.getBytes("GBK"), "ISO-8859-1");  
            ftp.deleteFile(fileName);  
            ftp.logout();  
            success = true;  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
        return success;  
    }  
  
    /** 
     * 上传文件-FTP方式 
     * @param ftp FTPClient对象 
     * @param path FTP服务器上传地址 
     * @param fileName 本地文件路径 
     * @param localPath 本里存储路径 
     * @return boolean 
     */  
    public boolean downFile(FTPClient ftp, String path, String fileName, String localPath) {  
        boolean success = false;  
        try {  
            ftp.changeWorkingDirectory(path);//转移到FTP服务器目录  
            FTPFile[] fs = ftp.listFiles(); //得到目录的相应文件列表  
            for (FTPFile ff : fs) {  
                if (ff.getName().equals(fileName)) {  
                    File localFile = new File(localPath + "\\" + ff.getName());  
                    OutputStream outputStream = new FileOutputStream(localFile);  
                    //将文件保存到输出流outputStream中  
                    ftp.retrieveFile(new String(ff.getName().getBytes("GBK"), "ISO-8859-1"), outputStream);  
                    outputStream.flush();  
                    outputStream.close();  
                    System.out.println("下载成功");  
                }  
            }  
            ftp.logout();  
            success = true;  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
        return success;  
    }  
      
    /** 
     * 判断是否有重名文件 
     * @param fileName 
     * @param fs 
     * @return 
     */  
    public static boolean isFileExist(String fileName, FTPFile[] fs) {  
        for (int i = 0; i < fs.length; i++) {  
            FTPFile ff = fs[i];  
            if (ff.getName().equals(fileName)) {  
                return true; //如果存在返回 正确信号  
            }  
        }  
        return false; //如果不存在返回错误信号  
    }  
  
    /** 
     * 根据重名判断的结果 生成新的文件的名称 
     * @param fileName 
     * @param fs 
     * @return 
     */  
    public static String changeName(String fileName, FTPFile[] fs) {  
        int n = 0;  
//      fileName = fileName.append(fileName);  
        while (isFileExist(fileName.toString(), fs)) {  
            n++;  
            String a = "[" + n + "]";  
            int b = fileName.lastIndexOf(".");//最后一出现小数点的位置  
            int c = fileName.lastIndexOf("[");//最后一次"["出现的位置  
            if (c < 0) {  
                c = b;  
            }  
            StringBuffer name = new StringBuffer(fileName.substring(0, c));//文件的名字  
            StringBuffer suffix = new StringBuffer(fileName.substring(b + 1));//后缀的名称  
            fileName = name.append(a) + "." + suffix;  
        }  
        return fileName.toString();  
    }  
  
    /** 
     *  
     * @param args 
     *  
     * @throws FileNotFoundException 
     *  
     * 测试程序 
     *  
     */  
    public static void main(String[] args) throws FileNotFoundException {  
  
        String path = "/home1/ftproot/textftp/test/";  
        File f1 = new File("d:\\a.txt");  
        String filename = f1.getName();  
        System.out.println(filename);  
        //InputStream input = new FileInputStream(f1);  
        //ftpTest a = new ftpTest();  
        //a.uploadFile("172.25.5.193", 21, "shiyanming", "123", path, filename, input);  
        /* 
         * String path ="D:\\ftpindex\\"; File f2 = new 
         * File("D:\\ftpindex\\old.txt"); String filename2= f2.getName(); 
         * System.out.println(filename2); ftpTest a = new 
         * ftpTest(); a.downFile("172.25.5.193", 21, "shi", "123", path, 
         * filename2, "C:\\"); 
         */  
        ftpTest a = new ftpTest();  
        InputStream input = new FileInputStream(f1);  
//      a.uploadFile("218.108.250.205", 21, "hwyhftp", "!#hwyhftp", path, filename, input);  
        //a.deleteFile("218.108.250.205", 21, "hwyhftp", "!#hwyhftp", path, filename);  
//      a.downFile("218.108.250.205", 21, "hwyhftp", "!#hwyhftp", path, "欢[2].txt");  
        FTPClient ftp = a.getConnectionFTP("111.222.333.444", 21, "testU", "testP");  
//      a.deleteFile(ftp, path, "a[2].txt");  
        a.uploadFile(ftp, path, filename, input);  
        a.closeFTP(ftp);  
    }  
}  

 

FTP异常信息 写道
java.io.IOException: Host attempting data connection 172.17.209.254 is not same as server 172.17.205.250

    ftp的工作原理 

       ftp要用到两个tcp连接即要使用两个端口 
       一个是命令链路:用来传递命令 
       一个是数据链路:用来上传下载数据 

       连接ftp server时有active和passive两种模式 
       通常使用主动模式可完成上传下载 
    主动模式工作原理  
        客户端使用命令链路主动告诉服务端:我打开了XX端口,你来连我吧 
     被动模式工作原理  
        跟主动模式相反,服务端告诉客户端:我打开了XX端口,你来连我吧 

    解决方法:
写道
remoteverification
This parameter allows to enable/disable remote host connections verification. It should help when getting "Host attempting data connection ip address is not same as server" issue. Disable verification with remoteverification="false". Default is value is "true".
 
ftpClient.setRemoteVerificationEnabled(false);
 

FTP帮助类

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
SQLiteOpenHelper是SQLiteDatabse的一个帮助类,用来管理数据的创建和版本更新。一般的用法是定义一
SQLiteOpenHelper是SQLiteDatabse的一个帮助类,用来管理数据的创建和版本更新。一般的用法是定义一
一、前言 最近工作比较忙,与此同时自己也在业余时间开发一个电子商务网站。虽然每天都很累,但感觉
近日突发奇想,封装一个Excel的帮助类,好让日后做一些Excel操作时方便一点,至少导入导出会方便点
一个简单的ORM制作大概需要以下几个类: SQL执行类 CURD操作类 其他酱油类 先从SQL执行类说起,可能
之前我一直都是在博客园中查看各位高手的博文,确实学到了不少知识,不过比较少写博客,现在就把我
在ASP.NET MVC框架中没有了自己的控件,页面显示完全就回到了写html代码的年代。还好在asp.net mvc
日期:2013-4-24 来源:GBin1.com 如果你想了解如何优化前端性能的话,这个工具类型的网站browserdi
using System; using System.Collections.Generic; using System.Linq; using System.Text; using S
日期:2013-4-24 来源:GBin1.com 如果你想了解如何优化前端性能的话,这个工具类型的网站browserdi
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号