欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java 文件上传的实例详解

程序员文章站 2024-02-28 22:10:22
java 文件上传的实例详解 java 文件上传 java文件上传,介绍几种常用的方法,也是经过本人亲手调试过的 1.jspsmartupload 这个...

java 文件上传的实例详解

java 文件上传

java文件上传,介绍几种常用的方法,也是经过本人亲手调试过的

1.jspsmartupload

这个组件用起来是挺方便的,不过就是只适合小文件上传,如果大文件上传的话就不行,查看了一下他的代码,m_totalbytes = m_request.getcontentlength(); m_binarray = new byte[m_totalbytes];居然把整个上传文件都读到内存去了,那如果是上传几十m的文件,同时几个用户上传,服务器稳挂,不过如果只是上传5m以内的小文件,这个组件还是挺实用的

下面是源代码:

file类

/*
 * 创建日期 2006-7-29
 *
 * 更改所生成文件模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
package com.kinstar.issuing.file;
/**
 * @author gongyifeng
 *
 * 更改所生成类型注释的模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
import java.io.bytearrayinputstream;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.math.biginteger;
import java.sql.resultset;
import java.sql.sqlexception;
import java.text.dateformat;
import java.text.simpledateformat;
import java.util.date;
import javax.servlet.servletexception;
// referenced classes of package com.jspsmart.upload:
// smartuploadexception, smartupload
public class file{
 private smartupload m_parent;
 private int m_startdata;
 private int m_enddata;
 private int m_size;
 private string m_fieldname;
 private string m_filename;
 private string m_fileext;
 private string m_filepathname;
 private string m_contenttype;
 private string m_contentdisp;
 private string m_typemime;
 private string m_subtypemime;
 private string m_contentstring;
 private boolean m_ismissing;
 public static final int saveas_auto = 0;
 public static final int saveas_virtual = 1;
 public static final int saveas_physical = 2;
 file(){
 m_startdata = 0;
 m_enddata = 0;
 m_size = 0;
 m_fieldname = new string();
 m_filename = new string();
 m_fileext = new string();
 m_filepathname = new string();
 m_contenttype = new string();
 m_contentdisp = new string();
 m_typemime = new string();
 m_subtypemime = new string();
 m_contentstring = new string();
 m_ismissing = true;
 }
 public void saveas(string s) throws ioexception, smartuploadexception{
 saveas(s, 0);
 }
 public void saveas(string s, int i) throws ioexception, smartuploadexception{
 string s1 = new string();
 s1 = m_parent.getphysicalpath(s, i);
 if(s1 == null)
  throw new illegalargumentexception("there is no specified destination file (1140).");
 try
 {
  java.io.file file = new java.io.file(s1);
  fileoutputstream fileoutputstream = new fileoutputstream(file);
  fileoutputstream.write(m_parent.m_binarray, m_startdata, m_size);
  fileoutputstream.close();
 }
 catch(ioexception ioexception)
 {
  throw new smartuploadexception("file can't be saved (1120).");
 }
 }
 public void filetofield(resultset resultset, string s) throws servletexception, ioexception, smartuploadexception, sqlexception{
 long l = 0l;
 int i = 0x10000;
 int j = 0;
 int k = m_startdata;
 if(resultset == null)
  throw new illegalargumentexception("the recordset cannot be null (1145).");
 if(s == null)
  throw new illegalargumentexception("the columnname cannot be null (1150).");
 if(s.length() == 0)
  throw new illegalargumentexception("the columnname cannot be empty (1155).");
 l = biginteger.valueof(m_size).divide(biginteger.valueof(i)).longvalue();
 j = biginteger.valueof(m_size).mod(biginteger.valueof(i)).intvalue();
 try
 {
  for(int i1 = 1; (long)i1 < l; i1++)
  {
  resultset.updatebinarystream(s, new bytearrayinputstream(m_parent.m_binarray, k, i), i);
  k = k != 0 ? k : 1;
  k = i1 * i + m_startdata;
  }
  
  if(j > 0)
  resultset.updatebinarystream(s, new bytearrayinputstream(m_parent.m_binarray, k, j), j);
 }catch(sqlexception sqlexception){
  byte abyte0[] = new byte[m_size];
  system.arraycopy(m_parent.m_binarray, m_startdata, abyte0, 0, m_size);
  resultset.updatebytes(s, abyte0);
 }catch(exception exception)
 {
  throw new smartuploadexception("unable to save file in the database (1130).");
 }
 }
 public boolean ismissing(){
 return m_ismissing;
 }
 
 public string getfieldname(){
 return m_fieldname;
 }
 
 public string getfilename(){
 dateformat df = new simpledateformat("yyyymmddhhmmss");
 string date = df.format(new date());
 
 return date+m_filename;
 }
 
 public string getfilepathname(){
 return m_filepathname;
 }
 
 public string getfileext(){
 return m_fileext;
 }
 
 public string getcontenttype(){
 return m_contenttype;
 }
 
 public string getcontentdisp(){
 return m_contentdisp;
 }
 
 public string getcontentstring(){
 string s = new string(m_parent.m_binarray, m_startdata, m_size);
 return s;
 }
 
 public string gettypemime() throws ioexception{
 return m_typemime;
 }
 
 public string getsubtypemime(){
 return m_subtypemime;
 }
 
 public int getsize(){
 return m_size;
 }
 
 protected int getstartdata(){
 return m_startdata;
 }
 
 protected int getenddata(){
 return m_enddata;
 }
 
 protected void setparent(smartupload smartupload){
 m_parent = smartupload;
 }
 
 protected void setstartdata(int i){
 m_startdata = i;
 }
 
 protected void setenddata(int i){
 m_enddata = i;
 }
 
 protected void setsize(int i){
 m_size = i;
 }
 
 protected void setismissing(boolean flag){
 m_ismissing = flag;
 }
 
 protected void setfieldname(string s){
 m_fieldname = s;
 }
 
 protected void setfilename(string s){
 m_filename = s;
 }
 
 protected void setfilepathname(string s){
 m_filepathname = s;
 }
 
 protected void setfileext(string s){
 m_fileext = s;
 }
 
 protected void setcontenttype(string s){
 m_contenttype = s;
 }
 
 protected void setcontentdisp(string s){
 m_contentdisp = s;
 }
 
 protected void settypemime(string s){
 m_typemime = s;
 }
 
 protected void setsubtypemime(string s){
 m_subtypemime = s;
 }
 
 public byte getbinarydata(int i){
 if(m_startdata + i > m_enddata)
  throw new arrayindexoutofboundsexception("index out of range (1115).");
 if(m_startdata + i <= m_enddata)
  return m_parent.m_binarray[m_startdata + i];
 else
  return 0;
 } 
}

files类

/*
 * 创建日期 2006-7-29
 *
 * 更改所生成文件模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
package com.kinstar.issuing.file;
/**
 * @author gongyifeng
 *
 * 更改所生成类型注释的模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
import java.io.ioexception;
import java.util.*;
// referenced classes of package com.jspsmart.upload:
// file, smartupload
public class files{
 private smartupload m_parent;
 private hashtable m_files;
 private int m_counter;
 
 files(){
 m_files = new hashtable();
 m_counter = 0;
 }
 
 protected void addfile(file file){
 if(file == null)
 {
  throw new illegalargumentexception("newfile cannot be null.");
 } else {
  m_files.put(new integer(m_counter), file);
  m_counter++;
  return;
 }
 }
 
 public file getfile(int i)
 {
 if(i < 0)
 throw new illegalargumentexception("file's index cannot be a negative value (1210).");
 file file = (file)m_files.get(new integer(i));
 if(file == null)
 throw new illegalargumentexception("files' name is invalid or does not exist (1205).");
 else
 return file;
 }
 
 public int getcount()
 {
 return m_counter;
 }
 
 public long getsize() throws ioexception
 {
 long l = 0l;
 for(int i = 0; i < m_counter; i++)
 l += getfile(i).getsize();
 
 return l;
 }
 
 public collection getcollection()
 {
 return m_files.values();
 }
 
 public enumeration getenumeration()
 {
 return m_files.elements();
 }
}

request类

/*
 * 创建日期 2006-7-29
 *
 * 更改所生成文件模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
package com.kinstar.issuing.file;
/**
 * @author gongyifeng
 *
 * 更改所生成类型注释的模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
import java.util.enumeration;
import java.util.hashtable;
public class request
{
 private hashtable m_parameters;
 private int m_counter;
 
 request(){
 m_parameters = new hashtable();
 m_counter = 0;
 }
 
 protected void putparameter(string s, string s1) {
 if(s == null)
  throw new illegalargumentexception("the name of an element cannot be null.");
 if(m_parameters.containskey(s))
 {
  hashtable hashtable = (hashtable)m_parameters.get(s);
  hashtable.put(new integer(hashtable.size()), s1);
 } else{
  hashtable hashtable1 = new hashtable();
  hashtable1.put(new integer(0), s1);
  m_parameters.put(s, hashtable1);
  m_counter++;
 }
 }
 
 public string getparameter(string s){
 if(s == null)
 throw new illegalargumentexception("form's name is invalid or does not exist (1305).");
 hashtable hashtable = (hashtable)m_parameters.get(s);
 if(hashtable == null)
 return null;
 else
 return (string)hashtable.get(new integer(0));
 }
 
 public enumeration getparameternames()
 {
 return m_parameters.keys();
 }
 
 public string[] getparametervalues(string s)
 {
 if(s == null)
  throw new illegalargumentexception("form's name is invalid or does not exist (1305).");
 hashtable hashtable = (hashtable)m_parameters.get(s);
 if(hashtable == null)
  return null;
 string as[] = new string[hashtable.size()];
 for(int i = 0; i < hashtable.size(); i++)
  as[i] = (string)hashtable.get(new integer(i));
 
 return as;
 }
}

smartupload类

/*
 * 创建日期 2006-7-29
 *
 * 更改所生成文件模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
package com.kinstar.issuing.file;
/**
 * @author gongyifeng
 *
 * 更改所生成类型注释的模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
import java.io.*;
import java.sql.resultset;
import java.sql.sqlexception;
import java.util.vector;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.servlet.jsp.jspwriter;
import javax.servlet.jsp.pagecontext;
// referenced classes of package com.jspsmart.upload:
// files, request, smartuploadexception, file
public class smartupload
{
 protected byte m_binarray[];
 protected httpservletrequest m_request;
 protected httpservletresponse m_response;
 protected servletcontext m_application;
 private int m_totalbytes;
 private int m_currentindex;
 private int m_startdata;
 private int m_enddata;
 private string m_boundary;
 private long m_totalmaxfilesize;
 private long m_maxfilesize;
 private vector m_deniedfileslist;
 private vector m_allowedfileslist;
 private boolean m_denyphysicalpath;
 private boolean m_forcephysicalpath;
 private string m_contentdisposition;
 public static final int save_auto = 0;
 public static final int save_virtual = 1;
 public static final int save_physical = 2;
 private files m_files;
 private request m_formrequest;
 
 public smartupload()
 {
 m_totalbytes = 0;
 m_currentindex = 0;
 m_startdata = 0;
 m_enddata = 0;
 m_boundary = new string();
 m_totalmaxfilesize = 0l;
 m_maxfilesize = 0l;
 m_deniedfileslist = new vector();
 m_allowedfileslist = new vector();
 m_denyphysicalpath = false;
 m_forcephysicalpath = false;
 m_contentdisposition = new string();
 m_files = new files();
 m_formrequest = new request();
 }
 
 public final void init(servletconfig servletconfig) throws servletexception
 {
 m_application = servletconfig.getservletcontext();
 }
 
 public void service(httpservletrequest httpservletrequest, httpservletresponse httpservletresponse)throws servletexception, ioexception
 {
 m_request = httpservletrequest;
 m_response = httpservletresponse;
 }
 
 public final void initialize(servletconfig servletconfig, httpservletrequest httpservletrequest, httpservletresponse httpservletresponse)throws servletexception
 {
 m_application = servletconfig.getservletcontext();
 m_request = httpservletrequest;
 m_response = httpservletresponse;
 }
 
 public final void initialize(pagecontext pagecontext)throws servletexception
 {
 m_application = pagecontext.getservletcontext();
 m_request = (httpservletrequest)pagecontext.getrequest();
 m_response = (httpservletresponse)pagecontext.getresponse();
 }
 
 public final void initialize(servletcontext servletcontext, httpsession httpsession, httpservletrequest httpservletrequest, httpservletresponse httpservletresponse, jspwriter jspwriter) throws servletexception
 {
 m_application = servletcontext;
 m_request = httpservletrequest;
 m_response = httpservletresponse;
 }
 
 public void upload()throws servletexception, ioexception, smartuploadexception
 {
 int i = 0;
 boolean flag = false;
 long l = 0l;
 boolean flag1 = false;
 string s = new string();
 string s2 = new string();
 string s4 = new string();
 string s5 = new string();
 string s6 = new string();
 string s7 = new string();
 string s8 = new string();
 string s9 = new string();
 string s10 = new string();
 boolean flag2 = false;
 m_totalbytes = m_request.getcontentlength();
 m_binarray = new byte[m_totalbytes];
 int j;
 for(; i < m_totalbytes; i += j)
 try
 {
  m_request.getinputstream();
  j = m_request.getinputstream().read(m_binarray, i, m_totalbytes - i);
 }
 catch(exception exception)
 {
  throw new smartuploadexception("unable to upload.");
 }
 
 for(; !flag1 && m_currentindex < m_totalbytes; m_currentindex++)
 if(m_binarray[m_currentindex] == 13)
  flag1 = true;
 else
  m_boundary = m_boundary + (char)m_binarray[m_currentindex];
 
 if(m_currentindex == 1)
  return;
 for(m_currentindex++; m_currentindex < m_totalbytes; m_currentindex = m_currentindex + 2)
 {
  string s1 = getdataheader();
  m_currentindex = m_currentindex + 2;
  boolean flag3 = s1.indexof("filename") > 0;
  string s3 = getdatafieldvalue(s1, "name");
  if(flag3)
  {
  s6 = getdatafieldvalue(s1, "filename");
  s4 = getfilename(s6);
  s5 = getfileext(s4);
  s7 = getcontenttype(s1);
  s8 = getcontentdisp(s1);
  s9 = gettypemime(s7);
  s10 = getsubtypemime(s7);
  }
  getdatasection();
  if(flag3 && s4.length() > 0)
  {
  if(m_deniedfileslist.contains(s5))
   throw new securityexception("the extension of the file is denied to be uploaded (1015).");
  if(!m_allowedfileslist.isempty() && !m_allowedfileslist.contains(s5))
   throw new securityexception("the extension of the file is not allowed to be uploaded (1010).");
  if(m_maxfilesize > 0l && (long)((m_enddata - m_startdata) + 1) > m_maxfilesize)
   throw new securityexception("size exceeded for this file : " + s4 + " (1105).");
  l += (m_enddata - m_startdata) + 1;
  if(m_totalmaxfilesize > 0l && l > m_totalmaxfilesize)
   throw new securityexception("total file size exceeded (1110).");
  }
  if(flag3)
  {
  com.kinstar.issuing.file.file file = new com.kinstar.issuing.file.file();
  file.setparent(this);
  file.setfieldname(s3);
  file.setfilename(s4);
  file.setfileext(s5);
  file.setfilepathname(s6);
  file.setismissing(s6.length() == 0);
  file.setcontenttype(s7);
  file.setcontentdisp(s8);
  file.settypemime(s9);
  file.setsubtypemime(s10);
  if(s7.indexof("application/x-macbinary") > 0)
   m_startdata = m_startdata + 128;
   file.setsize((m_enddata - m_startdata) + 1);
   file.setstartdata(m_startdata);
   file.setenddata(m_enddata);
   m_files.addfile(file);
  } else
  {
   string s11 = new string(m_binarray, m_startdata, (m_enddata - m_startdata) + 1);
   m_formrequest.putparameter(s3, s11);
  }
  if((char)m_binarray[m_currentindex + 1] == '-')
   break;
  }
 
  }
 
 public int save(string s)throws servletexception, ioexception, smartuploadexception
 {
 return save(s, 0);
 }
 
 public int save(string s, int i)throws servletexception, ioexception, smartuploadexception
 {
 int j = 0;
 if(s == null)
  s = m_application.getrealpath("/");
 if(s.indexof("/") != -1)
 {
  if(s.charat(s.length() - 1) != '/')
  s = s + "/";
  } else
  if(s.charat(s.length() - 1) != '\\')
  s = s + "\\";
  for(int k = 0; k < m_files.getcount(); k++)
  if(!m_files.getfile(k).ismissing())
  {
  m_files.getfile(k).saveas(s + m_files.getfile(k).getfilename(), i);
  j++;
 }
 
 return j;
 }
 
 public int getsize()
 {
 return m_totalbytes;
 }
 
 public byte getbinarydata(int i)
 {
 byte byte0;
 try
 {
  byte0 = m_binarray[i];
 }
 catch(exception exception)
 {
  throw new arrayindexoutofboundsexception("index out of range (1005).");
 }
 return byte0;
 }
 
 public files getfiles()
 {
 return m_files;
 }
 
 public request getrequest()
 {
 return m_formrequest;
 }
 
 public void downloadfile(string s) throws servletexception, ioexception, smartuploadexception
 {
 downloadfile(s, null, null);
 }
 
 public void downloadfile(string s, string s1) throws servletexception, ioexception, smartuploadexception, smartuploadexception
 {
 downloadfile(s, s1, null);
 }
 
 public void downloadfile(string s, string s1, string s2)throws servletexception, ioexception, smartuploadexception
 {
 downloadfile(s, s1, s2, 65000);
 }
 
 public void downloadfile(string s, string s1, string s2, int i)throws servletexception, ioexception, smartuploadexception
 {
 if(s == null)
  throw new illegalargumentexception("file '" + s + "' not found (1040).");
 if(s.equals(""))
  throw new illegalargumentexception("file '" + s + "' not found (1040).");
 if(!isvirtual(s) && m_denyphysicalpath)
  throw new securityexception("physical path is denied (1035).");
 if(isvirtual(s))
  s = m_application.getrealpath(s);
 java.io.file file = new java.io.file(s);
 fileinputstream fileinputstream = new fileinputstream(file);
 long l = file.length();
 boolean flag = false;
 int k = 0;
 byte abyte0[] = new byte[i];
 if(s1 == null)
  m_response.setcontenttype("application/x-msdownload");
 else
 if(s1.length() == 0)
  m_response.setcontenttype("application/x-msdownload");
 else
  m_response.setcontenttype(s1);
 m_response.setcontentlength((int)l);
 m_contentdisposition = m_contentdisposition != null ? m_contentdisposition : "attachment;";
 if(s2 == null)
  m_response.setheader("content-disposition", m_contentdisposition + " filename=" + getfilename(s));
 else
 if(s2.length() == 0)
  m_response.setheader("content-disposition", m_contentdisposition);
 else
  m_response.setheader("content-disposition", m_contentdisposition + " filename=" + s2);
 while((long)k < l)
 {
  int j = fileinputstream.read(abyte0, 0, i);
  k += j;
  m_response.getoutputstream().write(abyte0, 0, j);
 }
 fileinputstream.close();
 }
 
 public void downloadfield(resultset resultset, string s, string s1, string s2) throws servletexception, ioexception, sqlexception
 {
 if(resultset == null)
 throw new illegalargumentexception("the recordset cannot be null (1045).");
 if(s == null)
 throw new illegalargumentexception("the columnname cannot be null (1050).");
 if(s.length() == 0)
 throw new illegalargumentexception("the columnname cannot be empty (1055).");
 byte abyte0[] = resultset.getbytes(s);
 if(s1 == null)
 m_response.setcontenttype("application/x-msdownload");
 else
 if(s1.length() == 0)
 m_response.setcontenttype("application/x-msdownload");
 else
 m_response.setcontenttype(s1);
 m_response.setcontentlength(abyte0.length);
 if(s2 == null)
 m_response.setheader("content-disposition", "attachment;");
 else
 if(s2.length() == 0)
 m_response.setheader("content-disposition", "attachment;");
 else
 m_response.setheader("content-disposition", "attachment; filename=" + s2);
 m_response.getoutputstream().write(abyte0, 0, abyte0.length);
 }
 
 public void fieldtofile(resultset resultset, string s, string s1)throws servletexception, ioexception, smartuploadexception, sqlexception
 {
 try
 {
  if(m_application.getrealpath(s1) != null)
  s1 = m_application.getrealpath(s1);
  inputstream inputstream = resultset.getbinarystream(s);
  fileoutputstream fileoutputstream = new fileoutputstream(s1);
  int i;
  while((i = inputstream.read()) != -1)
  fileoutputstream.write(i);
  fileoutputstream.close();
 }
 catch(exception exception)
 {
  throw new smartuploadexception("unable to save file from the database (1020).");
 }
 }
 
 private string getdatafieldvalue(string s, string s1)
 {
 string s2 = new string();
 string s3 = new string();
 int i = 0;
 boolean flag = false;
 boolean flag1 = false;
 boolean flag2 = false;
 s2 = s1 + "=" + '"';
 i = s.indexof(s2);
 if(i > 0)
 {
  int j = i + s2.length();
  int k = j;
  s2 = "\"";
  int l = s.indexof(s2, j);
  if(k > 0 && l > 0)
  s3 = s.substring(k, l);
 }
 return s3;
 }
 
 private string getfileext(string s)
 {
 string s1 = new string();
 int i = 0;
 int j = 0;
 if(s == null)
  return null;
 i = s.lastindexof(46) + 1;
 j = s.length();
 s1 = s.substring(i, j);
 if(s.lastindexof(46) > 0)
  return s1;
 else
 return "";
 }
 
 private string getcontenttype(string s)
 {
 string s1 = new string();
 string s2 = new string();
 int i = 0;
 boolean flag = false;
 s1 = "content-type:";
 i = s.indexof(s1) + s1.length();
 if(i != -1)
 {
  int j = s.length();
  s2 = s.substring(i, j);
 }
 return s2;
 }
 
 private string gettypemime(string s)
 {
 string s1 = new string();
 int i = 0;
 i = s.indexof("/");
 if(i != -1)
  return s.substring(1, i);
 else
 return s;
 }
 
 private string getsubtypemime(string s)
 {
 string s1 = new string();
 int i = 0;
 boolean flag = false;
 i = s.indexof("/") + 1;
 if(i != -1)
 {
  int j = s.length();
  return s.substring(i, j);
 } else
 {
  return s;
 }
 }
 
 private string getcontentdisp(string s)
 {
 string s1 = new string();
 int i = 0;
 int j = 0;
 i = s.indexof(":") + 1;
 j = s.indexof(";");
 s1 = s.substring(i, j);
 return s1;
 }
 
 private void getdatasection()
 {
 boolean flag = false;
 string s = new string();
 int i = m_currentindex;
 int j = 0;
 int k = m_boundary.length();
 m_startdata = m_currentindex;
 m_enddata = 0;
 while(i < m_totalbytes)
 if(m_binarray[i] == (byte)m_boundary.charat(j))
 {
  if(j == k - 1)
  {
  m_enddata = ((i - k) + 1) - 3;
  break;
  }
  i++;
  j++;
 } else
 {
  i++;
  j = 0;
 }
 m_currentindex = m_enddata + k + 3;
 }
 
 private string getdataheader()
 {
 int i = m_currentindex;
 int j = 0;
 boolean flag = false;
 for(boolean flag1 = false; !flag1;)
 if(m_binarray[m_currentindex] == 13 && m_binarray[m_currentindex + 2] == 13)
 {
  flag1 = true;
  j = m_currentindex - 1;
  m_currentindex = m_currentindex + 2;
 } else
 {
  m_currentindex++;
 }
 
 string s = new string(m_binarray, i, (j - i) + 1);
 return s;
 }
 
 private string getfilename(string s)
 {
 string s1 = new string();
 string s2 = new string();
 int i = 0;
 boolean flag = false;
 boolean flag1 = false;
 boolean flag2 = false;
 i = s.lastindexof(47);
 if(i != -1)
  return s.substring(i + 1, s.length());
 i = s.lastindexof(92);
 if(i != -1)
  return s.substring(i + 1, s.length());
 else
 return s;
 }
 
 public void setdeniedfileslist(string s) throws servletexception, ioexception, sqlexception
 {
 string s1 = "";
 if(s != null)
 {
 string s2 = "";
 for(int i = 0; i < s.length(); i++)
 if(s.charat(i) == ',')
 {
  if(!m_deniedfileslist.contains(s2))
  m_deniedfileslist.addelement(s2);
  s2 = "";
 } else
 {
  s2 = s2 + s.charat(i);
 }
 
 if(s2 != "")
  m_deniedfileslist.addelement(s2);
 } else
 {
  m_deniedfileslist = null;
 }
 }
 
 public void setallowedfileslist(string s)
 {
 string s1 = "";
 if(s != null)
 {
  string s2 = "";
  for(int i = 0; i < s.length(); i++)
  if(s.charat(i) == ',')
  {
  if(!m_allowedfileslist.contains(s2))
  m_allowedfileslist.addelement(s2);
  s2 = "";
  } else
  {
  s2 = s2 + s.charat(i);
  }
  
  if(s2 != "")
  m_allowedfileslist.addelement(s2);
 } else
 {
  m_allowedfileslist = null;
 }
 }
 
 public void setdenyphysicalpath(boolean flag)
 {
 m_denyphysicalpath = flag;
 }
 
 public void setforcephysicalpath(boolean flag)
 {
 m_forcephysicalpath = flag;
 }
 
 public void setcontentdisposition(string s)
 {
 m_contentdisposition = s;
 }
 
 public void settotalmaxfilesize(long l)
 {
 m_totalmaxfilesize = l;
 }
 
 public void setmaxfilesize(long l)
 {
 m_maxfilesize = l;
 }
 
 protected string getphysicalpath(string s, int i)throws ioexception
 {
 string s1 = new string();
 string s2 = new string();
 string s3 = new string();
 boolean flag = false;
 s3 = system.getproperty("file.separator");
 if(s == null)
  throw new illegalargumentexception("there is no specified destination file (1140).");
 if(s.equals(""))
  throw new illegalargumentexception("there is no specified destination file (1140).");
 if(s.lastindexof("\\") >= 0)
 {
  s1 = s.substring(0, s.lastindexof("\\"));
  s2 = s.substring(s.lastindexof("\\") + 1);
 }
 if(s.lastindexof("/") >= 0)
 {
  s1 = s.substring(0, s.lastindexof("/"));
  s2 = s.substring(s.lastindexof("/") + 1);
 }
 s1 = s1.length() != 0 ? s1 : "/";
 java.io.file file = new java.io.file(s1);
 if(file.exists())
  flag = true;
 if(i == 0)
 {
  if(isvirtual(s1))
  {
  s1 = m_application.getrealpath(s1);
  if(s1.endswith(s3))
   s1 = s1 + s2;
  else
  s1 = s1 + s3 + s2;
   return s1;
  }
  if(flag)
  {
  if(m_denyphysicalpath)
   throw new illegalargumentexception("physical path is denied (1125).");
  else
   return s;
  } else
  {
  throw new illegalargumentexception("this path does not exist (1135).");
  }
 }
 if(i == 1)
 {
  if(isvirtual(s1))
  {
  s1 = m_application.getrealpath(s1);
  if(s1.endswith(s3))
  s1 = s1 + s2;
  else
  s1 = s1 + s3 + s2;
  return s1;
 }
 if(flag)
  throw new illegalargumentexception("the path is not a virtual path.");
 else
  throw new illegalargumentexception("this path does not exist (1135).");
 }
 if(i == 2)
 {
  if(flag)
  if(m_denyphysicalpath)
  throw new illegalargumentexception("physical path is denied (1125).");
  else
  return s;
  if(isvirtual(s1))
  throw new illegalargumentexception("the path is not a physical path.");
  else
  throw new illegalargumentexception("this path does not exist (1135).");
 } else
 {
  return null;
 }
 }
 
 public void uploadinfile(string s)throws ioexception, smartuploadexception
 {
 int i = 0;
 int j = 0;
 boolean flag = false;
 if(s == null)
  throw new illegalargumentexception("there is no specified destination file (1025).");
 if(s.length() == 0)
  throw new illegalargumentexception("there is no specified destination file (1025).");
 if(!isvirtual(s) && m_denyphysicalpath)
  throw new securityexception("physical path is denied (1035).");
 i = m_request.getcontentlength();
 m_binarray = new byte[i];
 int k;
 for(; j < i; j += k)
 try
 {
  k = m_request.getinputstream().read(m_binarray, j, i - j);
 }
 catch(exception exception)
 {
  throw new smartuploadexception("unable to upload.");
 }
 
 if(isvirtual(s))
  s = m_application.getrealpath(s);
 try
 {
  java.io.file file = new java.io.file(s);
  fileoutputstream fileoutputstream = new fileoutputstream(file);
  fileoutputstream.write(m_binarray);
  fileoutputstream.close();
 }
 catch(exception exception1)
 {
  throw new smartuploadexception("the form cannot be saved in the specified file (1030).");
 }
 }
 
 private boolean isvirtual(string s)
 {
 if(m_application.getrealpath(s) != null)
 {
  java.io.file file = new java.io.file(m_application.getrealpath(s));
  return file.exists();
 } else
 {
  return false;
 }
 }
}

smartuploadexception 类

/*
 * 创建日期 2006-7-29
 *
 * 更改所生成文件模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
package com.kinstar.issuing.file;
/**
 * @author gongyifeng
 *
 * 更改所生成类型注释的模板为
 * 窗口 > 首选项 > java > 代码生成 > 代码和注释
 */
public class smartuploadexception extends exception
{
 smartuploadexception(string s)
 {
 super(s);
 }
}

上传的servlet

package com.kinstar.issuing.action;
import java.io.ioexception;
import javax.servlet.servlet;
import javax.servlet.servletexception;
import java.io.*;
import java.sql.sqlexception;
import java.util.*;
import java.text.*;
import javax.servlet.*;
import javax.servlet.http.*;

import javax.servlet.http.httpservlet;
import javax.servlet.http.httpservletrequest;
import javax.servlet.http.httpservletresponse;
import com.kinstar.issuing.file.file;
import com.kinstar.issuing.file.smartupload;
import com.kinstar.issuing.objects.t_user;
import com.kinstar.issuing.operation.useroperation;
import com.kinstar.issuing.program.programservice;
import com.kinstar.issuing.session.sessiongloble;
import com.kinstar.issuing.util.stringutil;
/**
 * @version 1.0
 * @author gyf
 */

public class upload2programaction extends httpservlet{
 private servletconfig config;
 /**
 * 初始化servlet
 */
 final public void init(servletconfig config) throws servletexception {
 this.config = config;
 }
 /**
 * 处理get请求
 */
 public void doget(httpservletrequest request, httpservletresponse response) throws servletexception, ioexception {
  dopost(request,response);
 }
 
 /**
 * 响应post请求
 */
 public void dopost(httpservletrequest request, httpservletresponse response) throws servletexception, ioexception { 
  int count=0;
  smartupload mysmartupload = new smartupload();
  try {
   // 初始化
   mysmartupload.initialize(config,request,response);
 
   // 上载
   mysmartupload.upload();
   com.kinstar.issuing.file.file f1 = mysmartupload.getfiles().getfile(0);
  // com.kinstar.issuing.file.file f2 = mysmartupload.getfiles().getfile(1);
   string backpic = f1.getfilename();
  //string name2 = f2.getfilename();
  
   long size=0;
   
  // 保存上载文件到指定目录
  count=mysmartupload.save("ads"); 
  response.sendredirect("program.jsp?dopass=ture");
  
  }   

   
  catch (exception e){
   response.sendredirect("fail.jsp");
  } 
}

2.common-fileupload组件

挺好用的,也能够上传大文件,我试过,300m以上的文件上传本地传非常快,异地测试也能够上传成功.

首先要下载org.apache.commons.fileupload包和org.apache.commons.io包

下面是我的servlet

package com.kinstar.issuing.action;
import java.io.ioexception;
import javax.servlet.servlet;
import javax.servlet.servletexception;
import java.io.*;
import java.sql.sqlexception;
import java.util.*;
import java.text.*;
import javax.servlet.*;
import javax.servlet.http.*;
import java.util.regex.*;

import javax.servlet.http.httpservlet;
import javax.servlet.http.httpservletrequest;
import javax.servlet.http.httpservletresponse;
import org.apache.commons.fileupload.diskfileupload;
import org.apache.commons.fileupload.fileitem;
import org.apache.commons.fileupload.fileuploadexception;
import com.kinstar.issuing.objects.t_user;
import com.kinstar.issuing.operation.useroperation;
import com.kinstar.issuing.program.programservice;
import com.kinstar.issuing.session.sessiongloble;
import com.kinstar.issuing.util.stringutil;
/**
 * @version 1.0
 * @author gyf
 */

public class uploadprogramaction extends httpservlet{
 private static final string content_type = "text/html; charset=gb2312";
 
 /**
 * 处理get请求
 */
 public void doget(httpservletrequest request, httpservletresponse response) throws servletexception, ioexception {
  dopost(request,response);
 }
 
 /**
 * 响应post请求
 */
 public void dopost(httpservletrequest request, httpservletresponse response) throws servletexception, ioexception {
  // 变量定义
  response.setcontenttype(content_type);
  httpsession modifysession=request.getsession();
  sessiongloble logonuser;
  logonuser=(sessiongloble)modifysession.getattribute("userinfo");
    if(logonuser==null){
    response.sendredirect("mainindex.jsp");
  }
  t_user userinfo=new t_user();
  useroperation user=null;
  try {
   user = new useroperation();
  } catch (exception e1) {
  // todo 自动生成 catch 块
  e1.printstacktrace();
  }
  try {
   userinfo=user.getuser(logonuser.getuserid());
  } catch (exception e2) {
  // todo 自动生成 catch 块
  e2.printstacktrace();
  }
   //system.out.println("figure="+userinfo.getuserfigure());
   printwriter out=response.getwriter(); 
   dateformat updf = new simpledateformat("yyyymmddhhmm");
   string updatetime = updf.format(new date());
   int isneed = 0;
   string ischeck="0";
  
  //省农行用户上传的节目必需显示,且审批已经合格
   if(userinfo.getuserfigure().equals("1")){
   isneed = 1;
   ischeck = "1";
   }
   else{
   isneed = 0;
   ischeck = "0";
   }
  int type=0;
  string avatime="";
  string screen="";
  int filetime=0;
  int filetimereal=0;
  int circle=0;
  string picswitch="";
  string delestate="1";
  string backpic="";
  
  string fieldname="";
  string finalname="";
  string filenamereal="";
  long size=0;
  string name="";
   try {
  diskfileupload fu = new diskfileupload();
  // 设置允许用户上传文件大小,单位:字节,这里设为2m
  fu.setsizemax(5*1024*1024*1024);
  // 设置最多只允许在内存中存储的数据,单位:字节
  fu.setsizethreshold(10*1024*1024);
  // 设置一旦文件大小超过getsizethreshold()的值时数据存放在硬盘的目录
  fu.setrepositorypath("c:\\windows\\temp\\");
  //开始读取上传信息
  list fileitems = fu.parserequest(request);
  //依次处理每个上传的文件
  iterator iter = fileitems.iterator();
 
 
    //正则匹配,过滤路径取文件名
  string regexp=".+\\\\(.+)$";
 
  //过滤掉的文件类型
  string[] errortype={".exe",".com",".cgi",".asp"};
   
  pattern p = pattern.compile(regexp);
  stringutil su = new stringutil();
   
  while (iter.hasnext()) {
   fileitem item = (fileitem)iter.next();
  
    if(item.isformfield()) { 
    // 获得表单域的名字 
    fieldname = item.getfieldname(); 
    // 如果表单域的名字是name… 
    if(fieldname.equals("type")) 
      type = integer.parseint(item.getstring());
    
    } 
   if (!item.isformfield()) {
    name = item.getname();
    size = item.getsize();
    if((name==null||name.equals("")) && size==0)
    continue;
    matcher m = p.matcher(name);
    boolean result = m.find();
    if (result){
    for (int temp=0;temp<errortype.length;temp++){
    if (m.group(1).endswith(errortype[temp])){
    throw new ioexception(name+": wrong type");
    }
    }
    
    dateformat df = new simpledateformat("yyyymmddhhmmss");
        string date = df.format(new date());
    filenamereal=date+m.group(1);
    finalname=date+math.round(math.random()*10000)+filenamereal.substring(filenamereal.indexof("."));
    //保存上传的文件到指定的目录 
    //在下文中上传文件至数据库时,将对这里改写
    item.write(new file(getservletcontext().getrealpath(".//ads//")+finalname));
    //out.print(finalname+size);
    }
    else
    {
   throw new ioexception("fail to upload");
   
    } 
   }
   if(item.isformfield()) { 
   // 获得表单域的名字 
   fieldname = item.getfieldname(); 
   if(fieldname.equals("avatime")) 
   avatime=item.getstring();
   if(fieldname.equals("screen")) 
   screen=item.getstring();
   if(fieldname.equals("filetime")) 
   filetime = integer.parseint(item.getstring());
   if(fieldname.equals("filetimereal")) 
   filetimereal = integer.parseint(item.getstring());
   if(fieldname.equals("circle")) 
   circle = integer.parseint(item.getstring()); 
   if(fieldname.equals("switchpic")) 
    picswitch = item.getstring(); 
    
   }  
    }
   }catch (ioexception e){
    out.println(e);
   }catch (fileuploadexception e){
    out.println(e);
   } catch (exception e) {
  // todo 自动生成 catch 块
   e.printstacktrace();
   }
   if(finalname.equals("")){
    response.sendredirect("fail.jsp");
   }
   else{
  try {
  programservice ps = new programservice();
  ps.insertprogram(userinfo.getuserid(),updatetime,type,finalname,size,isneed,avatime,delestate,ischeck,userinfo.getcity(),backpic,screen,filetime,filetimereal,picswitch,circle,userinfo.getuserfigure(),new string(filenamereal.getbytes("gb2312"),"iso8859-1"));
  response.sendredirect("program.jsp?dopass=true"); 
  } catch (exception e3) {
  // todo 自动生成 catch 块
  e3.printstacktrace();
  }
   }
  }
}

如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!