JavaWeb文件上传和下载FTP

爱被打了一巴掌 2022-03-01 03:04 371阅读 0赞

# 前言 #

javaweb文件上传,目前我接触到的是上传到专门**文件服务器**和保存到**本地**两种。传统项目单机应用（只部署到一个tomcat下）保存文件就是直接保存到tomcat的某个文件夹下面。到后来接触到分布式，或者说一个应用要做负载均衡的时候，就需要单独的服务器来保存文件（为什么需要，如果文件直接保存到tomcat中，用户访问到的tomcat是随机的，就会出现可能访问到也有可能访问不到自己传上去的文件），这里我接触到**fastDFS**和**vsftp**两种文件服务器。两者是什么我就不具体说了。因为整个环境都是自己搭的而且自己也不是运维，所以选择了环境比较好搭建的**vsftp+nginx**这一套。然后编写了java端的上传和下载文件的工具类，当然是在别人写好的工具类上修改了一下，因为别人写的直接拿来用多多少少都会有坑，或者走不通的。最后我调好了一个我自己认为没多大问题的工具类。

# 简述 #

vsftp+nginx的环境搭建可以在网上搜索，在此处我只是说明一下这两者是干嘛的就好了  
vsftp:一种文件上传的服务，ftp一定听过，在自己的linux上安装vsftp服务就把它当作一个文件服务器来用了。  
nginx:用来做反向代理和负载均衡用的，这里用来做静态资源的反向代理。上传到服务器中的静态资源通过nginx来代理，这样通过浏览器可以访问自己上传的文件了。

# 步骤 #

## 1.搭建文件服务器(nginx+vsftp) ##

vsftp搭建：

###### 检查是否已经有了 ######

rpm -qa vsftpd

###### 安装vsftpd ######

yum -y install vsftpd

###### 启动 ######

service vsftpd start

###### 开启启动 ######

chkconfig vsftpd on

###### 创建用户 ######

useradd ftpqek

###### 设置权限（创建用户之后会在home下自动生成一个文件夹，名称就是 用户名的） ######

chmod -R 777 ftpqek

###### 添加密码 ######

passwd hzh1990 -> 密码 -> 确认密码

###### 启动ftp服务 ######

service vsftpd start

###### 查看ftp服务状态 ######

service vsftpd status

###### 重启ftp服务 ######

service vsftpd restart

###### 关闭ftp服务 ######

service vsftpd stop

这个东西去百度吧，搭建过程中会遇到一些问题。但是教程中没有记录，需要自己通过现象去解决问题。这个地方我只是记录一下我出现的一些问题：

1.  现象：测试文件服务器好使不好使得时候，用xftp(一种支持ftp的传输文件的工具)连接不上文件服务器  
    解决：原因是vsftp服务没有启动！怎么启动的以及查看启动状态的命令…百度吧
2.  现象：用java代码去测试上传文件的时候，自己指定了一个目标文件夹，而且一些关于vsftpd的配置也是设置了的，但是还是失败了  
    解决：需要修改vsftp的默认生成用来保存文件的文件夹权限，  
    这里我直接修改成了最高权限。linux命令 chmod -R 777 dirName

## 2.java端代码 ##

引入依赖

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

这个工具类是支持中文名的文件上传和下载的

package com.taotao.common.util;
    
    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.FTPFile;
    import org.apache.commons.net.ftp.FTPReply;
    
    /**
     * 　　* @Description: FTP文件上传和下载工具类
     * 　　* @author lf
     * 　　* @date 2019/3/21 10:33
     */
    public class FTPUtil {
    
        /**
         * 　　* @Description: 连接FTP服务器
         * 　　* @param ${tags}
         * 　　* @return FTPClient 对象
         * 　　* @author lf
         * 　　* @date 2019/3/21 10:37
         */
        private static FTPClient connectFTP(String host, int port, String username, String password) throws IOException {
            FTPClient ftp = new FTPClient();
            ftp.connect(host, port);// 连接FTP服务器 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
            ftp.login(username, password);// 登录
            //获取ftp是否连接成功的状态码
            if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
                ftp.disconnect();
                return null;
            }
            return ftp;
        }
    
    
        /**
         * Description: 向FTP服务器上传文件
         *
         * @param host     FTP服务器hostname
         * @param port     FTP服务器端口
         * @param username FTP登录账号
         * @param password FTP登录密码
         * @param basePath FTP服务器基础目录(ftp安装服务生成的基础目录)  例如：/home/ftpuser
         * @param filePath FTP服务器文件存放路径。例如分日期存放：/2015/01/01。文件的路径为basePath+filePath
         * @param filename 上传到FTP服务器上的文件名
         * @param input    输入流
         * @return 成功返回true，否则返回false
         */
        public static boolean uploadFile(String host, int port, String username, String password, String basePath,
                                         String filePath, String filename, InputStream input) {
            try {
                //1.连接ftp服务器
                FTPClient ftp = connectFTP(host, port, username, password);
                if (ftp == null) {
                    return false;
                }
                ftp.setControlEncoding("UTF-8");//设置编码格式，来支持上传文件名是中文的文件
                //2.切换ftp上传文件的目标目录为指定目录
                if (!ftp.changeWorkingDirectory(basePath + filePath)) {
                    //如果目录不存在创建目录
                    String[] dirs = filePath.split("/");
                    String tempPath = basePath;
                    for (String dir : dirs) {
                        if (null == dir || "".equals(dir)) continue;
                        tempPath += "/" + dir;
                        if (!ftp.changeWorkingDirectory(tempPath)) {
                            if (!ftp.makeDirectory(tempPath)) { //创建文件夹未成功
                                return false;
                            } else {
                                ftp.changeWorkingDirectory(tempPath);
                            }
                        }
                    }
                }
                //******************检查目标文件夹中是否是有同名文件
                if (haveSameFile(ftp, filename)) {
                    System.out.println("目标文件夹中已经存在相同文件！");
                }
                //3.设置上传文件的类型为二进制类型
                ftp.setFileType(FTP.BINARY_FILE_TYPE);
                ftp.enterLocalPassiveMode();
                //4.上传文件
                if (!ftp.storeFile(new String(filename.getBytes("UTF-8"), "iso-8859-1"), input)) {
                    return false;
                }
                //5.退出登陆 断开连接
                ftp.logout();
                ftp.disconnect();
            } catch (IOException e) {
                e.printStackTrace();
            }
            return true;
        }
    
        /**
         * Description: 从FTP服务器下载文件
         *
         * @param host       FTP服务器hostname
         * @param port       FTP服务器端口
         * @param username   FTP登录账号
         * @param password   FTP登录密码
         * @param remotePath FTP服务器上的相对路径
         * @param fileName   要下载的文件名
         * @param localPath  下载后保存到本地的路径
         * @return
         */
        public static boolean downloadFile(String host, int port, String username, String password, String remotePath,
                                           String fileName, String localPath) {
            try {
                FTPClient ftp = connectFTP(host, port, username, password);
                if(ftp ==null){
                    return false;
                }
                ftp.setControlEncoding("UTF-8");//支持中文名文件下载
                ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
                ftp.enterLocalPassiveMode();
                ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
                FTPFile[] fs = ftp.listFiles();
                for (FTPFile ff : fs) {
                    if (ff.getName().equals(fileName)) {
                        //下载文件
                        OutputStream os = new FileOutputStream(new File(localPath + "/" + fileName));
                        if(ftp.retrieveFile(new String(fileName.getBytes("UTF-8"), "iso-8859-1"), os)){//文件名编码 和上传的编码一致
                            return false;
                        }
                    }
                }
                ftp.logout();
                ftp.disconnect();
            } catch (IOException e) {
                e.printStackTrace();
                return false;
            }
            return true;
        }
    
        /**
         * 　　* @Description: 检查上传目录是否已经存在同名的文件
         * 　　* @param ${tags}
         * 　　* @return ${return_type}
         * 　　* @throws
         * 　　* @author lf
         * 　　* @date 2019/3/21 10:57
         *
         */
        public static boolean haveSameFile(FTPClient ftpClient, String fileName) throws IOException {
            FTPFile[] fs = ftpClient.listFiles();
            for (FTPFile ff : fs) {
                if (ff.getName().equals(fileName)) {
                    return true;
                }
            }
            return false;
        }
    }