上传下载

public ActionForward ftpUpload(ActionMapping mapping, ActionForm form,
HttpServletRequest request, HttpServletResponse response) throws IOException, FileUploadException {
String title = URLDecoder.decode(
request.getParameter("title") == null ? "" : request.getParameter("title"), "UTF-8");

String pxh  = request.getParameter("pxh");
String xtsoft = ApplicationPath.getInstance().param.getProperty("xtsoft");
String person_picuterPath = File.separator + xtsoft;

DiskFileItemFactory factory = new DiskFileItemFactory();
long allowedUploadSize = Long.parseLong(this.getAllowedUploadSize()) * 1024 * 1024;
factory.setSizeThreshold(4096);// 设置缓冲
// factory.setRepository(new File(""));// 设置缓冲区目录,默认是new
// File(System.getProperty("java.io.tmpdir"))
//System.out.println("临时文件所在路径:"+System.getProperty("java.io.tmpdir"));
ServletFileUpload sfu = new ServletFileUpload(factory);
sfu.setSizeMax(allowedUploadSize);
List items = new ArrayList();


try {
items = sfu.parseRequest(request);
} catch (SizeLimitExceededException e1) {
e1.printStackTrace();
String msgs = "<script>parent.close();parent.window.dialogArguments.alert('上传的文档不能超过"
+ Integer.parseInt(this.getAllowedUploadSize())
+ "M');" + "</script>";

request.setAttribute("message",msgs);
return mapping.findForward("upLoadMessage");
}

for (Iterator iterator = items.iterator(); iterator.hasNext();) {

FileItem fileItem= (FileItem) iterator.next();

if( !fileItem.isFormField())  //只有是文件上传的时候，才进行保存数据库
{
String picTitle = "";
String picType = "";
GUID userId = new GUID();

String picFileName = fileItem.getName();
String person_picuterPath1 = "";
byte[] picdata = new byte[0];
String picPath ="";
if (picFileName != null && !"".equals(picFileName)) {
int i = picFileName.lastIndexOf(".");

if (i != -1) {
picTitle = fileItem.getName().substring(
fileItem.getName().lastIndexOf("\\") + 1,
fileItem.getName().length());

picTitle = picTitle.substring(0,picTitle.lastIndexOf("."));

picType =  picFileName.substring(
picFileName.lastIndexOf(".") + 1, picFileName
.length());
}
picPath = userId + "." + picType;

}


person_picuterPath1 = person_picuterPath + File.separator + picPath;  //相对路径

FTPUtils ftpUtils = new FTPUtils();

if (ftpUtils.connect()) {
BufferedInputStream bis = new BufferedInputStream(fileItem.getInputStream());
ftpUtils.storeFile(person_picuterPath1, bis);

ftpUtils.close();
}

// try {
// int i = -1;
// InputStream in = fileItem.getInputStream();
// BufferedInputStream out = new BufferedInputStream();
// while ((i = in.read()) != -1) {
// out.write(i);
// }
// picdata = out.toByteArray();
// in.close();
// out.close();
// } catch (FileNotFoundException e) {
// e.printStackTrace();
// } catch (IOException e) {
// e.printStackTrace();
// }

if (fileItem.getInputStream()!=null) {
// uploadTools.uploadFile(person_picuterPath1, picdata);
// int pxh = xtSoftService.getmaxID("pxh", "xt_soft");
XtSoft soft = new XtSoft();
soft.setId(userId.toString());
soft.setTitle(title);
soft.setFileType(picType);
soft.setFileName(picPath);
soft.setPxh(Long.valueOf(String.valueOf(pxh)).longValue());
xtSoftService.AddXtSoft(soft);
}

}

}
request.setAttribute("message","上传成功！");
return mapping.findForward("upLoadMessage");

}



**********************************************************

public ActionForward FtpDownloadAttachment(ActionMapping mapping, ActionForm form,
HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {

String attchId = request.getParameter("attchId");
String fileType = request.getParameter("fileType");
String xtsoft = ApplicationPath.getInstance().param.getProperty("xtsoft");
String person_picuterPath1 = File.separator + xtsoft + File.separator + attchId+"."+fileType;  //相对路径

String path = ApplicationPath.getInstance().param.getProperty("DiskPath");
path = StringTools.replaceAll(path,"\\",File.separator);
path = StringTools.replaceAll(path,"/",File.separator);
BufferedOutputStream bos = null; 
FileInputStream fis = null; 

if (attchId != null && !"".equals(attchId)) { 
try {  

String reName = xtSoftService.getAttchmentName(attchId);
reName = reName+"."+fileType;
// String disposition = "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8");//注意(1) 

String   reponsefileName = new String(reName.getBytes("GBK"),"ISO8859_1");     
response.setHeader("Content-Disposition", "attachment;filename="+ reponsefileName);

response.setContentType("application/x-msdownload;charset=UTF-8");//注意(2) 
//   response.setHeader("Content-disposition", disposition); 

// fis = new FileInputStream(path +File.separator+ fileName); 
bos = new BufferedOutputStream(response.getOutputStream()); 
  
byte[] buffer = new byte[2048]; 

buffer = uploadTools.downloadFile(File.separator+ person_picuterPath1);
int n = 0;

// while ((n = fis.read(buffer))  != -1)
bos.write(buffer, 0, buffer.length);

bos.flush();
bos.close();
// fis.close();
} catch (IOException e) { 
e.printStackTrace(); 
}
} 
return null;

}


*******************************************************

/**
* 返回允许上传的大小,单位为M.要验证是否是数字
*
* @return
*/
private String getAllowedUploadSize() {
String sizeStr = "100";
InputStream in = null;
try {
in = this.getClass().getResourceAsStream("/app.properties");
Properties p = new Properties();
p.load(in);
sizeStr = p.getProperty("AllowedUploadSize");
if (sizeStr == null || sizeStr.trim().length() == 0) {
sizeStr = "100";
}
Integer.parseInt(sizeStr);
} catch (IOException e) {
e.printStackTrace();
} catch (NumberFormatException e) {
e.printStackTrace();
sizeStr = "100";
} finally {
try {
in.close();
} catch (Exception e) {
e.printStackTrace();
}
}
return sizeStr;

}