网络多媒体资源管理信息系统的开发

   else
   {
    session.setAttribute("user", userDTO);
  req.getRequestDispatcher("/WEB-INF/jsp/main.html").forward(req, resp);
   }
}
}
6. Filter
package com.icss.mms.filter;
/**
* io包
*/
import java.io.IOException;
/**
* servlet 包
*/
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
/**
* 字符编码的过滤
* @author WangHui
*/
public class CharacterFilter implements Filter {
  private String encoding = null;
  public void destroy() {
  }
  /**
   * 过滤器
   */
  Public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
   request.setCharacterEncoding(encoding);
   response.setCharacterEncoding(encoding);
   chain.doFilter(request, response);
  }
  /**
   * 初始化
   */
  public void init(FilterConfig filterConfig) throws ServletException {
   encoding = filterConfig.getInitParameter("encoding");
  }
}
7. 文件上传
package com.icss.mms.fileupload;
/**
* io包
*/
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
/**
* util 包
*/
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
/**
* servlet 包
*/
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
/**
* 上传文件
* @author WangHui
*
*/
public class FileUploadModel {
private static final long serialVersionUID = 2210691849912154951L;
private static final String regFile = "Content-Disposition: form-data; name=\".*\"; filename=\".*\"";
private static final String regArgu = "Content-Disposition: form-data; name=\".*\"";
private static final int DEFAULT_SIZE = 1024;
private byte[] buffer = null;
private int size;
private String fileName = null;
private String boundaryString = null;
private String endBoundaryString = null;
private Map<String, String> map = new HashMap<String, String>();
  private List<String> paths = new ArrayList<String>();
  private String savePath = null;
  private BufferedOutputStream output = null;
  private ServletInputStream input = null;
  public FileUploadModel() {
   this.size = DEFAULT_SIZE;
  }
  public String getFileName() {
   return this.fileName;
  }
  public void setCacheSize(int size) {
   this.size = size;
  }
  /**
   * @param param
   * @return
   */
  public String getParemeter(String param) {
   String parameter = null;
   if (map.containsKey(param))
    parameter = map.get(param);
   return parameter;
  }
  /**
   * @param savePath
   */
  public void setSavePath(String savePath) {
   this.savePath = savePath;
  }
    /**
     * @param req
     * @throws Exception
     */
  public void upload(HttpServletRequest req) throws Exception {
   upload(req, null);
  }
  /**
   * @param req
   * @param savePath
   * @throws Exception
   */
  public void upload(HttpServletRequest req, String savePath)
    throws Exception {
   if (savePath != null)
    setSavePath(savePath);
    setBoundary(req);
    writeToFile(req);
  }
  /**
   * @param req
   */
  private void setBoundary(HttpServletRequest req) {
   String contentType = req.getHeader("content-type");
   int index = contentType.indexOf("=-") + 1;
   contentType = contentType.substring(index);
   boundaryString = "--" + contentType;
   endBoundaryString = boundaryString + "--";
  }
  /**
   * @throws SavePathException
   */
  private void checkSavePath() throws SavePathException {
   if (savePath == null || savePath.trim().equals("")) {
    throw new SavePathException("The savePath is invalid");
   }
  }
   /**
    * @return
    * @throws FileNotFoundException
    */
  private BufferedOutputStream createOutputStream()
    throws FileNotFoundException {
   BufferedOutputStream bos = null;
   String path =savePath + "/" + createUUID() + "_" + fileName;
   File outFile = new File(path);
   OutputStream fos = new FileOutputStream(outFile);
   bos = new BufferedOutputStream(fos);
   paths.add(path);
   return bos;
  }
    /**
     * @return
     */
  private String createUUID(){
   return UUID.randomUUID().toString();
  }
  /**
   * @param req
   * @throws IOException
   */
  private void createInputStream(HttpServletRequest req) throws IOException {
   input = req.getInputStream();
  }
  private void initBuffer() {
   buffer = new byte[size];
  }
  /**
   * 写入文件
   * @param req
   * @throws Exception
   */
  private void writeToFile(HttpServletRequest req) throws Exception {        checkSavePath();
   createInputStream(req);
   initBuffer();
   String fileContent = null;
   String line = null;
   int i = input.readLine(buffer, 0, buffer.length);
   line = new String(buffer, 0, i);
   boolean flag = true;
   boolean flagToWhile = true;
   while (i != -1) {
    flag = true;
    if (boundaryString.equals(line.trim())) {
     int j = input.readLine(buffer, 0, buffer.length);
     line = new String(buffer, 0, j);
     if (line.trim().matches(regFile)) {
      fileName = line.substring(
        line.trim().lastIndexOf("=\"") + 2, line.trim()
          .lastIndexOf("\""));
      input.readLine(buffer, 0, buffer.length);
      input.readLine(buffer, 0, buffer.length);
      j = input.readLine(buffer, 0, buffer.length);
      fileContent = new String(buffer, 0, j);
      /**
       * 验证请求头部是否有文件内容存在
       */
     if(fileContent != null && !fileContent.trim().equals("")) {
       flagToWhile = true;
       output = createOutputStream();
      } else {
       j = input.readLine(buffer, 0, buffer.length);
       line = new String(buffer, 0, j);
       flagToWhile = false;
       flag = false;
      }
      while (flagToWhile) {
if(boundaryString.equals(fileContent.trim())|| endBoundaryString.equals(fileContent.trim())) {
        line = fileContent;
        flag = false;
        output.flush();
        output.close();
        break;
       } else {
        output.write(buffer, 0, j);
       }
       j = input.readLine(buffer, 0, buffer.length);
       fileContent = new String(buffer, 0, j);
      }
     }
     if (line.trim().matches(regArgu)) {
      String name = line.substring(line.trim().indexOf("\"") + 1,
        line.trim().lastIndexOf("\""));
      input.readLine(buffer, 0, buffer.length);
      j = input.readLine(buffer, 0, buffer.length);
      String value = new String(buffer, 0, j).trim();
      map.put(name, value);
     }
    }
    if (flag) {
     i = input.readLine(buffer, 0, buffer.length);
     if (i != -1)
      line = new String(buffer, 0, i);
    }
   }
  }
}
8. 文件下载
package com.icss.mms.filedownload;
/**
* io包
*/
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.OutputStream;
/**
* net包
*/
import java.net.URLEncoder;
/**
* util 包
*/
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;
/**
* 文件下载
* @author WangHui
*/
public class FileDownLoadModel {
  private List<File> files;
  private ZipOutputStream out;
  /**
   * 下载模型
   * @param srcFiles
   * @param out
   */
  public FileDownLoadModel(File[] srcFiles, OutputStream out){
   this.files = new ArrayList<File>();
   addFile(srcFiles);
   this.out = new ZipOutputStream(out);
  }
  public void addFile(File[] files){
   for(int i = 0; i<files.length; i++){
    addFile(files[i]);
   }
  }
    /**
     * @param file
     */
  public void addFile(File file){
   this.files.add(file);
  }
  /**
   * 下载出压缩文件
   */
  public void writeZipFilesToStream(){
   byte[] b = new byte[1024];
   try{
for(Iterator<File> ite = files.iterator(); ite.hasNext(); ){
   File file = ite.next();
BufferedInputStream in = new BufferedInputStream(new FileInputStream(file));
ZipEntry zip = new ZipEntry(URLEncoder.encode(file.getName(), "UTF-8"));
     out.putNextEntry(zip);
     int length;
     while((length = in.read(b))!=-1){
      out.write(b,0,length);
     }
     out.closeEntry();
     in.close();
    }
    out.close();
   } catch(Exception e){
    e.printStackTrace();
    System.out.println("文件下载流异常中断!");
   }
  }
}

首页上一页 2 3 4 5 下一页尾页 5/5/5

网络多媒体资源管理信息系统的开发(五)