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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/394068.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java nginx 例子_Java及nginx实现文件权限控制代码实例

我们知道&#xff0c;使用nginx作为文件下载服务器&#xff0c;可以极大地降低对后端Java服务器的负载冲击&#xff0c;但是nginx本身并不提供授权控制&#xff0c;因此好的方案是由后端服务器实现权限控制&#xff0c;最好的方式是直接复用应用的认证体系&#xff0c;最大化的…

leetcode934. 最短的桥(dfs+bfs)

在给定的二维二进制数组 A 中&#xff0c;存在两座岛。&#xff08;岛是由四面相连的 1 形成的一个最大组。&#xff09; 现在&#xff0c;我们可以将 0 变为 1&#xff0c;以使两座岛连接起来&#xff0c;变成一座岛。 返回必须翻转的 0 的最小数目。&#xff08;可以保证答…

谢烟客---------Linux之DNS服务系统的基础知识

DNS Domain Name Server1)C/S架构&#xff1a;SOCKET通信IP PORT2&#xff09;应用层协议&#xff1a;资源子网BIND Berkerley Information Name DomainDNS由来1&#xff09;统一名字&#xff0c;自己维护 <自己查询>解析: 基于key查找value: 查询数据库(二维关系的表: …

Java实现点击导出excel页面遮罩屏蔽,下载完成后解除遮罩

一、问题场景 最近在做数据统计功能&#xff0c;需求是导出大数据量的excel&#xff0c;时间间隔较长&#xff0c;大概需要十秒左右&#xff0c;点击导出后&#xff0c;页面没有做任何处理&#xff0c;用户也不知道是否正在导出&#xff1b;如果没有做交互上的限制&#xff0c;…

pbs 支持 java_Linux下Java安装与配置

安装以JDK1.6.0_43为例下载jdk-6u43-linux-x64.bin&#xff0c;http://www.oracle.com/technetwork/java/javase/downloads/index.html增加可执行权限 chmod x jdk-6u43-linux-x64.bin&#xff0c;执行 ./jdk-6u43-linux-x64.bin 生成目录jdk1.6.0_43拷贝到/usr/share下&#x…

使用Chatkit构建Node.js命令行聊天应用程序

by Hugo雨果 使用Chatkit构建Node.js命令行聊天应用程序 (Build a Node.js command-line chat application with Chatkit) Building chat in your app can be pretty complex. Yet, with Chatkit, implementing fully-featured chat is nothing but a few lines of code.在您的…

java 毫秒转分钟和秒_Java程序将毫秒转换为分钟和秒

Java程序将毫秒转换为分钟和秒在上面的程序中&#xff0c;您将学习如何在Java中将毫秒分别转换为分钟和秒。示例1&#xff1a;将毫秒分别转换为分钟和秒import java.util.concurrent.TimeUnit;public class Milliseconds {public static void main(String[] args) {long millis…

Andrew Ng机器学习之一 导论

监督学习与无监督学习 监督学习&#xff08;Supervised Learning) Ng的原文是&#xff1a; We gave the algorithm a data set that the "right answers" were given. 即给定了一个正确结果的集合供算法学习&#xff0c;强调了需要实现准备好正负样本喂给机器。 无监…

leetcode994. 腐烂的橘子(bfs)

在给定的网格中&#xff0c;每个单元格可以有以下三个值之一&#xff1a; 值 0 代表空单元格&#xff1b; 值 1 代表新鲜橘子&#xff1b; 值 2 代表腐烂的橘子。 每分钟&#xff0c;任何与腐烂的橘子&#xff08;在 4 个正方向上&#xff09;相邻的新鲜橘子都会腐烂。 返回直…

ES6对象的扩展

1.属性简写表示 2.方法简写表示 属性与方法简写&#xff1a; 3.属性名表达式 ES6允许字面量定义对象时&#xff0c;用方法二&#xff08;表达式&#xff09;作为对象的属性名&#xff0c;即把表达式放在方括号内。 4.Object.is()比较两个值是否严格相等 转载于:https://www.cnb…

Spring Cloud项目MVN编译 -- Non-resolvable import POM

最近利用闲余时间&#xff0c;打算搭建一套基于Spring Cloud G版的微服务架构(Spring boot 2.1.0)&#xff0c;一顿操作之后,IDEA也没有提示什么错误,自认为微服务搭建完毕。启动项目前&#xff0c;习惯性的Maven -clean了一下&#xff0c;我去&#xff0c;IDEA里面的Maven Pro…

datax底层原理_Datax 插件加载原理

Datax 插件加载原理插件类型Datax有好几种类型的插件&#xff0c;每个插件都有不同的作用。reader&#xff0c; 读插件。Reader就是属于这种类型的writer&#xff0c; 写插件。Writer就是属于这种类型的transformer&#xff0c; 目前还未知handler&#xff0c; 主要用于任务执行…

mysql windows身份验证_SQL Server 2005 怎么就不能用Windows身份验证方式登录呢?

SQL Server 2005 自从装到我的电脑上始终无法使用Windows身份验证的方式登录,由于使用用户名和密码登录还算顺畅,所以一直忽略了这SQL Server 2005 自从装到我的电脑上始终无法使用Windows身份验证的方式登录,由于使用用户名和密码登录还算顺畅,所以一直忽略了这个问题,直到又有…

JavaScript正则表达式快速简单的指南

Interested in learning JavaScript? Get my ebook at jshandbook.com有兴趣学习JavaScript吗&#xff1f; 在jshandbook.com上获取我的电子书 正则表达式简介 (Introduction to Regular Expressions) A regular expression (also called regex for short) is a fast way to w…

leetcode104. 二叉树的最大深度(dfs)

给定一个二叉树&#xff0c;找出其最大深度。二叉树的深度为根节点到最远叶子节点的最长路径上的节点数。说明: 叶子节点是指没有子节点的节点。示例&#xff1a; 给定二叉树 [3,9,20,null,null,15,7]&#xff0c;3/ \9 20/ \15 7 返回它的最大深度 3 。代码 class Soluti…

[解读REST] 3.基于网络应用的架构

链接上文[解读REST] 2.REST用来干什么的&#xff1f;&#xff0c;上文中解释到什么是架构风格和应该以怎样的视角来理解REST&#xff08;Web的架构风格&#xff09;。本篇来介绍一组自洽的术语&#xff0c;用它来描述和解释软件架构&#xff1b;以及列举下对于基于网络的应用来…

js判断对象还是数组

1.对于Javascript 1.8.5&#xff08;ECMAScript 5&#xff09;&#xff0c;变量名字.isArray( )可以实现这个目的 var a[]; var b{}; Array.isArray(a);//true Array.isArray(b)//false 2.如果你只是用typeof来检查该变量&#xff0c;不论是array还是object&#xff0c;都将返回…

mysql 除去列名打印_sql – 使用beeline时避免在列名中打印表名

在beeline中使用hive时使用简单的select查询我想在列名中返回没有表名的表作为默认值.例数据CREATE TABLE IF NOT EXISTS employee ( eid int, name String,salary String, destination String)COMMENT Employee detailsROW FORMAT DELIMITEDFIELDS TERMINATED BY \tLINES TERM…

移动应用程序和网页应用程序_如何开发感觉像本机移动应用程序的渐进式Web应用程序...

移动应用程序和网页应用程序by Samuele Dassatti通过萨穆尔达萨蒂 如何开发感觉像本机移动应用程序的渐进式Web应用程序 (How you can develop Progressive Web Apps that feel like native mobile apps) I’m currently developing a Progressive Web App that will also ser…

leetcode1162. 地图分析(bfs)

你现在手里有一份大小为 N x N 的「地图」&#xff08;网格&#xff09; grid&#xff0c;上面的每个「区域」&#xff08;单元格&#xff09;都用 0 和 1 标记好了。其中 0 代表海洋&#xff0c;1 代表陆地&#xff0c;请你找出一个海洋区域&#xff0c;这个海洋区域到离它最近…