SpringBoot之上传文件到FTP服务器

喜欢ヅ旅行 2023-10-03 07:35 2阅读 0赞

### 一、创建上传工具类 ###

package com.cuinn.upload.utils;
    
    import org.apache.commons.net.ftp.FTPClient;
    import org.apache.commons.net.ftp.FTPReply;
    
    import java.io.IOException;
    import java.io.InputStream;
    
    public class FtpUtil {
        
        //ftp服务器ip地址
        private static final String FTP_ADDRESS = "1.127.70.215";
        //端口号
        private static final int FTP_PORT = 21;
        //用户名
        private static final String FTP_USERNAME = "user-file";
        //密码
        private static final String FTP_PASSWORD = "123456";
        //附件路径
        private static final String FTP_BASEPATH = "/home/user-file/files";
    
        public static boolean uploadFile(String fileName, InputStream inputStream)  {
        
            boolean success = false;
            FTPClient ftpClient = new FTPClient();
            try{
        
                int reply;
                ftpClient.connect(FTP_ADDRESS, FTP_PORT);//连接FTP服务器
                ftpClient.login(FTP_USERNAME, FTP_PASSWORD);//登录
                reply = ftpClient.getReplyCode();
                if (!FTPReply.isPositiveCompletion(reply)){
        
                    ftpClient.disconnect();
                    return false;
                }
                ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
                ftpClient.makeDirectory(FTP_BASEPATH);
                ftpClient.changeWorkingDirectory(FTP_BASEPATH);
                ftpClient.enterLocalPassiveMode();
                ftpClient.storeFile(fileName, inputStream);
                inputStream.close();
                ftpClient.logout();
                success = true;
            }catch (IOException e){
        
                e.printStackTrace();
            }finally {
        
                if (ftpClient.isConnected()){
        
                    try{
        
                        ftpClient.disconnect();
                    }catch (IOException e){
        
                        e.printStackTrace();
                    }
                }
            }
            if (success){
        
                System.out.println("方法执行成功，文件上传到FTP服务器");
            }
            return success;
        }
    
    }

### 二、创建本地文件，调用FTP工具类进行文件上传 ###

package com.cuinn.upload.file;
    
    import com.cuinn.upload.utils.FtpUtil;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    
    public static boolean createFile(){
        
            boolean success = false;
            FileOutputStream fileOutputStream = null;
            InputStream inputStream = null;
            OutputStreamWriter outputStreamWriter = null;
            try{
        
                //创建文件
                File file = new File("D:\\hello.txt");
                if (!file.exists()){
        
                    file.createNewFile();
                }
                //以追加的方式写入内容
                fileOutputStream = new FileOutputStream(file, true);
                //获取模板内容
                String content = generateTemplate("我是信息行内容");
    
                //byte[] bytes = content.getBytes(StandardCharsets.UTF_8);
    
                outputStreamWriter = new OutputStreamWriter(fileOutputStream, "utf-8");
                outputStreamWriter.write(content);
    
                //写入字节数组指定区间
                //fileOutputStream.write(bytes, 0, content.length());
    
                //获取文件输入流
                inputStream = new FileInputStream(file);
    
                //文件上传
                String fileName = file.getName();
                FtpUtil.uploadFile(fileName, inputStream);
                success = true;
    
            }catch (IOException e){
        
                e.printStackTrace();
            }finally {
        
                try{
        
                    inputStream.close();
                    outputStreamWriter.close();
                }catch (IOException e){
        
                    e.printStackTrace();
                }
            }
            return success;
        }

三、SpringBoot启动类，运行测试

package com.cuinn.upload;
    
    import com.cuinn.upload.file.CreateFile;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @SpringBootApplication
    public class SpringBootUploadFileToFTPApplication {
        
        public static void main(String args[]){
        
            SpringApplication.run(SpringBootUploadFileToFTPApplication.class, args);
            if (CreateFile.createFile()){
        
                System.out.println("文件上传成功！");
            }else {
        
                System.out.println("文件上传失败！");
            }
        }
    }

### 四、测试结果 ###

1.查看运行结果![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70]  
2.查看FTP服务器中是否存在指定上传的文件  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 1]  
可以看到文件已上传成功

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210711222045700.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210711222319738.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70