java ftpclient上传txt文件

我会带着你远行 2022-03-22 05:45 264阅读 0赞

#### java ftpclient上传txt文件 ####

*      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.MalformedURLException;
 *  工具类
    
        public class FtpUtils { 
             //ftp服务器地址
             public String hostname = "192.3.81.100";
             //ftp服务器端口号默认为21
             public Integer port = 21 ;
             //ftp登录账号
             public String username = "Admin";
             //ftp登录密码
             public String password = "xxx";
         
             public static FTPClient ftpClient = null;
         
             //本地字符编码
             static String LOCAL_CHARSET = "UTF-8";
         
             // FTP协议里面，规定文件名编码为iso-8859-1
             static String SERVER_CHARSET = "ISO-8859-1";
             /** * 初始化ftp服务器 */
             public void initFtpClient() { 
                 ftpClient = new FTPClient();
                 ftpClient.setControlEncoding(LOCAL_CHARSET);
                 try { 
                     System.out.println("connecting...ftp服务器:"+this.hostname+":"+this.port);
                     ftpClient.connect(hostname, port); //连接ftp服务器
                     ftpClient.login(username, password); //登录ftp服务器
                     int replyCode = ftpClient.getReplyCode(); //是否成功登录服务器
                     if(!FTPReply.isPositiveCompletion(replyCode)){ 
                         System.out.println("connect failed...ftp服务器:"+this.hostname+":"+this.port);
                     }
                     System.out.println("connect successful...ftp服务器:"+this.hostname+":"+this.port);
                     ftpClient.sendCommand("OPTS UTF8","ON");
                 }catch (MalformedURLException e) { 
                     e.printStackTrace();
                 }catch (IOException e) { 
                     e.printStackTrace();
                 }
             }
         
             /** * 上传文件 * @param pathname ftp服务保存地址 * @param fileName 上传到ftp的文件名 * @param originfilename 待上传文件的名称（绝对地址） * * @return */
             public boolean uploadFile( String pathname, String fileName,String originfilename){ 
                 boolean flag = false;
                 InputStream inputStream = null;
                 try{ 
                     System.out.println("开始上传文件");
                     inputStream = new FileInputStream(new File(originfilename));
                     initFtpClient();
                     ftpClient.enterLocalPassiveMode();
                     ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
                     CreateDirecroty(pathname);
                     ftpClient.makeDirectory(pathname);
                     ftpClient.changeWorkingDirectory(pathname);
                     ftpClient.storeFile(new String(fileName.getBytes(LOCAL_CHARSET),
                             SERVER_CHARSET), inputStream);
         
         // ftpClient.storeFile(fileName, inputStream);
                     inputStream.close();
                     ftpClient.logout();
                     flag = true;
                     System.out.println("上传文件成功");
                 }catch (Exception e) { 
                     System.out.println("上传文件失败");
                     e.printStackTrace();
                 }finally{ 
                     if(ftpClient.isConnected()){ 
                         try{ 
                             ftpClient.disconnect();
                         }catch(IOException e){ 
                             e.printStackTrace();
                         }
                     }
                     if(null != inputStream){ 
                         try { 
                             inputStream.close();
                         } catch (IOException e) { 
                             e.printStackTrace();
                         }
                     }
                 }
                 return flag;
             }
             //改变目录路径
             public boolean changeWorkingDirectory(String directory) { 
                 boolean flag = true;
                 try { 
                     flag = ftpClient.changeWorkingDirectory(directory);
                     if (flag) { 
                         System.out.println("进入文件夹" + directory + " 成功！");
         
                     } else { 
                         System.out.println("进入文件夹" + directory + " 失败！开始创建文件夹");
                     }
                 } catch (IOException ioe) { 
                     ioe.printStackTrace();
                 }
                 return flag;
             }
             //创建多层目录文件，如果有ftp服务器已存在该文件，则不创建，如果无，则创建
             public boolean CreateDirecroty(String remote) throws IOException { 
                 boolean success = true;
                 String directory = remote + "/";
                 // 如果远程目录不存在，则递归创建远程服务器目录
                 if (!directory.equalsIgnoreCase("/") && !changeWorkingDirectory(new String(directory))) { 
                     int start = 0;
                     int end = 0;
                     if (directory.startsWith("/")) { 
                         start = 1;
                     } else { 
                         start = 0;
                     }
                     end = directory.indexOf("/", start);
                     String path = "";
                     String paths = "";
                     while (true) { 
                         String subDirectory = new String(remote.substring(start, end).getBytes("GBK"), "iso-8859-1");
                         path = path + "/" + subDirectory;
                         if (!existFile(path)) { 
                             if (makeDirectory(subDirectory)) { 
                                 changeWorkingDirectory(subDirectory);
                             } else { 
                                 System.out.println("创建目录[" + subDirectory + "]失败");
                                 changeWorkingDirectory(subDirectory);
                             }
                         } else { 
                             changeWorkingDirectory(subDirectory);
                         }
         
                         paths = paths + "/" + subDirectory;
                         start = end + 1;
                         end = directory.indexOf("/", start);
                         // 检查所有目录是否创建完毕
                         if (end <= start) { 
                             break;
                         }
                     }
                 }
                 return success;
             }
             //创建目录
             public boolean makeDirectory(String dir) { 
                 boolean flag = true;
                 try { 
                     flag = ftpClient.makeDirectory(dir);
                     if (flag) { 
                         System.out.println("创建文件夹" + dir + " 成功！");
         
                     } else { 
                         System.out.println("创建文件夹" + dir + " 失败！");
                     }
                 } catch (Exception e) { 
                     e.printStackTrace();
                 }
                 return flag;
             }
             /** * 下载文件 * * @param pathname FTP服务器文件目录 * * @param filename 文件名称 * * @param localpath 下载后的文件路径 * * @return */
             public  boolean downloadFile(String pathname, String filename, String localpath){ 
                 boolean flag = false;
                 OutputStream os=null;
                 try { 
                     System.out.println("开始下载文件");
                     initFtpClient();
                     //切换FTP目录
                     ftpClient.changeWorkingDirectory(pathname);
                     FTPFile[] ftpFiles = ftpClient.listFiles();
                     for(FTPFile file : ftpFiles){ 
                         if(filename.equalsIgnoreCase(file.getName())){ 
                             File localFile = new File(localpath + "/" + file.getName());
                             os = new FileOutputStream(localFile);
                             ftpClient.retrieveFile(file.getName(), os);
                             os.close();
                         }
                     }
                     ftpClient.logout();
                     flag = true;
                     System.out.println("下载文件成功");
                 } catch (Exception e) { 
                     System.out.println("下载文件失败");
                     e.printStackTrace();
                 } finally{ 
                     if(ftpClient.isConnected()){ 
                         try{ 
                             ftpClient.disconnect();
                         }catch(IOException e){ 
                             e.printStackTrace();
                         }
                     }
                     if(null != os){ 
                         try { 
                             os.close();
                         } catch (IOException e) { 
                             e.printStackTrace();
                         }
                     }
                 }
                 return flag;
             }
             //判断ftp服务器文件是否存在
             private boolean existFile(String path) throws IOException { 
                 boolean flag = false;
                 FTPFile[] ftpFileArr = ftpClient.listFiles(path);
                 if (ftpFileArr.length > 0) { 
                     flag = true;
                 }
                 return flag;
             }
         }
 *  工具调用
    
        FtpUtils ftp =new FtpUtils();
            ftp.uploadFile("/files/", "mylogs.txt", "D://mylogs.txt");
            //ftp.uploadFile("/FTP服务目录/", "文件名", “文件路径与文件名”);