package downloadMap;
import java.io.BufferedInputStream;
import java.io.IOException;
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 javax.swing.JOptionPane;
import javax.swing.ProgressMonitorInputStream;
import TIp.Jframet;
import doFile.ZipToFile;
import sun.net.TelnetInputStream;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;
public class FtpZipOption {
/**
*
* 從ftp服務(wù)器下載zip文件
*
* @param
*
*@throws Exception
**/
public static void downLoadZipFile(String wantFileName ) throws Exception {
/*new Thread(){
public void run(){
Jframet jf = new Jframet("正在鏈接ftp,qing'shao'h", "確定");
jf.jb.setVisible(false);
}
}.start();*/
String[] localFileNameArray = getLocalFileNameArray("c:\\BaseMap");// 得到所有已經(jīng)下載的
tb文件名
File downFile=new File("c:\\BaseMap");
if(!downFile.exists()) downFile.mkdir();
if (ifToDownLoadFile(wantFileName, localFileNameArray)) {// 判斷是否需要下載
String str; // 輸出信息字符串
/**
*
* 和服務(wù)器建立連接
*/
FtpClient ftp = new FtpClient("172.18.2.66"); // 根據(jù)服務(wù)器ip建立連接
//JOptionPane.showMessageDialog(null, "");
str = ftp.getResponseString(); // 獲得響應(yīng)信息
System.out.println("連接服務(wù)器:" + str);
/**
*
* 登陸到Ftp服務(wù)器
*/
ftp.login("admin", "1"); // 根據(jù)用戶名和密碼登錄服務(wù)器
str = ftp.getResponseString();
System.out.println("登錄:" + str);
/**
*
* 打開并定位到服務(wù)器目錄
*/
ftp.cd("mapdata2"); // 打開服務(wù)器上的文件目錄
str = ftp.getResponseString();
System.out.println("打開服務(wù)器目錄:" + str);
ftp.binary();// 轉(zhuǎn)化為二進(jìn)制的文件
TelnetInputStream ftpIn = ftp.get(wantFileName + ".zip");// 找到要讀取的文件
/*Jframet jf=new Jframet("正在下載地圖，請稍候...","確定");
jf.jb.setVisible(false);*/
long fileLength=FtpZipOption.getFileSize("wantFileName.zip");
System.out.println(fileLength);
byte[] buf = new byte[204800];
int bufsize = 0;
File f=new File("c:\\BaseMap");
if(!f.exists()) f.mkdirs();
String toLocalPath = "c:\\BaseMap\\" + wantFileName + ".zip";
/*File f=new File(toLocalPath);
f.mkdirs();*/
FileOutputStream ftpOut = new FileOutputStream(toLocalPath);
int readLine=0;
while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) {
//System.out.println(bufsize);
ftpOut.write(buf, 0, bufsize);
readLine=+bufsize;
}
System.out.println(readLine);
ftpOut.close();
ftpIn.close();
ZipToFile ziptofile=new ZipToFile();
String PostFilePath = "c:\\BaseMap";
ziptofile.zipToFile(toLocalPath, PostFilePath);
// JOptionPane.showMessageDialog(null, "下載" + wantFileName + ".zip完成!");
System.out.println("下載" + wantFileName + ".zip完成!");
/* jf.jl.setText("下載地圖成功");
jf.jb.setVisible(true);*/
} else {
}
}
public static long getFileSize(String filename) throws IOException {
String str; // 輸出信息字符串
/**
*
* 和服務(wù)器建立連接
*/
FtpClient ftp = new FtpClient("172.18.2.66"); // 根據(jù)服務(wù)器ip建立連接
str = ftp.getResponseString(); // 獲得響應(yīng)信息
System.out.println("連接服務(wù)器:" + str);
/**
*
* 登陸到Ftp服務(wù)器
*/
ftp.login("admin", "1"); // 根據(jù)用戶名和密碼登錄服務(wù)器
str = ftp.getResponseString();
System.out.println("登錄:" + str);
/**
*
* 打開并定位到服務(wù)器目錄
*/
ftp.cd("mapdata2"); // 打開服務(wù)器上的文件目錄
str = ftp.getResponseString();
System.out.println("打開服務(wù)器目錄:" + str);
ftp.binary();// 轉(zhuǎn)化為二進(jìn)制的文件
long fileSize = -1;
String s = "SIZE " + filename + "\r\n";
ftp.sendServer(s);
try {
int status = ftp.readServerResponse();
if (status == 213) {
String msg = ftp.getResponseString();
fileSize = Long.parseLong(msg.substring(3).trim());
}
} catch (IOException e) {
e.printStackTrace();
}
return fileSize;
}
// 上傳文件;并返回上傳文件的信息
/*private static String upLoadZipToServer(String filename) throws Exception {
String str; // 輸出信息字符串
String timeStr = getNowTime();// 獲得當(dāng)前時(shí)間
String recordStr = "上傳時(shí)間:" + timeStr + "\r\n";// 信息記錄字符串
*//**
*
* 和服務(wù)器建立連接
*//*
FtpClient ftp = new FtpClient("192.168.39.189"); // 根據(jù)服務(wù)器ip建立連接
str = ftp.getResponseString(); // 獲得響應(yīng)信息
System.out.println(str);
recordStr += "連接服務(wù)器:" + str + "\r\n";
*//**
*
* 登陸到Ftp服務(wù)器
*//*
ftp.login("test", "test"); // 根據(jù)用戶名和密碼登錄服務(wù)器
str = ftp.getResponseString();
System.out.println(str);
recordStr += "登錄:" + str + "\r\n";
*//**
*
* 打開并定位到test目錄
*//*
ftp.cd("uptest"); // 打開服務(wù)器上的test文件夾
ftp.binary();// 轉(zhuǎn)化為二進(jìn)制的文件
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[1024];
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(文件夾目錄)下所有文件，包括子目錄
*
* @param sourceFile
* ,待壓縮目錄; toFolerName,壓縮完畢生成的目錄
*
* @throws Exception
*/
/*public static void fileToZip(String sourceFile, String toFolerName)
throws Exception {
List fileList = getSubFiles(new File(sourceFile)); // 得到待壓縮的文件夾的所有內(nèi)容
ZipOutputStream zos = new ZipOutputStream(new FileOutputStream(
toFolerName));
ZipEntry ze = null;
byte[] buf = new byte[1024];
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[1024];
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為參數(shù)得到一個(gè)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("已經(jīng)解壓出:" + ze.getName());
}
zfile.close();
}
*//**
*
* 給定根目錄，返回另一個(gè)文件名的相對路徑，用于zip文件中的路徑.
*
* @param baseDir
* java.lang.String 根目錄
*
* @param realFileName
* java.io.File 實(shí)際的文件名
*
* @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;
else
ret = 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;
}
*//**
*
* 給定根目錄，返回一個(gè)相對路徑所對應(yīng)的實(shí)際文件名.
*
* @param zippath
* 指定根目錄
*
* @param absFileName
* 相對路徑名，來自于ZipEntry中的name
*
* @return java.io.File 實(shí)際的文件
*//*
private static File getRealFileName(String zippath, String absFileName) {
String[] dirs = absFileName.split("/", absFileName.length());
File ret = new File(zippath);// 創(chuàng)建文件對象
if (dirs.length > 1) {
for (int i = 0; i < dirs.length - 1; i++) {
ret = new File(ret, dirs);
}
}
if (!ret.exists()) {// 檢測文件是否存在
ret.mkdirs();// 創(chuàng)建此抽象路徑名指定的目錄
}
ret = new File(ret, dirs[dirs.length - 1]);// 根據(jù) ret 抽象路徑名和 child
// 路徑名字符串創(chuàng)建一個(gè)新 File 實(shí)例
return ret;
}
*/
/**
*
* 取得ftp服務(wù)器上某個(gè)目錄下的所有文件名
*
* @param ftp
* , FtpClient類實(shí)例; folderName,服務(wù)器的文件夾名
*
* @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;
}
/**
*
* 得到已經(jīng)下載的目錄下的所有文件名的數(shù)組
*
* @param localPath
* 本地的下載文件保存路徑
*
* @return 該路徑下所有tb文件名
*
* **/
private static String[] getLocalFileNameArray(String localPath) {
File diskFile = new File(localPath);
if (diskFile != null) {
String[] fileNameList = diskFile.list();
return fileNameList;
} else {
return null;
}
}
/**
*
*獲得當(dāng)前系統(tǒng)時(shí)間
*/
/*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 static String getWantFileName() throws Exception {
*//** 得到當(dāng)前的系統(tǒng)精確時(shí)間 **//*
Date currentTime = new Date(System.currentTimeMillis());
*//** 接下來得到系統(tǒng)當(dāng)前的年月日 **//*
DateFormat df1 = new SimpleDateFormat("yyyyMMdd");
Date todayDate = new Date(System.currentTimeMillis());
String todayStr = df1.format(todayDate);// 得到當(dāng)前的年月日
*//** 接下來得到四個(gè)比較時(shí)間的String類型；分別在00點(diǎn)，06點(diǎn)，12點(diǎn)和18點(diǎn) **//*
String compareTimeStr1 = todayStr + "00";
String compareTimeStr2 = todayStr + "06";
String compareTimeStr3 = todayStr + "12";
String compareTimeStr4 = todayStr + "18";
*//** 接下來得到四個(gè)比較時(shí)間的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);
*//** 接下來由當(dāng)前系統(tǒng)時(shí)間和四個(gè)參照時(shí)間進(jìn)行比較,找出該下載的文件名 **//*
if (currentTime.after(compareTime1) && currentTime.before(compareTime2)) {
// 此時(shí)應(yīng)該下載00點(diǎn)的文件,文件名為:compareTimeStr1
System.out.println("此時(shí)要下載的文件名為:" + compareTimeStr1 + ".zip");
return compareTimeStr1;
} else if (currentTime.after(compareTime2)
&& currentTime.before(compareTime3)) {
// 此時(shí)應(yīng)該下載06點(diǎn)的文件,文件名為:compareTimeStr2
System.out.println("此時(shí)要下載的文件名為:" + compareTimeStr2 + ".zip");
return compareTimeStr2;
} else if (currentTime.after(compareTime3)
&& currentTime.before(compareTime4)) {
// 此時(shí)應(yīng)該下載12點(diǎn)的文件,文件名為:compareTimeStr3
System.out.println("此時(shí)要下載的文件名為:" + compareTimeStr3 + ".zip");
return compareTimeStr3;
} else if (currentTime.after(compareTime4)) {
// 此時(shí)應(yīng)該下載18點(diǎn)的文件,文件名為:compareTimeStr4
System.out.println("此時(shí)要下載的文件名為:" + compareTimeStr4 + ".zip");
return compareTimeStr4;
} else {
// nothing to do
return null;
}
}
*/
/**
*
* 判斷此時(shí)是否需要下載文件
*
* @param wantFileName
* ,此時(shí)該下載的文件名; localFileNameArray ,本地已經(jīng)有的文件名
*
* @return ture--需要下載; false--本地已經(jīng)有了,不需要下載
*
* **/
public static boolean ifToDownLoadFile(String wantFileName,
String[] localFileNameArray) {
if (wantFileName == null && localFileNameArray == null) {// 當(dāng)想要下載的文件名獲得失敗
return false;
} else if (wantFileName == null && localFileNameArray != null) {// 當(dāng)想要下載的文件名獲得失敗
return false;
} else if (wantFileName != null && localFileNameArray == null) {// 當(dāng)本地沒有已下載的文件
return true;
} else if (wantFileName != null && localFileNameArray != null) {// 當(dāng)要下載的文件在本地還沒有
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 {
long aa=FtpZipOption.getFileSize("2.zip");
System.out.println(aa);
FtpZipOption.downLoadZipFile("2");
} catch (Exception e) {
e.printStackTrace();
}
}
}
這個(gè)是我從網(wǎng)上找的，可是下載2個(gè)G的壓縮包打不開，幾百兆的可以！求解