文章摘要
这篇文章描述了一个Java类`UploadServlet`，它是用作一个文件上传Servlet。该类的主要功能包括：
1. **文件上传设置**：通过`ServletContext`设置上传文件的路径和临时文件的路径，并创建临时文件夹。
2. **文件上传处理**：使用`ServletFileUpload`工具解析上传的数据，将每个文件提取出来进行处理。处理过程中，会检查文件是否是表单提交数据，并验证文件扩展名是否合法。
3. **文件上传逻辑**：对于每个合法的文件，会读取文件内容并写入本地存储。上传完成后，将文件信息（如文件名、大小、扩展名和保存路径）保存到数据库中。
4. **错误处理**：如果遇到文件大小或总上传量超出限制的情况，会抛出异常并显示错误信息，同时重传错误。
5. **进度监控**：通过`ProgressListener`监听文件上传进度，并向客户端展示下载进度。
6. **异常处理**：在上传过程中，如果发生异常（如文件大小超限），会重传错误并跳转到错误页面。
这篇文章的核心内容是围绕文件上传的逻辑实现，包括上传设置、文件处理、错误处理和进度监控。
package servlet.upload;
import dao.upload.AccessoryDao;
import entity.upload.EntityAccessory;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadBase;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.ProgressListener;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Calendar;
import java.util.Iterator;
import java.util.List;
import java.util.UUID;
@WebServlet(“/UploadServlet”)
public class UploadServlet extends HttpServlet {
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
//设置文件上传基本路径
String savePath=this.getServletContext().getRealPath(“/WEB-INF/uploadFiles”);
//设置临时文件路径
String tempPath=this.getServletContext().getRealPath(“/WEB-INF/tempFiles”);
File tempFile=new File(tempPath);
if (!tempFile.exists()) {
tempFile.mkdir();
}
//定义异常消息
String errorMessage=””;
//创建file items工厂
DiskFileItemFactory factory=new DiskFileItemFactory();
//设置缓冲区大小
factory.setSizeThreshold(1024 * 100);
//设置临时文件路径
factory.setRepository(tempFile);
//创建文件上传处理器
ServletFileUpload upload=new ServletFileUpload(factory);
//监听文件上传进度
ProgressListener progressListener=new ProgressListener() {
public void update(long pBytesRead, long pContentLength, int pItems) {
System.out.println(“正在读取文件： ” + pItems);
if (pContentLength==-1) {
System.out.println(“已读取： ” + pBytesRead + ” 剩余0″);
} else {
System.out.println(“文件总大小：” + pContentLength + ” 已读取：” + pBytesRead);
}
}
};
upload.setProgressListener(progressListener);
//解决上传文件名的中文乱码
upload.setHeaderEncoding(“UTF-8″);
//判断提交上来的数据是否是上传表单的数据
if (!ServletFileUpload.isMultipartContent(request)) {
//按照传统方式获取数据
return;
}
//设置上传单个文件的大小的最大值，目前是设置为1024*1024字节，也就是1MB
//upload.setFileSizeMax(1024 * 1024);
//设置上传文件总量的最大值，最大值=同时上传的多个文件的大小的最大值的和，目前设置为10MB
upload.setSizeMax(1024 * 1024 * 10);
try {
//使用ServletFileUpload解析器解析上传数据，解析结果返回的是一个List<FileItem>集合，每一个FileItem对应一个Form表单的输入项
List<FileItem> items=upload.parseRequest(request);
Iterator<FileItem> iterator=items.iterator();
while (iterator.hasNext()) {
FileItem item=iterator.next();
//判断jsp提交过来的是不是文件
if (item.isFormField()) {
errorMessage=”请提交文件！”;
break;
} else {
//文件名
String fileName=item.getName();
if (fileName==null || fileName.trim()==””) {
System.out.println(“文件名为空！”);
}
//处理不同浏览器提交的文件名带路径问题
fileName=fileName.substring(fileName.lastIndexOf(“\”) + 1);
//文件大小
Long fileSize=item.getSize();
//文件扩展名
String fileExtension=fileName.substring(fileName.lastIndexOf(“.”) + 1);
//判断扩展名是否合法
if (!validExtension(fileExtension)) {
errorMessage=”上传文件非法！”;
item.delete();
break;
}
//获得文件输入流
InputStream in=item.getInputStream();
//得到保存文件的名称
String saveFileName=createFileName(fileName);
//得到文件保存路径
String realFilePath=createRealFilePath(savePath, saveFileName);
//创建文件输出流
FileOutputStream out=new FileOutputStream(realFilePath);
//创建缓冲区
byte buffer[]=new byte[1024];
int len=0;
while ((len=in.read(buffer)) > 0) {
//写文件
out.write(buffer, 0, len);
}
//关闭输入流
in.close();
//关闭输出流
out.close();
//删除临时文件
item.delete();
<span style=”color:#FF0000;”>//将上传文件信息保存到附件表中
EntityAccessory entity=new EntityAccessory();
entity.setFileName(fileName);
entity.setFileSize(fileSize);
entity.setFile_ext_name(fileExtension);
entity.setFilePath(realFilePath);
AccessoryDao.add(entity);</span>
}
}
} catch (FileUploadBase.FileSizeLimitExceededException e) {
e.printStackTrace();
errorMessage=”单个文件超出最大值！！！”;
} catch (FileUploadBase.SizeLimitExceededException e) {
e.printStackTrace();
errorMessage=”上传文件的总的大小超出限制的最大值！！！”;
} catch (FileUploadException e) {
e.printStackTrace();
errorMessage=”文件上传失败！！！”;
} finally {
<span style=”color:#FF0000;”>if (!””.equals(errorMessage)) {
request.setAttribute(“errorMessage”, errorMessage);
request.getRequestDispatcher(“pages/upload/error.jsp”).forward(request, response);
} else {
response.sendRedirect(“listUploadedFiles”);
}</span>
}
}
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
doGet(request, response);
}
private boolean validExtension(String fileExtension) {
String[] exts=