Java 文件上传的实例详解

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();
  }
   }
  }
}

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