AJAX和JSP實(shí)現(xiàn)的基于WEB的文件上傳的進(jìn)度控制代碼第2/2頁(yè)
BackGroundService這個(gè)Servlet類負(fù)責(zé)接收Form Post數(shù)據(jù)、回應(yīng)狀態(tài)輪詢請(qǐng)求、處理取消文件上傳的請(qǐng)求。 盡管可以把這些功能相互分離開(kāi)來(lái),但為了簡(jiǎn)單明了,還是將它們放到Servlet中,只是由不同的方法進(jìn)行分割。 源代碼如下:
/** * 本例程演示了通過(guò)Web上傳文件過(guò)程中的進(jìn)度顯示。您可以對(duì)本例程進(jìn)行任何修改和使用。 * 如果需要轉(zhuǎn)載本例程,請(qǐng)您注明作者。 * * 作者: 劉作晨 * EMail:liuzuochen@gmail.com */ package liuzuochen.sample.upload;
/** * Title: 后臺(tái)服務(wù) * * Description: 為客戶端提供上傳及文件傳輸狀態(tài)查詢服務(wù) * */ import java.io.File; import java.io.IOException; import java.util.List; import javax.servlet.ServletException; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.fileupload.FileItem; import org.apache.commons.fileupload.FileUploadException; import org.apache.commons.fileupload.disk.DiskFileItemFactory; import org.apache.commons.fileupload.servlet.*; public class BackGroundService extends javax.servlet.http.HttpServlet implements javax.servlet.Servlet { public static final String UPLOAD_DIR = "/upload"; public static final String DEFAULT_UPLOAD_FAILURE_URL = "./result.jsp"; public BackGroundService() { super(); } protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doPost(request, response); } /** * 從文件路徑中取出文件名 */ private String takeOutFileName(String filePath) { int pos = filePath.lastIndexOf(File.separator); if (pos > 0) { return filePath.substring(pos + 1); } else { return filePath; } } /** * 從request中取出FileUploadStatus Bean */ public static FileUploadStatus getStatusBean( HttpServletRequest request) { BeanControler beanCtrl = BeanControler.getInstance(); return beanCtrl.getUploadStatus(request.getRemoteAddr()); } /** * 把FileUploadStatus Bean保存到類控制器BeanControler */ public static void saveStatusBean( HttpServletRequest request, FileUploadStatus statusBean) { statusBean.setUploadAddr(request.getRemoteAddr()); BeanControler beanCtrl = BeanControler.getInstance(); beanCtrl.setUploadStatus(statusBean); } /** * 刪除已經(jīng)上傳的文件 */ private void deleteUploadedFile(HttpServletRequest request) { FileUploadStatus satusBean = getStatusBean(request); for (int i = 0; i < satusBean.getUploadFileUrlList().size(); i++) { File uploadedFile = new File(request.getRealPath(UPLOAD_DIR) + File.separator + satusBean.getUploadFileUrlList(). get(i)); uploadedFile.delete(); } satusBean.getUploadFileUrlList().clear(); satusBean.setStatus("刪除已上傳的文件"); saveStatusBean(request, satusBean); } /** * 上傳過(guò)程中出錯(cuò)處理 */ private void uploadExceptionHandle( HttpServletRequest request, String errMsg) throws ServletException, IOException { //首先刪除已經(jīng)上傳的文件 deleteUploadedFile(request); FileUploadStatus satusBean = getStatusBean(request); satusBean.setStatus(errMsg); saveStatusBean(request, satusBean); } /** * 初始化文件上傳狀態(tài)Bean */ private FileUploadStatus initStatusBean(HttpServletRequest request) { FileUploadStatus satusBean = new FileUploadStatus(); satusBean.setStatus("正在準(zhǔn)備處理"); satusBean.setUploadTotalSize(request.getContentLength()); satusBean.setProcessStartTime(System.currentTimeMillis()); satusBean.setBaseDir(request.getContextPath() + UPLOAD_DIR); return satusBean; } /** * 處理文件上傳 */ private void processFileUpload(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { DiskFileItemFactory factory = new DiskFileItemFactory(); //設(shè)置內(nèi)存緩沖區(qū),超過(guò)后寫(xiě)入臨時(shí)文件 factory.setSizeThreshold(10240000); //設(shè)置臨時(shí)文件存儲(chǔ)位置 factory.setRepository(new File(request.getRealPath("/upload/temp"))); ServletFileUpload upload = new ServletFileUpload(factory); //設(shè)置單個(gè)文件的最大上傳值 upload.setFileSizeMax(102400000); //設(shè)置整個(gè)request的最大值 upload.setSizeMax(102400000); upload.setProgressListener(new FileUploadListener(request)); //保存初始化后的FileUploadStatus Bean saveStatusBean(request, initStatusBean(request)); String forwardURL = ""; try { List items = upload.parseRequest(request); //獲得返回url for (int i = 0; i < items.size(); i++) { FileItem item = (FileItem) items.get(i); if (item.isFormField()) { forwardURL = item.getString(); break; } } //處理文件上傳 for (int i = 0; i < items.size(); i++) { FileItem item = (FileItem) items.get(i); //取消上傳 if (getStatusBean(request).getCancel()) { deleteUploadedFile(request); break; } //保存文件 else if (!item.isFormField() && item.getName().length() > 0) { String fileName = takeOutFileName(item.getName()); File uploadedFile = new File(request.getRealPath(UPLOAD_DIR) + File.separator + fileName); item.write(uploadedFile); //更新上傳文件列表 FileUploadStatus satusBean = getStatusBean(request); satusBean.getUploadFileUrlList().add(fileName); saveStatusBean(request, satusBean); Thread.sleep(500); } } } catch (FileUploadException e) { uploadExceptionHandle(request, "上傳文件時(shí)發(fā)生錯(cuò)誤:" + e.getMessage()); } catch (Exception e) { uploadExceptionHandle(request, "保存上傳文件時(shí)發(fā)生錯(cuò)誤:" + e.getMessage()); } if (forwardURL.length() == 0) { forwardURL = DEFAULT_UPLOAD_FAILURE_URL; } request.getRequestDispatcher(forwardURL).forward(request, response); } /** * 回應(yīng)上傳狀態(tài)查詢 */ private void responseStatusQuery(HttpServletRequest request, HttpServletResponse response) throws IOException { response.setContentType("text/xml"); response.setHeader("Cache-Control", "no-cache"); FileUploadStatus satusBean = getStatusBean(request); response.getWriter().write(satusBean.toJSon()); } /** * 處理取消文件上傳 */ private void processCancelFileUpload(HttpServletRequest request, HttpServletResponse response) throws IOException { FileUploadStatus satusBean = getStatusBean(request); satusBean.setCancel(true); saveStatusBean(request, satusBean); responseStatusQuery(request, response); } protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { boolean isMultipart = ServletFileUpload.isMultipartContent(request); if (isMultipart) { processFileUpload(request, response); } else { request.setCharacterEncoding("UTF-8"); if (request.getParameter("uploadStatus") != null) { responseStatusQuery(request, response); } if (request.getParameter("cancelUpload") != null) { processCancelFileUpload(request, response); } } } }
這是一個(gè)單例類,它的功能是為客戶端保存文件上傳狀態(tài),這里我沒(méi)有使用Session來(lái)存儲(chǔ)文件上傳狀態(tài),因?yàn)閷?duì)于AJAX這種異步調(diào)用,服務(wù)器會(huì)開(kāi)啟不同的Session,所以無(wú)法通過(guò)Session保存文件上傳狀態(tài)。 我并不認(rèn)為這種方法最好,如果有更好的方法,歡迎大家一起討論。 源代碼如下:
/** * 本例程演示了通過(guò)Web上傳文件過(guò)程中的進(jìn)度顯示。您可以對(duì)本例程進(jìn)行任何修改和使用。 * 如果需要轉(zhuǎn)載本例程,請(qǐng)您注明作者。 * * 作者: 劉作晨 * EMail:liuzuochen@gmail.com */
package liuzuochen.sample.upload; /** * Title: 類控制器 * * Description: 主要作用是對(duì)FileUploadStatus進(jìn)行管理,為客戶端提供相應(yīng)的 * FileUploadStatus類對(duì)象。這是一個(gè)單例類。 * */ import java.util.Vector; public class BeanControler { private static BeanControler beanControler = new BeanControler(); private Vector vector = new Vector(); private BeanControler() { } public static BeanControler getInstance() { return beanControler; } /** * 取得相應(yīng)FileUploadStatus類對(duì)象的存儲(chǔ)位置 */ private int indexOf(String strID) { int nReturn = -1; for (int i = 0; i < vector.size(); i++) { FileUploadStatus status = (FileUploadStatus) vector.elementAt(i); if (status.getUploadAddr().equals(strID)) { nReturn = i; break; } } return nReturn; } /** * 取得相應(yīng)FileUploadStatus類對(duì)象 */ public FileUploadStatus getUploadStatus(String strID) { return (FileUploadStatus) vector.elementAt(indexOf(strID)); } /** * 存儲(chǔ)FileUploadStatus類對(duì)象 */ public void setUploadStatus(FileUploadStatus status) { int nIndex = indexOf(status.getUploadAddr()); if ( -1 == nIndex) { vector.add(status); } else { vector.insertElementAt(status, nIndex); vector.removeElementAt(nIndex + 1); } } /** * 刪除FileUploadStatus類對(duì)象 */ public void removeUploadStatus(String strID){ int nIndex = indexOf(strID); if(-1!=nIndex) vector.removeElementAt(nIndex); } }
客戶端我們采用Prototype框架。請(qǐng)下載。
AjaxWrapper.js對(duì)Prototype進(jìn)行了封裝。請(qǐng)下載分析
fileUpload.html是文件上傳界面。 請(qǐng)下載。
result.jsp是文件上傳結(jié)果顯示界面。 請(qǐng)下載
fileUpload.css是樣式文件。 源代碼如下:
body {
color:#000;
background-color:white;
font:15px Georgia, "Lucida Grande", Arial, sans-serif;
letter-spacing:0.01em;
margin:15px;
}
#controlPanel,#resultPanel{
width:700px;
margin:20px auto;
padding:25px;
border:3px solid gray;
-moz-border-radius:10px;
background:#f8f8f8;
}
#errorArea{
width:400px;
margin:20px auto;
padding:25px;
border:3px solid gray;
-moz-border-radius:10px;
background:red;
}
#normalMessageArea{
width:400px;
margin:20px auto;
padding:25px;
border:3px solid gray;
-moz-border-radius:10px;
background:yellow;
}
#progressBar { padding-top: 5px; }
#totalProgressBarBox {
width: 350px;
height: 20px;
border: 1px inset;
background: #eee;
}
#totalProgressBarBoxContent {
width: 0;
height: 20px;
border-right: 1px solid #444;
background: #9ACB34;
}
web.xml中完成Servlet的配置。
<?xml version="1.0" encoding="UTF-8"?>
<web-app id="WebApp_ID" version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
<display-name>AjaxPractice</display-name>
<servlet>
<description></description>
<display-name>BackGroundService</display-name>
<servlet-name>BackGroundService</servlet-name>
<servlet-class>liuzuochen.sample.upload.BackGroundService</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>BackGroundService</servlet-name>
<url-pattern>*.action</url-pattern>
</servlet-mapping>
<welcome-file-list>
<welcome-file>index.html</welcome-file>
<welcome-file>index.htm</welcome-file>
<welcome-file>index.jsp</welcome-file>
<welcome-file>default.html</welcome-file>
<welcome-file>default.htm</welcome-file>
<welcome-file>default.jsp</welcome-file>
</welcome-file-list>
</web-app>
整個(gè)程序到這里就介紹完了,希望它多少能為您的工作或?qū)W習(xí)帶來(lái)點(diǎn)兒幫助。