生活随笔
收集整理的這篇文章主要介紹了
activeMQ在文件上传的应用
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
本次試驗主要用到了activeMq和上傳插件uploadify的知識，感謝以下兩篇文章的作者。
1.http://itindex.net/detail/47160-java-jquery-%E4%B8%8A%E4%BC%A0
2.http://blog.csdn.net/jiuqiyuliang/article/details/47160259
本文中不再提供activeMq和uploadify的介紹。
項目結構
web.xml
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="WebApp_ID" version="3.0"><display-name>uploadifyDemo</display-name><welcome-file-list><welcome-file>index.jsp</welcome-file></welcome-file-list><servlet><servlet-name>upload</servlet-name><servlet-class>com.dao.chu.upload.Upload</servlet-class></servlet><servlet-mapping><servlet-name>upload</servlet-name><url-pattern>/servlet/Upload</url-pattern></servlet-mapping></web-app>
index.jsp
文件中很多注釋掉的代碼有興趣可以打開探究uploadify插件。
<%@ page language="java" contentType="text/html; charset=utf-8"%>
<%String path = request.getContextPath();String basePath = request.getScheme() + "://"+ request.getServerName() + ":" + request.getServerPort()+ path + "/";
%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<base href="<%=basePath%>">
<title>Upload</title><!--裝載文件-->
<link href="css/uploadify.css" rel="stylesheet" type="text/css" />
<script type="text/javascript" src="uploadify/jquery-1.9.1.js"></script>
<script type="text/javascript" src="uploadify/jquery.uploadify.min.js"></script><!--ready事件-->
<script type="text/javascript">$(document).ready(function() {$("#uploadify").uploadify({'uploader' : 'servlet/Upload','swf' : 'uploadify/uploadify.swf','cancelImg' : 'img/uploadify-cancel.png','folder' : 'uploads',//您想將文件保存到的路徑'queueID' : 'fileQueue',//與下面的id對應'queueSizeLimit' : 20,'fileDesc' : 'rar文件或zip文件','fileExt' : '*.rar;*.zip', //控制可上傳文件的擴展名，啟用本項時需同時聲明fileDesc'auto' : false,'multi' : true,'simUploadLimit' : 2,'buttonText' : '選擇文件','onDialogOpen' : function() {//當選擇文件對話框打開時觸發/* alert( 'Open!'); */},'onSelect' : function(file) {//當每個文件添加至隊列后觸發/* alert( 'id: ' + file.id+ ' - 索引: ' + file.index+ ' - 文件名: ' + file.name+ ' - 文件大小: ' + file.size+ ' - 類型: ' + file.type+ ' - 創建日期: ' + file.creationdate+ ' - 修改日期: ' + file.modificationdate+ ' - 文件狀態: ' + file.filestatus); */},'onSelectError' : function(file,errorCode,errorMsg) {//當文件選定發生錯誤時觸發alert( 'id: ' + file.id+ ' - 索引: ' + file.index+ ' - 文件名: ' + file.name+ ' - 文件大小: ' + file.size+ ' - 類型: ' + file.type+ ' - 創建日期: ' + file.creationdate+ ' - 修改日期: ' + file.modificationdate+ ' - 文件狀態: ' + file.filestatus+ ' - 錯誤代碼: ' + errorCode+ ' - 錯誤信息: ' + errorMsg);},'onDialogClose' : function(swfuploadifyQueue) {//當文件選擇對話框關閉時觸發if( swfuploadifyQueue.filesErrored > 0 ){alert( '添加至隊列時有'+swfuploadifyQueue.filesErrored+'個文件發生錯誤n'+'錯誤信息:'+swfuploadifyQueue.errorMsg+'n選定的文件數:'+swfuploadifyQueue.filesSelected+'n成功添加至隊列的文件數:'+swfuploadifyQueue.filesQueued+'n隊列中的總文件數量:'+swfuploadifyQueue.queueLength);}},'onQueueComplete' : function(stats) {//當隊列中的所有文件全部完成上傳時觸發/* alert( '成功上傳的文件數: ' + stats.successful_uploads+ ' - 上傳出錯的文件數: ' + stats.upload_errors+ ' - 取消上傳的文件數: ' + stats.upload_cancelled+ ' - 出錯的文件數' + stats.queue_errors); */},'onUploadComplete' : function(file,swfuploadifyQueue) {//隊列中的每個文件上傳完成時觸發一次/* alert( 'id: ' + file.id+ ' - 索引: ' + file.index+ ' - 文件名: ' + file.name+ ' - 文件大小: ' + file.size+ ' - 類型: ' + file.type+ ' - 創建日期: ' + file.creationdate+ ' - 修改日期: ' + file.modificationdate+ ' - 文件狀態: ' + file.filestatus); */},'onUploadError' : function(file,errorCode,errorMsg,errorString,swfuploadifyQueue) {//上傳文件出錯是觸發（每個出錯文件觸發一次）alert( 'id: ' + file.id+ ' - 索引: ' + file.index+ ' - 文件名: ' + file.name+ ' - 文件大小: ' + file.size+ ' - 類型: ' + file.type+ ' - 創建日期: ' + file.creationdate+ ' - 修改日期: ' + file.modificationdate+ ' - 文件狀態: ' + file.filestatus+ ' - 錯誤代碼: ' + errorCode+ ' - 錯誤描述: ' + errorMsg+ ' - 簡要錯誤描述: ' + errorString);},'onUploadProgress' : function(file,fileBytesLoaded,fileTotalBytes,queueBytesLoaded,swfuploadifyQueueUploadSize) {//上傳進度發生變更時觸發/* alert( 'id: ' + file.id+ ' - 索引: ' + file.index+ ' - 文件名: ' + file.name+ ' - 文件大小: ' + file.size+ ' - 類型: ' + file.type+ ' - 創建日期: ' + file.creationdate+ ' - 修改日期: ' + file.modificationdate+ ' - 文件狀態: ' + file.filestatus+ ' - 當前文件已上傳: ' + fileBytesLoaded+ ' - 當前文件大小: ' + fileTotalBytes+ ' - 隊列已上傳: ' + queueBytesLoaded+ ' - 隊列大小: ' + swfuploadifyQueueUploadSize); */},'onUploadStart': function(file) {//上傳開始時觸發（每個文件觸發一次）/* alert( 'id: ' + file.id+ ' - 索引: ' + file.index+ ' - 文件名: ' + file.name+ ' - 文件大小: ' + file.size+ ' - 類型: ' + file.type+ ' - 創建日期: ' + file.creationdate+ ' - 修改日期: ' + file.modificationdate+ ' - 文件狀態: ' + file.filestatus ); */},'onUploadSuccess' : function(file,data,response) {//上傳完成時觸發（每個文件觸發一次）/* alert( 'id: ' + file.id+ ' - 索引: ' + file.index+ ' - 文件名: ' + file.name+ ' - 文件大小: ' + file.size+ ' - 類型: ' + file.type+ ' - 創建日期: ' + file.creationdate+ ' - 修改日期: ' + file.modificationdate+ ' - 文件狀態: ' + file.filestatus+ ' - 服務器端消息: ' + data+ ' - 是否上傳成功: ' + response); */}});});
</script>
</head><body><div id="fileQueue"></div><input type="file" name="uploadify" id="uploadify" /><p><!-- 上傳第一個未上傳的文件 --><a href="javascript:$('#uploadify').uploadify('upload')">上傳</a><!-- 取消第一個未取消的文件 --><a href="javascript:$('#uploadify').uploadify('cancel')">取消上傳</a><a href="javascript:$('#uploadify').uploadify('upload','*')">上傳所有文件</a>?<a href="javascript:$('#uploadify').uploadify('cancel','*')">取消所有上傳</a></p>
</body>
</html>
FileVo.java
這里封裝了文件的一些信息。
package com.dao.chu.orm;import java.io.Serializable;public class FileVo implements Serializable
{/*** serialVersionUID*/private static final long serialVersionUID = 1L;//保存的包路徑private String savePath;//保存全路徑private String filePath;//原文件名private String oldFileName;//新文件名private String newFileName;//文件大小private String fileSize;//擴展名private String extName;public String getSavePath(){return savePath;}public void setSavePath(String savePath){this.savePath = savePath;}public String getFilePath(){return filePath;}public void setFilePath(String filePath){this.filePath = filePath;}public String getOldFileName(){return oldFileName;}public void setOldFileName(String oldFileName){this.oldFileName = oldFileName;}public String getNewFileName(){return newFileName;}public void setNewFileName(String newFileName){this.newFileName = newFileName;}public String getFileSize(){return fileSize;}public void setFileSize(String fileSize){this.fileSize = fileSize;}public String getExtName(){return extName;}public void setExtName(String extName){this.extName = extName;}@Overridepublic String toString(){return "FileVo [savePath=" + savePath + ", filePath=" + filePath + ", oldFileName=" + oldFileName+ ", newFileName=" + newFileName + ", fileSize=" + fileSize + ", extName=" + extName + "]";}public FileVo(String savePath, String filePath, String oldFileName, String newFileName, String fileSize,String extName){super();this.savePath = savePath;this.filePath = filePath;this.oldFileName = oldFileName;this.newFileName = newFileName;this.fileSize = fileSize;this.extName = extName;}}
Upload.java
package com.dao.chu.upload;import java.io.File;
import java.io.IOException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.UUID;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;import com.dao.chu.orm.FileVo;
import com.dao.chu.util.MqProducer;@SuppressWarnings("serial")
public class Upload extends HttpServlet
{@SuppressWarnings("unchecked")public void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException{String savePath = this.getServletConfig().getServletContext().getRealPath("");savePath = savePath + "/uploads/";File f1 = new File(savePath);System.out.println(savePath);if (!f1.exists()){f1.mkdirs();}DiskFileItemFactory fac = new DiskFileItemFactory();ServletFileUpload upload = new ServletFileUpload(fac);upload.setHeaderEncoding("utf-8");List fileList = null;try{fileList = upload.parseRequest(request);}catch (FileUploadException ex){return;}Iterator<FileItem> it = fileList.iterator();String oldFileName = "";String newFileName = "";String extName = "";while (it.hasNext()){FileItem item = it.next();if (!item.isFormField()){oldFileName = item.getName();long size = item.getSize();String type = item.getContentType();System.out.println(size + " " + type);if (oldFileName == null || oldFileName.trim().equals("")){continue;}// 擴展名格式：if (oldFileName.lastIndexOf(".") >= 0){extName = oldFileName.substring(oldFileName.lastIndexOf("."));}File file = null;do{// 生成文件名：newFileName = UUID.randomUUID().toString();file = new File(savePath + newFileName + extName);} while (file.exists());File saveFile = new File(savePath + newFileName + extName);try{item.write(saveFile);Map<String, String> map = setFileVo(savePath, savePath, oldFileName, newFileName, String.valueOf(size), extName);//MQ發送消息MqProducer.sendMessage(map);}catch (Exception e){e.printStackTrace();}}}response.getWriter().print(newFileName + extName);}@SuppressWarnings("unused")private Map<String, String> setFileVo(String savePath, String filePath, String oldFileName, String newFileName, String fileSize,String extName){FileVo fileVo = new FileVo(savePath, filePath, oldFileName, newFileName, fileSize, extName);Map<String, String> map = mapPutFileVo(fileVo);return map;}private Map<String, String> mapPutFileVo(FileVo fileVo){Map<String, String> map = new HashMap<String,String>();map.put("savePath", fileVo.getSavePath());map.put("filePath", fileVo.getFilePath());map.put("newFileName", fileVo.getNewFileName());map.put("oldFileName", fileVo.getOldFileName());map.put("extName", fileVo.getExtName());map.put("fileSize", fileVo.getFileSize());return map;}
}
MqProducer.java
注意此處將每次發送的消息設為10條，也就是上傳一個文件發送十條消息。一般只設為1即可。
package com.dao.chu.util;import java.util.Map;import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.MessageProducer;
import javax.jms.Session;import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;/*** * MQ生產者，發送消息* @see [相關類/方法]* @since [產品/模塊版本]*/
public class MqProducer
{// 默認連接用戶名private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;// 默認連接密碼private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;// 默認連接地址private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;// 發送的消息數量private static final int SENDNUM = 10;/*** * 發送消息,外部調用方法* * @see [類、類#方法、類#成員]*/public static void sendMessage(Map<String, String> map){// 連接工廠ConnectionFactory connectionFactory;// 連接Connection connection = null;// 會話 接受或者發送消息的線程Session session;// 消息的目的地Destination destination;// 消息生產者MessageProducer messageProducer;// 實例化連接工廠connectionFactory =new ActiveMQConnectionFactory(MqProducer.USERNAME, MqProducer.PASSWORD, MqProducer.BROKEURL);try{// 通過連接工廠獲取連接connection = connectionFactory.createConnection();// 啟動連接connection.start();// 創建sessionsession = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);// 創建一個名稱為NewFileList的消息隊列destination = session.createQueue("NewFileList");// 創建消息生產者messageProducer = session.createProducer(destination);// 發送消息send(session, messageProducer,map);session.commit();}catch (Exception e){e.printStackTrace();}finally{if (connection != null){try{connection.close();}catch (JMSException e){e.printStackTrace();}}}}/*** 發送消息，內部方法* * @param session* @param messageProducer 消息生產者* @throws Exception*/public static void send(Session session, MessageProducer messageProducer,Map<String, String> map)throws Exception{for (int i = 0; i < MqProducer.SENDNUM; i++){MapMessage message = session.createMapMessage();message.setObject("map", map);System.out.println("發送消息：Activemq 發送消息" + map.toString());// 通過消息生產者發出消息messageProducer.send(message);}}}
運行效果
主頁
選擇文件并點擊上傳所有文件
控制臺共打印出50條消息
打開本地的mq，看隊列
可看到共有50條消息。
點擊NewFileList并點擊某個消息
可看到具體發送的消息，里面我們封裝了文件名稱，文件大小，文件路徑等。這樣我們就可以實時監控文件上傳情況。
源碼下載
轉載于:https://www.cnblogs.com/tongrui/p/6376251.html
總結
以上是生活随笔為你收集整理的activeMQ在文件上传的应用的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
