文件上传
篇一:自定义简单的协议用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