从FTP上下载文件并打成ZIP包给用户下载

司寇6966

//从FTP上下载文件并打成ZIP包给用户下载   
FTPClient ftpClient = null;   
ZipOutputStream zipOut = null;   
try {   
// 创建ftp连接对象   
ftpClient = new FTPClient();   
ftpClient.connect(FtpContants.FTP_IP, FtpContants.FTP_PORT);   
// 登陆ftp服务器   
ftpClient.login(FtpContants.FTP_USERNAME, FtpContants.FTP_PWD);   
// 设置文件的传输类型，默认是ASCII，修改为二进制   
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);   
// printWorkingDirectory是用户的工作目录   
String basePath = ftpClient.printWorkingDirectory() + "/download/data";   
// 切换到指定目录中，如果切换失败说明目录不存在   
boolean boo = ftpClient.changeWorkingDirectory(basePath);   
// 如果切换路径失败，说明拼接的路径有问题，抛出异常   
if (!boo) {   
LogUtil.printErrorLog("the directory does not exist ,"  
+ "or the user don't hava the enterence to this directory " + basePath);   
return;   
}   
// 这个方法的意思就是每次数据连接之前,ftp client告诉ftp server开通一个端口来传输数据   
ftpClient.enterLocalPassiveMode();   
// 遍历路径下的所有文件   
FTPFile[] fileList = ftpClient.listFiles();   
response.reset();   
// 设置导出文件头   
response.setContentType("application/octet-stream");   
response.setHeader("Content-Disposition",   
"attachment;filename=" + new String(zipFileName.getBytes(LANGUE_GBK), LANGUE_ISO));   
// 定义Zip输出流   
zipOut = new ZipOutputStream(response.getOutputStream());   
byte[] byteReader = new byte[BYTE_INIT_SIZE];   
ByteArrayOutputStream os = null;   
for (FTPFile tempFile : fileList) {   
if (tempFile.isFile()) {   
os = new ByteArrayOutputStream();   
String downFileName = new String(tempFile.getName().getBytes(LANGUE_GBK), LANGUE_ISO);   
// 从FTP上下载downFileName该文件把该文件转化为字节数组的输出流   
ftpClient.retrieveFile(downFileName, os);   
byte[] bytes = os.toByteArray();   
InputStream ins = new ByteArrayInputStream(bytes);   
int len;   
zipOut.putNextEntry(new ZipEntry(tempFile.getName()));   
// 读入需要下载的文件的内容，打包到zip文件   
while ((len = ins.read(byteReader)) > 0) {   
zipOut.write(byteReader, 0, len);   
}   
}   
}   
zipOut.flush();   
} catch (IOException e) {   
LogUtil.printErrorLog(e.getMessage());     
} finally {   
// 关闭ftp连接   
if (null != ftpClient) {   
try {   
ftpClient.disconnect();   
} catch (IOException e) {   
LogUtil.printErrorLog("close Ftp connection error :" + e.getMessage());   
}   
}   
// 关闭zip文件输出流   
if (null != zipOut) {   
try {   
zipOut.closeEntry();   
zipOut.close();   
} catch (IOException e) {   
LogUtil.printErrorLog("close ZipOutputStream connection error :" + e.getMessage());   
}   
}   
}