FTP服务器文件的上传、拼接、下载

逃离我推掉我的手 2022-05-17 05:30 338阅读 0赞

用到的包是 commons-net-1.4.1.jar ， 可以通过maven下载，也可以在maven上直接下载导入到项目。

1，工具类如下

package com.util.ftp;

import org.apache.commons.net.ftp.FTPClient;  
import org.apache.commons.net.ftp.FTPReply;  
import java.io.File;  
import java.io.FileNotFoundException;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
import java.net.SocketException;

/\*\*  
 \* FTP工具类<br>  
 \* 方法包括：ftp连接、ftp文件下载、上传文件到ftp、拼接ftp上的文件内容  
 \* @author zsm  
 \*  
 \*/  
public class FtpUtil \{

/\*\*  
     \* 获取FTPClient对象  
     \*  
     \* @param ftpHost     FTP主机服务器  
     \* @param ftpPassword FTP 登录密码  
     \* @param ftpUserName FTP登录用户名  
     \* @param ftpPort     FTP端口 默认为21  
     \* @return  
     \*/  
    public static FTPClient getFTPClient(String ftpHost, String ftpUserName,  
                                         String ftpPassword, int ftpPort) \{  
        FTPClient ftpClient = new FTPClient();  
        try \{  
            ftpClient = new FTPClient();  
            ftpClient.connect(ftpHost, ftpPort);// 连接FTP服务器  
            ftpClient.login(ftpUserName, ftpPassword);// 登陆FTP服务器  
            if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) \{  
                System.out.println("未连接到FTP，用户名或密码错误。");  
                ftpClient.disconnect();  
            \} else \{  
                System.out.println("FTP连接成功。");  
            \}  
        \} catch (SocketException e) \{  
            e.printStackTrace();  
            System.out.println("FTP的IP地址可能错误，请正确配置。");  
        \} catch (IOException e) \{  
            e.printStackTrace();  
            System.out.println("FTP的端口错误,请正确配置。");  
        \}  
        return ftpClient;  
    \}

/\*\*  
     \* 从FTP服务器下载文件  
     \*  
     \* @param ftpHost FTP IP地址  
     \* @param ftpUserName FTP 用户名  
     \* @param ftpPassword FTP用户名密码  
     \* @param ftpPort FTP端口  
     \* @param ftpPath FTP服务器中文件所在路径 格式： a/b  
     \* @param localPath 下载到本地的位置 格式：C:\\\\Users\\\\Administrator\\\\Desktop\\\\  
     \* @param fileName 文件名称  
     \*/  
    public static void downloadFtpFile(String ftpHost, String ftpUserName,  
                                       String ftpPassword, int ftpPort, String ftpPath, String localPath,  
                                       String fileName) \{

FTPClient ftpClient = null;

try \{  
            ftpClient = getFTPClient(ftpHost, ftpUserName, ftpPassword, ftpPort);  
            ftpClient.setControlEncoding("UTF-8"); // 中文编码处理  
            ftpClient.setFileType(FTPClient.BINARY\_FILE\_TYPE);  
            ftpClient.enterLocalPassiveMode();  
            ftpClient.changeWorkingDirectory(ftpPath);

File localFile = new File(localPath + File.separatorChar + fileName);  
            OutputStream os = new FileOutputStream(localFile);  
            ftpClient.retrieveFile(fileName, os);  
            os.close();  
            ftpClient.logout();

\} catch (FileNotFoundException e) \{  
            System.out.println("没有找到" + ftpPath + "文件");  
            e.printStackTrace();  
        \} catch (SocketException e) \{  
            System.out.println("连接FTP失败.");  
            e.printStackTrace();  
        \} catch (IOException e) \{  
            e.printStackTrace();  
            System.out.println("文件读取错误。");  
            e.printStackTrace();  
        \}

/\*\*  
     \* 向FTP服务器上传文件  
     \* @param ftpHost FTP服务器hostname  
     \* @param ftpUserName 账号  
     \* @param ftpPassword 密码  
     \* @param ftpPort 端口  
     \* @param ftpPath  FTP服务器中文件所在路径 格式： a/b  
     \* @param fileName ftp文件名称  
     \* @param input 文件流 (文件内容)  
     \* @return 成功返回true，否则返回false  
     \*/  
    public static boolean uploadFile(String ftpHost, String ftpUserName,  
                                     String ftpPassword, int ftpPort, String ftpPath,  
                                     String fileName,InputStream input) \{  
        boolean success = false;  
        FTPClient ftpClient = null;  
        try \{  
            int reply;  
            ftpClient = getFTPClient(ftpHost, ftpUserName, ftpPassword, ftpPort);  
            reply = ftpClient.getReplyCode();  
            if (!FTPReply.isPositiveCompletion(reply)) \{  
                ftpClient.disconnect();  
                return success;  
            \}  
            ftpClient.setControlEncoding("UTF-8"); //中文编码处理  
            ftpClient.setFileType(FTPClient.BINARY\_FILE\_TYPE);  
            ftpClient.enterLocalPassiveMode();  
            ftpClient.changeWorkingDirectory(ftpPath);

ftpClient.storeFile(fileName, input);

input.close();  
            ftpClient.logout();  
            success = true;  
        \} catch (IOException e) \{  
            e.printStackTrace();  
        \} finally \{  
            if (ftpClient.isConnected()) \{  
                try \{  
                    ftpClient.disconnect();  
                \} catch (IOException ioe) \{  
                \}  
            \}  
        \}  
        return success;  
    \}  
    /\*\*  
     \* 如果服务器没有该文件，会创建一个空文件，如果存在该文件，就将内容拼接到文件中  
     \* @param ftpHost FTP服务器hostname  
     \* @param ftpUserName 账号  
     \* @param ftpPassword 密码  
     \* @param ftpPort 端口  
     \* @param ftpPath  FTP服务器中文件所在路径 格式： a/b  
     \* @param fileName ftp文件名称  
     \* @param input 文件流 (拼接的文件内容)  
     \* @return 成功返回true，否则返回false  
     \*/  
    public static boolean uploadAppendFile(String ftpHost, String ftpUserName,  
                                     String ftpPassword, int ftpPort, String ftpPath,  
                                     String fileName,InputStream input) \{  
        boolean success = false;  
        FTPClient ftpClient = null;  
        try \{  
            int reply;  
            ftpClient = getFTPClient(ftpHost, ftpUserName, ftpPassword, ftpPort);  
            reply = ftpClient.getReplyCode();  
            if (!FTPReply.isPositiveCompletion(reply)) \{  
                ftpClient.disconnect();  
                return success;  
            \}  
            ftpClient.setControlEncoding("UTF-8"); // 中文支持  
            ftpClient.setFileType(FTPClient.BINARY\_FILE\_TYPE);  
            ftpClient.enterLocalPassiveMode();  
            ftpClient.changeWorkingDirectory(ftpPath);

ftpClient.appendFile(fileName, input);

2，测试类如下，测试中有的方法注释了，打开即可测试。

package com.util.ftp;

import java.io.ByteArrayInputStream;  
import java.io.InputStream;  
import java.io.UnsupportedEncodingException;

public class Test \{  
    public static void main(String\[\] args) \{  
        String ftpHost = "192.168.0.102";  
        String ftpUserName = "meng";  
        String ftpPassword = "123456";  
        int ftpPort = 21;  
        String ftpPath = "/";  
          
        //上传    
          
        String localPath = "C:\\\\Users\\\\Administrator\\\\Desktop\\\\abc.txt";//本地要上传的文件  
        String fileName = "abcdd.txt";//上传到服务器的名字，文件名可修改  
          
        //下载    
//        String localPath = "C:\\\\Users\\\\Administrator\\\\Desktop\\\\";//本地保存的地址  
//        String fileName = "123.txt";//从服务器下载的文件

//上传一个文件  
//        try\{  
//            FileInputStream in=new FileInputStream(new File(localPath));  
//            boolean test = FtpUtil222.uploadFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, fileName,in);  
//            System.out.println(test);  
//        \} catch (FileNotFoundException e)\{  
//            e.printStackTrace();  
//            System.out.println(e);  
//        \}

//在FTP服务器上生成一个文件，并将一个字符串写入到该文件中  
        try \{  
            //windows下的文本文件换行符:\\r\\n   linux/unix下的文本文件换行符:\\r     Mac下的文本文件换行符:\\n  
            InputStream input = new ByteArrayInputStream("test append\\r\\n".getBytes("utf-8"));  
            boolean flag = FtpUtil.uploadAppendFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, fileName,input);  
            System.out.println(flag);  
        \} catch (UnsupportedEncodingException e) \{  
            e.printStackTrace();  
        \}

//下载一个文件  
       // FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);  
    \}  
\}

3，如果文件无法上传，可能是ftp权限问题，打开读写权限。

4，API地址：[http://commons.apache.org/proper/commons-net/apidocs/org/apache/commons/net/ftp/FTPClient.html][http_commons.apache.org_proper_commons-net_apidocs_org_apache_commons_net_ftp_FTPClient.html]

5，如果是在本地测试，推荐用ServU创建本地ftp服务站点。

![70][]

[http_commons.apache.org_proper_commons-net_apidocs_org_apache_commons_net_ftp_FTPClient.html]: http://commons.apache.org/proper/commons-net/apidocs/org/apache/commons/net/ftp/FTPClient.html
[70]: /images/20220517/adc2fadb585942dc935dec3a673f5a99.png