大文件在线上传(HTTP协议)

package ces.frame.module.HttpServlet.servlet; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.io.OutputStream; import java.io.RandomAccessFile; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.util.List; import java.util.ResourceBundle; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import ces.frame.module.HttpServlet.servlet.core.FileDownServ; import ces.frame.module.HttpServlet.servlet.core.FileUploadServ; public class ServletAction extends FileServlet{ ResourceBundle rb = ResourceBundle.getBundle("config"); String homepath_g = rb.getString("FILE_PATH"); File downfile = new File("D:\\bak\\test\\wz_djbf_sys.zip"); /** * 文件下载 * @param request * @param response */ public void down(HttpServletRequest request,HttpServletResponse response){ String subid = request.getParameter("subid")==null?"":request.getParameter("subid"); String filepath = downfile.getPath(); //指定文件读取位置 String skip = request.getParameter("skip")==null?"0":request.getParameter("skip"); long sk = Long.parseLong(skip); FileDownServ fds = new FileDownServ(); boolean bl = fds.down(filepath, response,sk); if(bl){ out(response, "true"); }else{ out(response, "false"); } System.out.println("============下载结束"); } /** * 文件下载 * @param request * @param response */ public void down1(HttpServletRequest request,HttpServletResponse response){ String filepath = request.getParameter("filepath")==null?"":request.getParameter("filepath"); //指定文件读取位置 String skip = request.getParameter("skip")==null?"0":request.getParameter("skip"); long sk = Long.parseLong(skip); FileDownServ fds = new FileDownServ(); boolean bl = fds.down(filepath, response,sk); if(bl){ out(response, "true"); }else{ out(response, "false"); } System.out.println("============下载结束"); } /** * 获取服务器文件名 * @param request * @param response */ public void getRemotFileName(HttpServletRequest request,HttpServletResponse response){ String filepath = downfile.getPath(); String name = new File(filepath).getName(); out(response, name); } /** * 文件上传 * @param request * @param response */ public void upload(HttpServletRequest request,HttpServletResponse response){ //文件名 String filename = request.getParameter("filename")==null?"":request.getParameter("filename"); //客户选择折文件夹下面的文件路径 String clientFolder = request.getParameter("clientFolder")==null?"":request.getParameter("clientFolder"); //客户端文件大小 String clientFileSize = request.getParameter("clientFileSize")==null?"":request.getParameter("clientFileSize"); //String homepath = homepath_g+clientFolder; new File(new File(homepath_g+"/"+filename).getParent()).mkdirs(); File file = new File(homepath_g+"/"+filename); if(file.length()>=Long.parseLong(clientFileSize)){ System.out.println("服务器端文件已存在"); }else{ new FileUploadServ().upload(file, request,file.length()); } System.out.println(homepath_g+"/"+filename); try { OutputStream out = response.getOutputStream(); ObjectOutputStream obj = new ObjectOutputStream(out); obj.writeObject("true"); obj.close(); out.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void out(HttpServletResponse resposne,String message){ try { OutputStream out = resposne.getOutputStream(); ObjectOutputStream obj = new ObjectOutputStream(out); obj.writeObject(message); obj.close(); out.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static void main(String[] args) { String url = "申早是琸呻吟声"; //url = URLEncoder.encode(url); //System.out.println(url); try { url = URLEncoder.encode(url, "gb2312"); System.out.println(url); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 文件合并 * @param request * @param response */ public void fileHb(HttpServletRequest request,HttpServletResponse response){ String filename = request.getParameter("filename"); InputStream input = null; ObjectInputStream objinput = null; OutputStream out = null; RandomAccessFile raf = null; InputStream input1 = null; try{ input = request.getInputStream(); objinput = new ObjectInputStream(input); Object obj = objinput.readObject(); //文件合并对象 raf = new RandomAccessFile(homepath_g+filename,"rw"); List list = (List)obj; for(int a=0;a<list.size();a++){ File f = (File)list.get(a); if(a!=0){ raf.seek(new File(homepath_g+filename).length()); } input1 = new FileInputStream(homepath_g+f.getName()); int c=0; byte[] by = new byte[1024]; while((c=input1.read(by))!=-1){ raf.write(by, 0, c); } //合并一个文件后关闭文件流 input1.close(); new File(homepath_g+f.getName()).delete(); } out = response.getOutputStream(); ObjectOutputStream objout = new ObjectOutputStream(out); objout.writeObject("合并完成"); objout.close(); }catch (Exception e) { // TODO: handle exception e.printStackTrace(); }finally{ try{ if(null!=input1){ input1.close(); } if(null!=raf){ raf.close(); } if(null!=input){ input.close(); } if(null!=objinput){ objinput.close(); } if(null!=out){ out.close(); } }catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } } /** * 上传完成后要操作的方法 * @param request * @param response */ public void afterDistance(HttpServletRequest request,HttpServletResponse response){ String code = request.getParameter("code")==null?"":request.getParameter("code"); System.out.println("前台传的参数:"+code); //==========================输出到客户端 try { OutputStream out = response.getOutputStream(); ObjectOutputStream obj = new ObjectOutputStream(out); obj.writeObject(code); obj.close(); out.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 得到文件大小 */ public void getFileLength(HttpServletRequest request,HttpServletResponse response){ try{ String filepath = request.getParameter("filepath"); long l = new File(homepath_g+"/"+filepath).length(); OutputStream out = response.getOutputStream(); ObjectOutputStream obj = new ObjectOutputStream(out); obj.writeObject(""+l); obj.close(); out.close(); }catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } /** * 得到文件大小 */ public void downFileLength(HttpServletRequest request,HttpServletResponse response){ try{ String filepath = downfile.getPath(); long l = new File(filepath).length(); OutputStream out = response.getOutputStream(); ObjectOutputStream obj = new ObjectOutputStream(out); obj.writeObject(""+l); obj.close(); out.close(); }catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } }