java实现批量上传(swfupload)

时间:2023-03-08 17:10:07

下载 swfupload 文件夹 里面包含handlers.js,swfupload.js,swfupload.swf 三个文件。

我的是和ssh项目整合在一起的。因为struts2的拦截器会拦截所有请求,在跳转到上传文件的servlet中时request请求会被转换为struts的请求。所以要去掉struts的请求。

假如web.xml配置的拦截所有请求,可以修改这里,不拦截所有

<filter>
<filter-name>struts2</filter-name>
<filter-class>
org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter
</filter-class>
<init-param>
<param-name>config</param-name>
<param-value>
struts-default.xml,struts-plugin.xml,resources/struts/struts.xml
</param-value>
</init-param>
<init-param>
<param-name>actionPackages</param-name>
<param-value>com.yuncai.modules</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>struts2</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>

或者在struts.xml中加上 <constant name="struts.action.excludePattern" value="/servlet/.*" />  struts不会拦截这个路径下的所有

上传文件的servlet的路径

<struts>
<!-- 开启使用开发模式,详细错误提示 -->
<constant name="struts.devMode" value="true" />
<!-- 默认后缀名 -->
<constant name="struts.action.extension" value="jsp" />
<constant name="struts.action.excludePattern" value="/servlet/.*" />
<!-- 指定每次请求到达,重新加载资源文件 -->
<constant name="struts.i18n.reload" value="true" />
<!-- 视图标签默认的视图主题-->
<constant name="struts.ui.theme" value="simple" />
<!-- 国际化资源文件 -->
<constant name="struts.custom.i18n.resources" value="globalMessages" />
<!-- locale -->
<constant name="struts.locale" value="zh_CN" />
<!-- 指定资源编码类型 -->
<constant name="struts.i18n.encoding" value="UTF-8" />
<!-- 生成URL时是否包含请求参数 -->
<constant name="struts.url.includeParams" value="none" />
<!-- 文件上传中整个请求内容允许的最大字节数 -->
<constant name="struts.multipart.maxSize" value="1048576000" /> <constant name="struts.objectFactory" value="spring"/> </struts>
<%@ page language="java" pageEncoding="utf-8"%>
<%@ taglib prefix="fmt" uri="http://java.sun.com/jsp/jstl/fmt"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>
<head>
<link rel="stylesheet" type="text/css" href="../css/zlstyle.css">
<script type="text/javascript" src="/swfupload/swfupload.js"></script>
<script type="text/javascript" src="/swfupload/handlers.js"></script>
<script type="text/javascript" src="../js/jquery-1.10.2.min.js"></script>
</head>
<body leftmargin="10" topmargin="10" marginwidth="10" marginheight="10">
<table width="100%" border="1" bordercolor="#464646" align="center"
cellpadding="0" cellspacing="0">
<tr>
<td align="right">
是否显示:
</td>
<td>
<input type="checkbox" id="isValid" value="0" onclick="check1();"/>
</td>
</tr>
<tr>
<td align="right">
说明:
</td>
<td>
<textarea rows="" cols="" id="info"></textarea>
</td>
</tr>
</table>
<input type="button" onclick="swfupload();" value="添加控件"/>
<span id="spanButtonPlaceholder"></span>
<div id="divFileProgressContainer" style="width:200;display:none;"></div>
<div id="thumbnails">
<table id="infoTable" border="0" style="background-color: #C5D9FF;"></table>
</div>
<!--为了把表单数据传到servlet,所以多加了一个点击按钮-->
<script type="text/javascript">
var swfu;
function swfupload() {
swfu = new SWFUpload({
upload_url: "/servlet/FileUploadServlet",
// File Upload Settings
file_size_limit : "50 MB", // 1000MB
file_types : "*.apk",//设置可上传的类型
file_types_description : "所有文件",
file_upload_limit : "100",
// 向服务端传递的参数
use_query_string : true,
post_params: {
"isValid" : document.getElementById("isValid").value,"info" : document.getElementById("info").value
}, file_queue_error_handler : fileQueueError,//选择文件后出错
file_dialog_complete_handler : fileDialogComplete,//选择好文件后提交
file_queued_handler : fileQueued,
upload_progress_handler : uploadProgress,
upload_error_handler : uploadError,
upload_success_handler : uploadSuccess,
upload_complete_handler : uploadComplete, // Button Settings
button_image_url : "images/SmallSpyGlassWithTransperancy_17x18.png",
button_placeholder_id : "spanButtonPlaceholder",
button_width: 100,
button_height: 18,
button_text : '<span class="button">选择APK</span>',
button_text_style : '.button { font-family: Helvetica, Arial, sans-serif; font-size: 12pt; } .buttonSmall { font-size: 10pt; }',
button_text_top_padding: 0,
button_text_left_padding: 18,
button_window_mode: SWFUpload.WINDOW_MODE.TRANSPARENT,
button_cursor: SWFUpload.CURSOR.HAND, // Flash Settings
flash_url : "swfupload/swfupload.swf", custom_settings : {
upload_target : "divFileProgressContainer"
},
// Debug Settings
debug: false //是否显示调试窗口
});
};
function startUploadFile(){
swfu.startUpload();
} function check1(){
var isValid = document.getElementById("isValid").value;
if(isValid==0)
document.getElementById("isValid").value="1";
else
document.getElementById("isValid").value="0";
}</script>
</body>
package com.yuncai.modules.servlet;

import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Enumeration; import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession; import org.apkinfo.api.GetApkInfo;
import org.apkinfo.api.domain.ApkInfo; import com.oreilly.servlet.MultipartRequest;
import com.yuncai.core.tools.DBConn;
import com.yuncai.core.tools.HttpOut;
import com.yuncai.core.tools.LogUtil;
import com.yuncai.core.util.DBHelper;
import com.yuncai.core.util.DBUpload; /**
* @author gx
* @version 2014-4-3
*/
public class FileUploadServlet extends HttpServlet { private static final long serialVersionUID = -3096800116651263134L; private String fileSizeLimit; public void init(ServletConfig config) throws ServletException {
this.fileSizeLimit = config.getInitParameter("fileSizeLimit");
} public void destroy() {
super.destroy();
} public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
HttpSession session = request.getSession();
String uploadDir = "upload" + File.separatorChar + "apk" + File.separatorChar;
String ctxDir = session.getServletContext().getRealPath(String.valueOf(File.separatorChar));
if (!ctxDir.endsWith(String.valueOf(File.separatorChar))) {
ctxDir = ctxDir + File.separatorChar;
}
File savePath = new File(ctxDir + uploadDir);
if (!savePath.exists()) {
savePath.mkdirs();
}
String saveDirectory = ctxDir + uploadDir;
int maxPostSize = 80 * 1024 * 1024;
String encoding = "UTF-8";
MultipartRequest multi = null;
try {
multi = new MultipartRequest(request, saveDirectory, maxPostSize, encoding);
} catch (IOException e) {
e.printStackTrace();
return;
} Enumeration<?> files = multi.getFileNames();
while (files.hasMoreElements()) {
String name = (String) files.nextElement();
File f = multi.getFile(name);
if (f != null) { Connection conn = DBConn.getConn("sqlServer");
String sql ="";
PreparedStatement ps=null;
sql = "select ID from T_Channel where NAME=?";
ResultSet rs =null;
try {
conn = DBConn.getConn("sqlServer");
sql ="insert into table(isValid,info) values(?,?)";
ps=conn.prepareStatement(sql); ps.setString(2, request.getParameter("info"));
ps.setString(1, request.getParameter("isValid"));
ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
if(DBHelper.isNoNull(ps))
ps.close();
if(DBHelper.isNoNull(conn))
conn.close();
} catch (SQLException e) {
}
}
}
} } public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
this.doPost(request, response);
} public String getFileSizeLimit() {
return fileSizeLimit;
} public void setFileSizeLimit(String fileSizeLimit) {
this.fileSizeLimit = fileSizeLimit;
} }