文件上传协议

文件上传协议 篇一:自定义简单的协议用socket实现文件上传 3、服务端定义一个ServerSocket 监听一个某个端口，当 有上传请求到来时就 在线程池中取一个线程处理请求。 package com.my.socket.server; import java.io.File; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import com.my.socket.constant.MyServerConstant; public final class MySockerServer { public static void main(String[] args) throws IOException { final File savedir = new File(MyServerCons tant.SAVE_DIRECTORY); if (!savedir.exists()) savedir.mkdir(); ServerSocket myServerSocket = new ServerSocket(MyServerConstant.PORT, 50); while (true) 1 { Socket mySocket = myServerSocket.accept(); ExecutorService executorService = Executors.newFixedThreadPool(8); executorService.execute(new ServerHander(mySocket, savedir)); } } } 4、服务端处理上传的线程类: package com.my.socket.server; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.util.HashMap; import java.util.Map; import com.my.socket.constant.MyServerConstant; import com.my.socket.util.StreamUtil; public class ServerHander implements Runnable { private Socket mySocket = null; private File saveFileDirectory = null; 2 public ServerHander(Socket mySocket, File saveFileDirectory) { super(); this.mySocket = mySocket; this.saveFileDirectory = saveFileDirectory; } @Override public void run() { try { InputStream in = mySocket.getInputStream(); byte[] headData = StreamUtil.readHead(in);//上传的文件头 读入数组 Map<String, String headParamter = this.pareHeader(new String(headData, MyServerConstant.UTF_8)); File saveFile = new File(this.saveFileDirectory,headParamter.get(MyServerConstant.FILE_NAME)); if (!saveFile.exists()) saveFile.createNewFile(); OutputStream fos = new FileOutputStream(saveFile); byte[] buffer = new byte[1024]; while ((len = in.read(buffer, 0, 1024)) != -1) { fos.write(buffer, 0, len); } fos.flush(); fos.close(); System.out.println(end); OutputStream os = mySocket.getOutputStream(); os.flush(); if (mySocket != null) mySocket.close(); } catch (IOException e) 3 { e.printStackTrace(); } } private Map<String, String pareHeader(String param) { Map<String, String headParamter = new HashMap<String, String(); if (param == null || .endsWith(param)) throw new RuntimeException(上传 的包是错误的～); String[] params = param.split(;); for (String s : params) { headParamter.put(entry[0], entry[1]); } return headParamter; } } 5、一个读取文件头的工具类: package com.my.socket.util; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; public final class StreamUtil { private StreamUtil() { } public static byte[] readHead(InputStream in) { 4 ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); char c; StringBuffer sb = new StringBuffer(); try { while ((c = (char) in.read()) != -1) { 篇二:文件上传与下载 文件上传与下载 上传 文件上传概述 ? 实现web开发中的文件上传功能，需完成如下二步操作: ? 在web页面中添加上传输入项 ? 在servlet中读取上传文件的数据，并保存到服务器硬盘中。 ? 如何在web页面中添加上传输入项? ? <input type=“file”标签用于在web页面中添加文件上传输入项，设置文件上传输入项时须注意: ? 1、必须要设置input输入项的name属性，否则浏览器将不会发送上传文件的数据。 ? ,、必须把form的enctype属值设为multipart/form-data.设置该值后，浏览器在上传文件时，将把文件数据附带在http请求消息体中，并使用,，,,协议对上传的文件进行描述，以方便接收方对上传数据进行解析 5 和处理。 ? 3、单的提交方式要是post ? 如何在Servlet中读取文件上传数据，并保存到本地硬盘中? ? Request对象提供了一个getInputStream方法，通过这个方法可以读取到客户端提交过来的数据。但由于用户可能会同时上传多个文件，在servlet端编程直接读取上传数据，并分别解析出相应的文件数据是一项非常麻烦的工作，示例。 ? 为方便用户处理文件上传数据，Apache 开源组织提供了一个用来处理表单文件上传的一个开源组件 ( Commons-fileupload )，该组件性能优异，并且其API使用极其简单，可以让开发人员轻松实现web文件上传功能，因此在web开发中实现文件上传功能，通常使用Commons-fileupload组件实现。 ? 使用Commons-fileupload组件实现文件上传，需要导入该组件相应的支撑jar包:Commons-fileupload和commons-io。commons-io 不属于文件上传组件的开发jar文件，但Commons-fileupload 组件从1.1 版本开始，它工作时需要commons-io包的支持。 文件上传步骤 ? 实现步骤 ,、创建DiskFileItemFactory对象，设置缓冲区大小和 6 临时文件目录 ,、使用DiskFileItemFactory 对象创建ServletFileUpload对象，并设置上传文件的大小限制。 ,、调用ServletFileUpload.parseRequest方法解析request对象，得到一个保存了所有上传内容的List对象。 ,、对list进行迭代，每迭代一个FileItem对象，调用其isFormField方法判断是否是上传文件 ? True 为普通表单字段，则调用getFieldName、getString方法得到字 段名和字段值 ? False 为上传文件，则调用getInputStream方法得到数据输入流，从 而读取上传数据。 FileUpload上传操作核心API 1、DiskFileItemFactory 磁盘文件项工厂类 public DiskFileItemFactory(int sizeThreshold, java.io.File repository) 构造工厂时，指定内存缓冲区大小和临时文件存放位置 public void setSizeThreshold(int sizeThreshold) 设置内存缓冲区大小，默认10K public void setRepository(java.io.File repository)设置临时文件存放位置，默认System.getProperty(java.io.tmpdir). 7 内存缓冲区: 上传文件时，上传文件的内容优先保存在内存缓冲区中，当上传文件大小超过缓冲区大小，就会在服务器端产生临时文件 临时文件存放位置: 保存超过了内存缓冲区大小上传文件而产生临时文件 * 产生临时文件可以通过 FileItem的delete方法删除 2、ServletFileUpload 文件上传核心类 static boolean isMultipartContent(javax.servlet.http.HttpServletRequest request) 判断request的编码方式是否为multipart/form-data java.util.List parseRequest(javax.servlet.http.HttpServletRequest request) 解析request，将请求体每个部分封装FileItem对象，返回List<FileItem void setFileSizeMax(long fileSizeMax) 设置单个文件上传大小 void setSizeMax(long sizeMax) 设置总文件上传大小 void setHeaderEncoding(java.lang.String encoding) 设置编码集 解决上传文件名乱码 ***** 3、FileItem 表示文件上传表单中 每个数据部分 boolean isFormField() 判断该数据项是否为文件上传 8 项，true 不是文件上传 false 是文件上传 if(fileItem.isFormField()){ // 不是上传项 java.lang.String getFieldName() 获得普通表单项name属性 java.lang.String getString() / java.lang.String getString(java.lang.String encoding) 获得普通表单项value属性 传入编码集用来解决输入value乱码 }else{ // 是上传项 java.lang.String getName() 获得上传文件名 (注意IE6存在路径) java.io.InputStream getInputStream() 获得上传文件内容输入流 // 上传文件 void delete() 删除临时文件(删除时，必须要管理输入输出流) } 注意事项:因为文件上传表单采用编码方式 multipart/form-data 与传统url编码不同，所有getParameter 方法不能使用 setCharacterEncoding 无法解决输入项乱码问题 9 JavaScript的多文件上传表单 ? 技巧: ? 每次动态增加一个文件上传输入框，都把它和删除按纽放置在一个单独的 div中，并对删除按纽的onclick事件进行响应，使之删除删除按纽所在的 div。 ? 如: this.parentNode.parentNode.removeChild(this.parentNode); 上传文件存在的问题 ? 上传文件后，在服务器端保存位置 第一类存放位置:直接存放WebRoot目录下 和 除WEB-INF META-INF的其它子目录下 例如: WebRoot/upload * 客户端可以直接在浏览器上通过url访问位置(资料无需通过权限控制，而可以直接访问) ---- 对上传资源安全性要求不高、或者资源需要用户直接可见 * 例如:购物商城商品图片 第二类存放位置:放入WEB-INF及其子目录 或者 不受tomcat服务器管理目录 例如: WebRoot/WEB-INF/upload 、c:\ 、d:\abc 10 * 客户端无法通过URL直接访问，必须由服务器内部程序才能读取 (安全性较高，可以很容易添加权限控制) * 例如:会员制在线视频 ? 上传文件在同一个目录重名问题 如果文件重名，后上传文件就会覆盖先上传文件 文件名 UUID filename = UUID.randomUUID().toString() + _ + filename; ? 为了防止同一个目录下方上传文件数量过多 ---- 必须采用目录分离算法 1) 按照上传时间进行目录分离 (周、月 ) 2) 按照上传用户进行目录分离 ----- 为每个用户建立单独目录 3) 按照固定数量进行目录分离 ------ 假设每个目录只能存放3000个文件 ，每当一个目录存满3000个文件后，创建一个新的目录 4) 按照唯一文件名的hashcode 进行目录分离 public static String generateRandomDir(String uuidFileName) { // 获得唯一文件名的hashcode int hashcode = uuidFileName.hashCode(); // 获得一级目录 int d1 = hashcode & 0xf; 11 // 获得二级目录 int d2 = (hashcode 4) & 0xf; return / + d2 + / + d1;// 共有256目录l } ? 乱码问题 普通编写项 value属性乱码 ------------- fileItem.getString(编码集); 上传文件项 文件名乱码 --------- fileupload.setHeaderEncoding(编码集); 下载 常见文件下载有两种方式 1、超链接直接指向下载资源 如果文件浏览器识别，将直接打开文件，显示在浏览 器上， 如果文件格式浏览器不识别，将弹出下载窗口 对于浏览器识别格式的文件，通过另存为进行下载 客户端访问服务器静态资源文件时，静态资源文件是通 过 缺省Servlet返回的，在tomcat配置文件conf/web.xml 找 到 --- org.apache.catalina.servlets.DefaultServlet 2、编写服务器程序，读取服务器端文件，完成下载 必须设置两个头信息 ，来自MIME协议 Content-Type Content-Disposition 12 response.setContentType(getServletContext().getMimeType(filename)); response.setHeader(Content-Disposition, attachment;filename= + filename); // 以附件形式打开，不管 格式浏览器是否识别 处理IE浏览器与Firefox浏览器乱码问题 if (agent.contains(MSIE)) { // IE浏览器 filename = URLEncoder.encode(filename, utf-8); filename = filename.replace(+, ); } else if (agent.contains(Firefox)) { // 火狐浏览器 BASE64Encoder base64Encoder = new BASE64Encoder(); filename = =?utf-8?B? + base64Encoder.encode(filename.getBytes(utf-8)) + ?=; } else if (agent.contains(Chrome)) { // google浏览器 filename = URLEncoder.encode(filename, utf-8); } else { // 其它浏览 器 filename = URLEncoder.encode(filename, utf-8); } 综合案例 网盘系统 需求: 1、系统提供一个文件上传功能，在用户上传文件后，文 件保存在服务器端指定目录，文件相关信息保存在数据库中 * 每上传一个文件，数据库中存在一条数据记录 2、系统提供一个文件下载功能，将数据表中所有资源信 息，显示在页面上，允许用户进行下载 13 创建数据库环境 create database day23 create table resources( id int primary key auto_increment, uuidname varchar(100) unique not null, realname varchar(40) not null, savepath varchar(100) not null, uploadtime timestamp , description varchar(255) ); 导入jar包 、c3p0-config.xml 、JDBCUtils工具类 篇三:Android之使用Http协议实现文件上传功能 注意一般使用Http协议上传的文件都比较小，一般是小于2M 这里示例是上传一个小的MP3文件 1.主Activity:MainActivity.java ? ? ? ? ? ? 14 ? ? ? public class MainActivity extends Activity { private static final String TAG = MainActivity; private EditText timelengthText; private EditText titleText; private EditText videoText; @Override public void onCreate(Bundle savedInstanceState) ?? { ?? super.onCreate(savedInstanceState); ?? setContentView(R.layout.main); ?? //提交上传按钮 ?? Button button = (Button) this.findViewById(R.id.button); ?? timelengthText = (EditText) this.findViewById(R.id.timelength);?? videoText = (EditText) this.findViewById(R.id.video); ?? titleText = (EditText) this.findViewById(R.id.title); ?? button.setOnClickListener(new View.OnClickListener() ?? { ?? @Override ?? public void onClick(View v) 15 ?? { ?? String title = titleText.getText().toString(); ?? String timelength = timelengthText.getText().toString();?? Map<String, String params = new HashMap<String, String();?? params.put(method, save); ?? params.put(title, title); ?? params.put(timelength, timelength); ?? try ?? { ??//得到SDCard的目录 ??File uploadFile = new File(Environment.getExternalStorageDirectory(), videoText.getText().toString());??//上传音频文件 ??FormFile formfile = new FormFile(02.mp3, uploadFile, video, audio/mpeg); ?? SocketHttpRequester.post(:8080/videoweb/video/manage.do, params, formfile); ??Toast.makeText(MainActivity.this, R.string.success, 1).show(); 16 ?? } ?? catch (Exception e) ?? { ??Toast.makeText(MainActivity.this, R.string.error, 1).show(); ??Log.e(TAG, e.toString()); ?? } ?? } ??}); ?? } ?? } 2.上传工具类，注意里面构造协议字符串需要根据不同的提交表单来处理 ?? public class SocketHttpRequester ?? { ?? /** ??* 发送xml数据 ??* @param path 请求地址 ??* @param xml xml数据 ??* @param encoding 编码 ??* @return ??* @throws Exception 17 ??*/ ?? public static byte[] postXml(String path, String xml, String encoding) throws Exception{ ??byte[] data = xml.getBytes(encoding); ??URL url = new URL(path); ??HttpURLConnection conn = (HttpURLConnection)url.openConnection();??conn.setRequestMethod(POST); ??conn.setDoOutput(true); ??// baidu ??conn.setRequestProperty(Content-Type, text/xml; charset=+ encoding); ??conn.setRequestProperty(Content-Length, String.valueOf(data.length)); ?? ??conn.setConnectTimeout(5 * 1000); ??OutputStream outStream = conn.getOutputStream(); ??outStream.write(data); ??outStream.flush(); ??outStream.close(); ??if(conn.getResponseCode()==200){ 18 ?? return readStream(conn.getInputStream()); ??} ??return null; ?? } ?? ?? /** ??* 直接通过HTTP协议提交数据到服务器,实现如下面 表单提交功能: ??*<FORM METHOD=POST ACTION=:8080/ssi/fileload/test.do enctype=multipart/form-data ?? <INPUT TYPE=text NAME=name ?? <INPUT TYPE=text NAME=id ?? <input type=file name=imagefile/ ?? <input type=file name=zip/ ?? </FORM ??* @param path 上传路径(注:避免使用localhost或 127.0.0.1这样的路径测试， ??*因为它会指向手机模拟器， 你可以使用或:8080这样的路径测试) ??* @param params 请求参数 key为参数名,value为参 数值 ??* @param file 上传文件 19 ??*/ ?? public static boolean post(String path, Map<String, String params, FormFile[] files) throws Exception ?? { ??//数据分隔线 ??final String BOUNDARY = ---------------------------7da2137580612; ??//数据结束标志 ---------------------------7da2137580612-- ??final String endline = -- + BOUNDARY + --/r/n; ?? ??//下面两个for循环都是为了得到数据长度参数，依据表 单的类型而定 ??//首先得到文件类型数据的总长度(包括文件分割线) ???int fileDataLength = 0; ???for(FormFile uploadFile : files) ???{ ??? StringBuilder fileExplain = new StringBuilder(); ??? fileExplain.append(--); ??? fileExplain.append(BOUNDARY); ??? fileExplain.append(/r/n); ??? fileExplain.append(Content-Disposition: form-data;name=/+ 20 uploadFile.getParameterName()+/;filename=/+ uploadFile.getFilname() + //r/n); ??? fileExplain.append(Content-Type: + uploadFile.getContentType()+/r/n/r/n); ??? fileExplain.append(/r/n); ??? fileDataLength += fileExplain.length(); ??? if(uploadFile.getInStream()!=null){ ??? fileDataLength += uploadFile.getFile().length(); ??? }else{ ??? fileDataLength += uploadFile.getData().length; ??? } ???} ???//再构造文本类型参数的实体数据 ???StringBuilder textEntity = new StringBuilder(); ???for (Map.Entry<String, String entry : params.entrySet()) ???{ ??? textEntity.append(--); ??? textEntity.append(BOUNDARY); ??? textEntity.append(/r/n); ??? textEntity.append(Content-Disposition: form-data; 21 name=/+ entry.getKey() + //r/n/r/n); ??? textEntity.append(entry.getValue()); ??? textEntity.append(/r/n); ???} ??? ???//计算传输给服务器的实体数据总长度(文本总长度+ 数据总长度+分隔符) ???int dataLength = textEntity.toString().getBytes().length + fileDataLength + endline.getBytes().length; ??? ???URL url = new URL(path); ???//默认端口号其实可以不写 ???int port = url.getPort()==-1 ? 80 : url.getPort(); ???//建立一个Socket链接 ???Socket socket = new Socket(InetAddress.getByName(url.getHost()), port);???//获 得一个输出流(从Android流到web) ???OutputStream outStream = socket.getOutputStream(); ???//下面完成HTTP请求头的发送 ???String requestmethod = POST + url.getPath()+ HTTP/1.1/r/n;???outStream.write(requestmethod.getBytes() 22 ); ???//构建accept ???String accept = Accept: image/gif, image/jpeg, image/pjpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/vnd.ms-excel, application/vnd.ms-powerpoint, application/msword, */*/r/n; ???outStream.write(accept.getBytes()); ???//构建language ???String language = Accept-Language: zh-CN/r/n; ???outStream.write(language.getBytes()); ???//构建contenttype ???String contenttype = Content-Type: multipart/form-data; boundary=+ BOUNDARY+ /r/n; ???outStream.write(contenttype.getBytes()); ???//构建contentlength ???String contentlength = Content-Length: + dataLength + /r/n;???outStream.write(contentlength.getBytes()); ???//构建alive ???String alive = Connection: Keep-Alive/r/n; 23 ???outStream.write(alive.getBytes()); ???//构建host ???String host = Host: + url.getHost() +:+ port +/r/n; ???outStream.write(host.getBytes()); ???//写完HTTP请求头后根据HTTP协议再写一个回车 换行 ???outStream.write(/r/n.getBytes()); ???//把所有文本类型的实体数据发送出来 ???outStream.write(textEntity.toString().getBytes());??? ???//把所有文件类型的实体数据发送出来 ???for(FormFile uploadFile : files) ???{ ??? StringBuilder fileEntity = new StringBuilder(); ??? fileEntity.append(--); ??? fileEntity.append(BOUNDARY); ??? fileEntity.append(/r/n); ??? fileEntity.append(Content-Disposition: form-data;name=/+ uploadFile.getParameterName()+/;filename=/+ uploadFile.getFilname() + //r/n); ??? fileEntity.append(Content-Type: + uploadFile.getContentType()+/r/n/r/n); 24 ??? outStream.write(fileEntity.toString().getBytes()); ??? //边读边写 ??? if(uploadFile.getInStream()!=null) ??? { ??? byte[] buffer = new byte[1024]; ??? int len = 0; ??? while((len = uploadFile.getInStream().read(buffer, 0, 1024))!=-1) ??? { ???outStream.write(buffer, 0, len); ??? } ??? uploadFile.getInStream().close(); ??? } ??? else ??? { 相关热词搜索:文件上传 协议 http协议上传文件 socket 协议文件上传 25