Java实现FTP上传文件,NGINX代理回显

古城微笑少年丶 2022-09-05 05:21 303阅读 0赞

创建ftp服务器

1.创建ftp角色

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70][]

2.打开windows的ftp服务器功能

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 1][]

3.添加ftp服务器

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 4][]

登录ftp

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 5][]

登录成功,访问到d盘  /mulu/file/

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 6][]

开启ftp角色对于目录的读写权限 (先添加角色进去,再开启读写权限)

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 7][]

自己配置nginx 映射 d://mulu/file

Java实现ftp上传功能

ftp上传工具类

@Component
    public class FtpUtil {
    
    	private static final Logger log = LoggerFactory.getLogger(FtpUtil.class);
    		//账号
    		@Value("${ftp.account}")
    		public String FTP_ACCOUNT;
    		
    		//密码
    		@Value("${ftp.password}")
    		public String FTP_PASSWORD;
    		
    		//端口
    		@Value("${ftp.port}")
    		public int FTP_PORT;
    		
    		//ip地址
    		@Value("${ftp.server}")
    		public String FTP_SERVERIP;
    
    		@Value("${ftp.fileFolder}")
    		public String fileFolder;
    
    
    		/** 
    		 * Description: 向FTP服务器上传文件 
    		 * @param //host FTP服务器hostname
    		 * @param  //port FTP服务器端口
    		 * @param //username FTP登录账号
    		 * @param  //password FTP登录密码
    		 * @param  //basePath FTP服务器基础目录
    		 * @param filePath FTP服务器文件存放路径。例如分日期存放：/2015/01/01。文件的路径为basePath+filePath
    		 * @param filename 上传到FTP服务器上的文件名 
    		 * @param input 输入流 
    		 * @return 成功返回true，否则返回false
    		 */  
    		public  boolean uploadFile(String filePath, String filename, InputStream input) {
    			log.info("======进入 向FTP服务器上传文件 ");
    			boolean result = false;
    			FTPClient ftp = new FTPClient();
    			try {
    				int reply;
    				ftp.connect(FTP_SERVERIP, FTP_PORT);// 连接FTP服务器
    				log.info("======ftp连接成功 ");
    				// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
    				ftp.login(FTP_ACCOUNT, FTP_PASSWORD);// 登录
    				log.info("======ftp登录成功 ");
    				reply = ftp.getReplyCode();
    				log.info("======reply =={}", JSON.toJSONString(reply));
    				if (!FTPReply.isPositiveCompletion(reply)) {
    					ftp.disconnect();
    					log.info("======!FTPReply.isPositiveCompletion(reply) 进来了");
    					return result;
    				}
    				//切换到上传目录
    				if (!ftp.changeWorkingDirectory(filePath)) {
    					//如果目录不存在创建目录
    					log.info("======切换到上传目录 filePath =={}", JSON.toJSONString(filePath));
    					String[] dirs = filePath.split("/");
    					log.info("======切换到上传目录 dirs =={}", JSON.toJSONString(dirs));
    					String tempPath = "";
    					log.info("======切换到上传目录 tempPath =={}", JSON.toJSONString(tempPath));
    					for (String dir : dirs) {
    						if (StringUtils.isEmpty(dir)) {
    							continue;
    						}
    						tempPath += "/" + dir;
    						log.info("======切换到上传目录 ftp.changeWorkingDirectory(tempPath) =={}", JSON.toJSONString(ftp.changeWorkingDirectory(tempPath)));
    						if (!ftp.changeWorkingDirectory(tempPath)) {
    							log.info("文件夹不存在");
    							log.info("======切换到上传目录 ftp.makeDirectory(tempPath)=={}", JSON.toJSONString(ftp.makeDirectory(tempPath)));
    							if (!ftp.makeDirectory(tempPath)) {
    								return result;
    							} else {
    								log.info("======切换到上传目录 esle  ftp.changeWorkingDirectory(tempPath);");
    								ftp.changeWorkingDirectory(tempPath);
    							}
    						}
    					}
    				}
    				log.info("======执行完切换目录====");
    				ftp.enterLocalPassiveMode();
    				log.info("======上传目录 ftp.enterLocalPassiveMode()成功");
    				//设置上传文件的类型为二进制类型
    				ftp.setFileType(FTP.BINARY_FILE_TYPE);
    				log.info("======上传目录 ftp.setFileType(FTP.BINARY_FILE_TYPE)成功");
    				//上传文件
    				if (!ftp.storeFile(filename, input)) {
    					return result;
    				}
    				input.close();
    				log.info("======切换到上传目录 input.close()成功");
    				ftp.logout();
    				log.info("======切换到上传目录 ftp.logout()成功");
    				result = true;
    				log.info("======切换到上传目录 上传成功");
    			} catch (IOException e) {
    				e.printStackTrace();
    			} finally {
    				if (ftp.isConnected()) {
    					try {
    						ftp.disconnect();
    					} catch (IOException ioe) {
    					}
    				}
    			}
    			return result;
    		}
    
    		
    }

工具类 配置参数 ,账号,密码,端口 ,ip 上传文件夹

#ftp相关  这里的ip是ftp服务器ip, 我是在已有服务器172.16.1.13上测试的,不是在刚设置的172.16.1.20上测试的,填写自己的ftp服务器IP即可
    ftp.account=zhylftp
    ftp.password=zhylftp
    ftp.port=21
    ftp.server=172.16.1.13
    ftp.fileFolder=/provide

ftp上传包装方法

@Value("${ftp.head.url}")
        private String ftpUrl;
    
    //ftp文件上传
        @Override
        public ResultVO ftpUpload(MultipartFile file, QueryParam param) {
            try {
                // 获取旧文件名
                String fileName = file.getOriginalFilename();
                if (StringUtils.isEmpty(fileName)) {
                    throw new GlobalException("文件名有误");
                }
                log.info("上传的文件名为：" + fileName);
                // 获取文件的后缀名
                String suffixName = fileName.substring(fileName.lastIndexOf("."));
                log.info("上传的后缀名为：" + suffixName);
    
                log.info("ftp文件上传  ftpUtil ======{}", JSON.toJSONString(ftpUtil));
                InputStream inputStream = file.getInputStream();
                String UUIDName = UUID.randomUUID().toString().replace("-", "") + suffixName; //新文件名
                log.info("上传的文件名为：" + (UUIDName));
                boolean b = ftpUtil.uploadFile(ftpUtil.fileFolder, UUIDName, inputStream);
                if(b){
                    String fileUrl = ftpUrl+ftpUtil.fileFolder+"/"+UUIDName;
                    Map map = new HashMap();
                    map.put("oldFileName", fileName);
                    map.put("picName", UUIDName);
                    map.put("url", fileUrl);
                    return new ResultVO(StatusCode.RESULT_SUCCESS,map);
                }else {
                    return new ResultVO(StatusCode.UPLOAD_FILE_ERROR);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            return new ResultVO(StatusCode.SYSTEM_EXCEPTION);
        }

ftpUrl 访问头

#ftp 上传访问头
    ftp.head.url=http://172.16.1.13:8999

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 9][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70]: /images/20220829/24d747e019af4e179dcc3d26c17755ae.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 1]: /images/20220829/f2ba2490eccf4902927e5ba963ef9de5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 2]: /images/20220829/8a1fc9311143466fa6ba45435047baf0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 3]: /images/20220829/26cbb68195f949d9879174b518f07d0e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 4]: /images/20220829/0666c94aa56d488aa6f2203036a49593.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 5]: /images/20220829/57987ed18ede44cf9b2363f0d43ea356.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 6]: /images/20220829/f9df1d3e6196478da879742b3a22b7ff.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 7]: /images/20220829/7fc63b7373e64b3a8f09a01896aace15.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 8]: /images/20220829/f5d0961c1cfb4c23a3b7bc21970d6610.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 9]: /images/20220829/7338f26e447b42a1968ee95aa11e0a8a.png