ftp客户端往服务端上传文件

客官°小女子只卖身不卖艺 2022-01-15 01:31 377阅读 0赞

###### 基于commons-net实现ftp客户端创建文件夹、文件上传、下载功能 ######

--------------------

1、导入commons-net maven坐标

<dependency>
                <groupId>commons-net</groupId>
                <artifactId>commons-net</artifactId>
                <version>3.6</version>
            </dependency>

2、为了方便使用，已经封装成了一个工具FtpClientUtil

package com.chen.ftpclient.demo;
    
    import org.apache.commons.net.PrintCommandListener;
    import org.apache.commons.net.ftp.FTP;
    import org.apache.commons.net.ftp.FTPClient;
    import org.apache.commons.net.ftp.FTPFile;
    import org.apache.commons.net.ftp.FTPReply;
    
    import java.io.*;
    import java.net.ConnectException;
    /** * @description: FtpClientUtil * @date: 2019/6/12 17:27 * @author: https://blog.csdn.net/chen_2890 */
    public class FtpClientUtil { 
        /** * ftp服务器地址 */
        private String server;
        /** * 端口 */
        private int port;
        /** * 用户名 */
        private String username;
        /** * */
        private String password;
    
        public FtpClientUtil() { 
            server = "192.168.3.110";
            port = 1111;
            username = "uftp";
            password = "uftp222";
        }
        public FtpClientUtil(String server, int port, String username,
                             String password) { 
            this.server = server;
            this.port = port;
            this.username = username;
            this.password = password;
        }
        /** * @param remoteFilePath 远程文件路径，是相对路径 * @param localFilePath 本地文件路径，是绝对路径 * @return void * @description 上传文件 * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:16 * @version V1.0 */
        public void upload(String remoteFilePath, String localFilePath) { 
            FTPClient ftp = null;
            try { 
                ftp = new FTPClient();
                ftp.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out), true));
                //连接ftp服务器
                connect(ftp);
                //设置属性
                setProperty(ftp);
                //在ftp服务中创建文件夹,如果存在则不创建
                String[] fileNames = remoteFilePath.split("/");
                for (Integer i = 0; i < fileNames.length - 1; i++) { 
                    ftp.makeDirectory(fileNames[i]);
                    ftp.changeWorkingDirectory(fileNames[i]);
                }
                //上传文件
                if(!existFile(ftp,remoteFilePath)){ 
                    upload(ftp,fileNames[fileNames.length - 1], localFilePath);
                }else{ 
                    System.out.println("[存在]："+remoteFilePath);
                }
                //退出
                logout(ftp);
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                if (ftp.isConnected()) { 
                    try { 
                        ftp.disconnect();
                    } catch (IOException f) { 
                    }
                }
            }
        }
        /** * @param remoteFilePath 远程文件路径，是相对路径 * @param localFilePath 本地文件路径，是绝对路径 * @return void * @description 文件下载 * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:16 * @version V1.0 */
        public void download(String remoteFilePath, String localFilePath) { 
            FTPClient ftp = null;
            try { 
                ftp = new FTPClient();
                ftp.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out), true));
                //连接ftp服务器
                connect(ftp);
                //设置属性
                setProperty(ftp);
                //下载文件
                download(ftp, remoteFilePath, localFilePath);
                //退出
                logout(ftp);
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                if (ftp.isConnected()) { 
                    try { 
                        ftp.disconnect();
                    } catch (IOException f) { 
                    }
                }
            }
        }
        /** * @param remotePathName 远程文件夹名称，不支持多层级目录的创建 * @return void * @description 创建文件夹 * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:19 * @version V1.0 */
        public void mkdir(String remotePathName) { 
            
            FTPClient ftp = null;
            try { 
                ftp = new FTPClient();
                ftp.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out), true));
                //连接ftp服务器
                connect(ftp);
                //设置属性
                setProperty(ftp);
                //创建文件夹
                mkdir(ftp, remotePathName);
                //退出
                logout(ftp);
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                if (ftp.isConnected()) { 
                    try { 
                        ftp.disconnect();
                    } catch (IOException f) { 
                    }
                }
            }
        }
        /** * @param ftp * @param remotePathName * @return void * @description 创建文件夹 * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:20 * @version V1.0 */
        private void mkdir(FTPClient ftp, String remotePathName) throws Exception { 
            ftp.makeDirectory(remotePathName);
        }
        /** * @description 下载 * @param ftp * @param remoteFilePath * @param localFilePath * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:21 * @version V1.0 */
        private void download(FTPClient ftp, String remoteFilePath,
                              String localFilePath) throws Exception { 
            OutputStream output = new FileOutputStream(localFilePath);
            ftp.retrieveFile(remoteFilePath, output);
            output.close();
        }
        /** * @description 设置属性 * @param ftp * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:22 * @version V1.0 */
        private void setProperty(FTPClient ftp) throws Exception { 
            ftp.enterLocalPassiveMode();
            //二进制传输,默认为ASCII
            ftp.setFileType(FTP.BINARY_FILE_TYPE);
        }
        /** * @description 退出登录 * @param ftp * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:22 * @version V1.0 */
        private void logout(FTPClient ftp) throws Exception { 
            ftp.noop();
            ftp.logout();
        }
        /** * @description 文件上传 * @param ftp * @param remoteFilePath * @param localFilePath * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:22 * @version V1.0 */
        private void upload(FTPClient ftp, String remoteFilePath,
                            String localFilePath) throws Exception { 
            //上传
            InputStream input;
            
            input = new FileInputStream(localFilePath);
    
            ftp.storeFile(remoteFilePath, input);
    
            input.close();
            
        }
        /** * @description ftp连接 * @param ftp * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:23 * @version V1.0 */
        private void connect(FTPClient ftp) throws Exception { 
            //连接服务器
            ftp.connect(server, port);
            int reply = ftp.getReplyCode();
            //是否连接成功
            if (!FTPReply.isPositiveCompletion(reply)) { 
                throw new ConnectException(server + " 服务器拒绝连接");
            }
            //登陆
            if (!ftp.login(username, password)) { 
                throw new ConnectException("用户名或密码错误");
            }
        }
        /** * @description 判断ftp服务器文件是否存在 * @param ftp * @param path * @return boolean * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:23 * @version V1.0 */
        public static boolean existFile(FTPClient ftp, String path) { 
            boolean flag = false;
            try { 
                ftp.enterLocalPassiveMode();
                FTPFile[] ftpFileArr = ftp.listFiles(path);
                if (ftpFileArr.length > 0) { 
                    flag = true;
                }
            } catch (IOException ioe) { 
                ioe.printStackTrace();
                System.out.println(ioe.getMessage());
            }
    
            return flag;
        }
    }

3、测试用例

package com.chen.ftpclient.demo;
    
    /** * @description: FtpTest * @date: 2019/6/12 17:28 * @author: https://blog.csdn.net/chen_2890 */
    public class FtpTest { 
    
        /** * @description 测试main方法 * @param args * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:27 * @version V1.0 */
        public static void main(String[] args) { 
            //上传文件
            upload();
            //下载文件
            //download();
            //创建文件夹
            //mkdir();
        }
        /** * @description 测试创建文件夹功能 * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:26 * @version V1.0 */
        private static void mkdir() { 
            FtpClientUtil clientUtil = new FtpClientUtil();
            clientUtil.mkdir("test");
        }
        /** * @description 测试文件下载功能 * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:26 * @version V1.0 */
        private static void download() { 
            String remoteFilePath = "/C6666666/2019-06-12/20190612013246.jpg";
            String localFilePath = "F:\\test\\20190612013246.jpg";
            FtpClientUtil clientUtil = new FtpClientUtil();
            clientUtil.download(remoteFilePath, localFilePath);
        }
        /** * @description 测试文件上传功能 * @return void * @author https://blog.csdn.net/chen_2890 * @date 2019/6/12 17:27 * @version V1.0 */
        private static void upload() { 
            String remoteFilePath = "/C6666666/2019-06-12/20190612013246.jpg";
            String localFilePath = "F:\\test\\20190612013246.jpg";
            FtpClientUtil clientUtil = new FtpClientUtil();
            clientUtil.upload(remoteFilePath, localFilePath);
        }
    }

`要是还有不太明白的地方请留言，评论必回`  
`要是对我的文章感兴趣的话，关注一下吧，谢谢！`

### 上一篇：[Linux基本命令][Linux] ###

### 下一篇：[Linux下如何部署jar包并后台运行?][Linux_jar] ###

原来微信打赏还可以备注哦

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fMjg5MA_size_16_color_FFFFFF_t_70_pic_center]

[Linux]: https://blog.csdn.net/chen_2890/article/details/90487697
[Linux_jar]: https://blog.csdn.net/chen_2890/article/details/90520517
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fMjg5MA_size_16_color_FFFFFF_t_70_pic_center]: /images/20220114/90330dded9a54fe7928d43d0f91d0250.png