ftp上传下载和zip压缩解压操作
package com.test.action;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.BufferedReader;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.text.DateFormat;import java.text.SimpleDateFormat;import java.util.ArrayList;import java.util.Date;import java.util.Enumeration;import java.util.List;import java.util.zip.ZipEntry;import java.util.zip.ZipFile;import java.util.zip.ZipOutputStream;import sun.net.TelnetInputStream;import sun.net.TelnetOutputStream;import sun.net.ftp.FtpClient;public class FtpZipOption {/** * 从ftp服务器下载zip文件 * @param*@throws Exception **/public static void downLoadZipFile() throws Exception { String wantFileName = getWantFileName() ;//得到此时该下载的文件名 String[] localFileNameArray = getLocalFileNameArray("D:\\download") ;//得到所有已经下载的文件名 if(ifToDownLoadFile(wantFileName,localFileNameArray)){//判断是否需要下载 String str; //输出信息字符串 /** * 和服务器建立连接 */ FtpClient ftp = new FtpClient("192.168.39.189"); //根据服务器ip建立连接 str = ftp.getResponseString(); //获得响应信息 System.out.println("连接服务器:" + str); /** * 登陆到Ftp服务器 */ ftp.login("test", "test"); //根据用户名和密码登录服务器 str = ftp.getResponseString(); System.out.println("登录:"+str); /** * 打开并定位到服务器目录 */ ftp.cd("downziptest\\downzip"); //打开服务器上的文件目录 str = ftp.getResponseString() ; System.out.println("打开服务器目录:"+str) ; ftp.binary();//转化为二进制的文件 TelnetInputStream ftpIn = ftp.get(wantFileName+".zip");//找到要读取的文件 byte[] buf = new byte; int bufsize = 0; String toLocalPath = "D:\\download\\"+wantFileName+".zip" ; FileOutputStream ftpOut = new FileOutputStream(toLocalPath); while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) { ftpOut.write(buf, 0, bufsize); } ftpOut.close(); ftpIn.close(); System.out.println("下载"+wantFileName+".zip完成!") ; }else{ System.out.println(wantFileName+".zip在本地已经存在,不予下载") ; }} //上传文件;并返回上传文件的信息private static String upLoadZipToServer(String filename) throws Exception {String str; //输出信息字符串String timeStr = getNowTime();//获得当前时间String recordStr = "上传时间:" + timeStr + "\r\n";//信息记录字符串/** * 和服务器建立连接 */FtpClient ftp = new FtpClient("192.168.39.189"); //根据服务器ip建立连接 str = ftp.getResponseString(); //获得响应信息System.out.println(str);recordStr += "连接服务器:" + str + "\r\n";/** * 登陆到Ftp服务器 */ftp.login("test", "test"); //根据用户名和密码登录服务器str = ftp.getResponseString();System.out.println(str);recordStr += "登录:" + str + "\r\n";/** * 打开并定位到test目录 */ftp.cd("uptest"); //打开服务器上的test文件夹ftp.binary();//转化为二进制的文件str = ftp.getResponseString();System.out.println(str); FileInputStream is = null ;TelnetOutputStream os = null ; try { //"upftpfile"用ftp上传后的新文件名 os = ftp.put("uptest.zip"); File file_in = new java.io.File(filename); if (file_in.length()==0) { return "上传文件为空!"; } is = new FileInputStream(file_in); byte[] bytes = new byte; int c; while ((c = is.read(bytes))!= -1) { os.write(bytes, 0, c); }}finally { if (is != null) { is.close(); } if (os != null) { os.close(); } }return "上传文件成功!";}/** * zip压缩功能,压缩sourceFile(文件夹目录)下所有文件，包括子目录 * @paramsourceFile,待压缩目录; toFolerName,压缩完毕生成的目录 * @throws Exception */public static void fileToZip(String sourceFile, String toFolerName) throws Exception {List fileList = getSubFiles(new File(sourceFile)); //得到待压缩的文件夹的所有内容ZipOutputStream zos = new ZipOutputStream(new FileOutputStream(toFolerName));ZipEntry ze = null;byte[] buf = new byte;int readLen = 0;for (int i = 0; i < fileList.size(); i++) { //遍历要压缩的所有子文件File file = (File) fileList.get(i);System.out.println("压缩到的文件名:" + file.getName());ze = new ZipEntry(getAbsFileName(sourceFile, file));ze.setSize(file.length());ze.setTime(file.lastModified());zos.putNextEntry(ze);InputStream is = new BufferedInputStream(new FileInputStream(file));while ((readLen = is.read(buf, 0, 1024)) != -1) {zos.write(buf, 0, readLen);}is.close();}zos.close();System.out.println("压缩完成!");}/** * 解压zip文件 * @param sourceFile,待解压的zip文件; toFolder,解压后的存放路径 * @throws Exception **/public static void zipToFile(String sourceFile, String toFolder) throws Exception {String toDisk = toFolder;//接收解压后的存放路径ZipFile zfile = new ZipFile(sourceFile);//连接待解压文件System.out.println("要解压的文件是:" + zfile.getName());Enumeration zList = zfile.entries();//得到zip包里的所有元素ZipEntry ze = null;byte[] buf = new byte;while (zList.hasMoreElements()) {ze = (ZipEntry) zList.nextElement();if (ze.isDirectory()) {System.out.println("打开zip文件里的文件夹:" + ze.getName()+ " skipped...");continue;}System.out.println("zip包里的文件: " + ze.getName() + "\t" + "大小为:"+ ze.getSize() + "KB");//以ZipEntry为参数得到一个InputStream，并写到OutputStream中OutputStream outputStream = new BufferedOutputStream(new FileOutputStream(getRealFileName(toDisk, ze.getName())));InputStream inputStream = new BufferedInputStream(zfile.getInputStream(ze));int readLen = 0;while ((readLen = inputStream.read(buf, 0, 1024)) != -1) {outputStream.write(buf, 0, readLen);}inputStream.close();outputStream.close();System.out.println("已经解压出:" + ze.getName());}zfile.close();}/** * 给定根目录，返回另一个文件名的相对路径，用于zip文件中的路径. * @param baseDir java.lang.String 根目录 * @param realFileName java.io.File 实际的文件名 * @return 相对文件名 */private static String getAbsFileName(String baseDir, File realFileName) {File real = realFileName;File base = new File(baseDir);String ret = real.getName();while (true) {real = real.getParentFile();if (real == null)break;if (real.equals(base))break;elseret = real.getName() + "/" + ret;}return ret;}/** * 取得指定目录下的所有文件列表，包括子目录. * @param baseDir File 指定的目录 * @return 包含java.io.File的List */private static List<File> getSubFiles(File baseDir) {List<File> ret = new ArrayList<File>();File[] tmp = baseDir.listFiles();for (int i = 0; i < tmp.length; i++) {if (tmp.isFile())ret.add(tmp);if (tmp.isDirectory())ret.addAll(getSubFiles(tmp));}return ret;}/** * 给定根目录，返回一个相对路径所对应的实际文件名. * @param zippath 指定根目录 * @param absFileName 相对路径名，来自于ZipEntry中的name * @return java.io.File 实际的文件 */private static File getRealFileName(String zippath, String absFileName){String[] dirs = absFileName.split("/", absFileName.length());File ret = new File(zippath);// 创建文件对象if (dirs.length > 1) {for (int i = 0; i < dirs.length - 1; i++) {ret = new File(ret, dirs);}}if (!ret.exists()) {// 检测文件是否存在ret.mkdirs();// 创建此抽象路径名指定的目录}ret = new File(ret, dirs);// 根据 ret 抽象路径名和 child 路径名字符串创建一个新 File 实例return ret;}/** * 取得ftp服务器上某个目录下的所有文件名 * @param ftp, FtpClient类实例; folderName,服务器的文件夹名 * @throws Exception * @return list 某目录下文件名列表 **/private static List getServerFileNameList(FtpClient ftp,String folderName) throws Exception{ BufferedReader dr = new BufferedReader(new InputStreamReader(ftp.nameList(folderName)));List<String> list = new ArrayList<String>() ;String s;while((s=dr.readLine())!=null){list.add(s) ;}return list ;}/** * 得到已经下载的目录下的所有文件名的数组 * @param localPath 本地的下载文件保存路径 * @return 该路径下所有文件名 * **/private static String[] getLocalFileNameArray(String localPath){File diskFile = new File(localPath);if(diskFile!=null){String[] fileNameList = diskFile.list() ;return fileNameList ;}else{return null ;}}/** *获得当前系统时间*/public static String getNowTime() {String timeStr;DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH-mm-ss");Date currentTime = new Date(System.currentTimeMillis());timeStr = format.format(currentTime);return timeStr;}public staticString getWantFileName() throws Exception{/**得到当前的系统精确时间**/Date currentTime = new Date(System.currentTimeMillis()); /**接下来得到系统当前的年月日**/DateFormat df1 = new SimpleDateFormat("yyyyMMdd");Date todayDate = new Date(System.currentTimeMillis()) ;String todayStr =df1.format(todayDate) ;//得到当前的年月日/**接下来得到四个比较时间的String类型；分别在00点，06点，12点和18点**/StringcompareTimeStr1 = todayStr+"00";StringcompareTimeStr2 = todayStr+"06";StringcompareTimeStr3 = todayStr+"12";StringcompareTimeStr4 = todayStr+"18";/**接下来得到四个比较时间的date类型**/DateFormat df2 = new SimpleDateFormat("yyyyMMddHH");Date compareTime1 = df2.parse(compareTimeStr1) ;Date compareTime2 = df2.parse(compareTimeStr2) ;Date compareTime3 = df2.parse(compareTimeStr3) ;Date compareTime4 = df2.parse(compareTimeStr4) ;/**接下来由当前系统时间和四个参照时间进行比较,找出该下载的文件名**/if(currentTime.after(compareTime1)&&currentTime.before(compareTime2)){//此时应该下载00点的文件,文件名为:compareTimeStr1System.out.println("此时要下载的文件名为:"+compareTimeStr1+".zip") ;return compareTimeStr1 ;}else if(currentTime.after(compareTime2)&&currentTime.before(compareTime3)){//此时应该下载06点的文件,文件名为:compareTimeStr2System.out.println("此时要下载的文件名为:"+compareTimeStr2+".zip") ;return compareTimeStr2;}else if(currentTime.after(compareTime3)&&currentTime.before(compareTime4)){//此时应该下载12点的文件,文件名为:compareTimeStr3System.out.println("此时要下载的文件名为:"+compareTimeStr3+".zip") ;return compareTimeStr3 ;}else if(currentTime.after(compareTime4)){//此时应该下载18点的文件,文件名为:compareTimeStr4System.out.println("此时要下载的文件名为:"+compareTimeStr4+".zip") ;return compareTimeStr4 ;}else{//nothing to doreturn null ;}}/** * 判断此时是否需要下载文件 * @param wantFileName,此时该下载的文件名; localFileNameArray ,本地已经有的文件名 * @return ture--需要下载; false--本地已经有了,不需要下载 * **/public static boolean ifToDownLoadFile(String wantFileName,String[] localFileNameArray){if(wantFileName==null&&localFileNameArray==null){//当想要下载的文件名获得失败return false ;}else if(wantFileName==null&&localFileNameArray!=null){//当想要下载的文件名获得失败return false ;}else if(wantFileName!=null&&localFileNameArray==null){//当本地没有已下载的文件return true ;}else if(wantFileName!=null&&localFileNameArray!=null){//当要下载的文件在本地还没有if(localFileNameArray.length>0){for(int i=0; i<localFileNameArray.length; i++){if(localFileNameArray.equals(wantFileName+".zip")){return false ;}}return true ;}else{return true ;}}else{return false ;}}public static void main(String args[]){try {FtpZipOption.downLoadZipFile() ;} catch (Exception e) {e.printStackTrace();}}}
页:
[1]