【基于Socket模拟Http协议上传文件】

永久链接: http://gaojingsong.iteye.com/blog/2414484

预览文章: 【Http文件上传协议解析】

 

核心代码：

import java.io.BufferedReader;

import java.io.File;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.InetAddress;

import java.net.Socket;

import java.net.URL;

import java.net.UnknownHostException;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Random;

 

 

public class SocketUploadUtil {

public static void main(String[] args) throws Exception {

// 判断端口号

int port = 9090;

// 构建socket,用于与服务器的联接

Socket socket = new Socket("127.0.0.1", port);

String path ="http://localhost:9090/mgr/upload";

String file = "c:/examples.cfg";

 

HashMap<String, String> params = new HashMap<String, String>();

params.put("email", "[e-mail]");

 

FileProperty f = new FileProperty("examples.cfg", new File(file), "file1", "text/plain");

List<FileProperty> files = new ArrayList<FileProperty>();

files.add(f);

uploadFile(socket,port, path, params,files);

}

/**

* descript: 用于文件上传的帮助类

* 直接通过http协议提交数据到服务器。 实现类似于下面web页面提交数据的功能 

<form method="post" 

 action="upload" 

 enctype="multipart/form-data">

 

<label>email:</label>

<input type="text" name="email" value="[e-mail]">

<br><br>

 

<label>File1:</label>

<input type="file" name="file1">

<br><br>

 

<label>File2:</label>

<input type="file" name="file2">

<br><br>

 

<br>

<input type="submit" value="upload">

</form>

* @throws IOException

* @throws UnknownHostException

*/

public static boolean uploadFile(Socket socket,int port,

String path, Map<String, String> params,

List<FileProperty> files) throws UnknownHostException, IOException {

Random r=new Random();

// 属性数据的分隔线

final String BOUNDARY = "---------------------------"+ r.nextInt(9999999);

final String ENDLINE = "--" + BOUNDARY + "--\r\n";

long fileInEntityDataLength = 0; // 存http协议实体部分文件数据的总长度

// 下面开始计算http协议实体部分的总长度

// 1.先计算文件部分包括文件属性和文件内容的长度

for (FileProperty uploadFile : files) {

StringBuilder sb = new StringBuilder();

sb.append("--");

sb.append(BOUNDARY);

sb.append("\r\n");

sb.append("Content-Disposition: form-data; name=\""

+ uploadFile.getParameterName() + "\";filename=\""

+ uploadFile.getFileName() + "\"\r\n");

sb.append("Content-Type: " + uploadFile.getContenttype()

+ "\r\n\r\n");

sb.append("\r\n");

// 以上形成了文件的属性值部分的参数长度

fileInEntityDataLength += sb.toString().length();

// 再加上文件内容的总长度

if (uploadFile.getInputStream() != null) { // 如果用的是文件流的话，就计算流文件长度

fileInEntityDataLength += uploadFile.getFile().length();

} else { // 否则计算二进制文件长度

fileInEntityDataLength += uploadFile.getData().length;

}

}

// 2.再计算文本属性部分的长度

StringBuilder sb2 = new StringBuilder();

for (Map.Entry<String, String> entry : params.entrySet()) {

sb2.append("--");

sb2.append(BOUNDARY);

sb2.append("\r\n");

sb2.append("Content-Disposition: form-data; name=\""

+ entry.getKey() + "\"\r\n\r\n");

sb2.append(entry.getValue());

sb2.append("\r\n");

}

// 计算传输给服务器的实体数据的总长度

// 实体数据总长度=文本数据总长+文件内容总长+结束语长度

long datalength = sb2.toString().getBytes().length + fileInEntityDataLength+ ENDLINE.getBytes().length;

 

// 构建URL对象，用于联接网络

URL url = new URL(path);

// 输出流

OutputStream outputStream = socket.getOutputStream();

 

// 下面完成http请求头的拼接和发送

StringBuffer protocal = new StringBuffer( "POST " + url.getPath() + " HTTP/1.1\r\n");

protocal.append( "Accept: image/jpeg, application/x-ms-application, image/gif, application/xaml+xml, " +

"image/pjpeg, application/x-ms-xbap, application/vnd.ms-excel, application/vnd.ms-powerpoint, application/msword, */*\r\n");

protocal.append( "Accept-Language: zh-CN\r\n" );

 

//以下的两行最重要

protocal.append(  "Content-Type: multipart/form-data; boundary="+ BOUNDARY + "\r\n" );

protocal.append(  "Content-Length: " + datalength + "\r\n" );

 

protocal.append( "Connection: Keep-Alive\r\n" );

protocal.append(  "Host: " + url.getHost() + ":" + port + "\r\n" );

protocal.append( "\r\n" );

System.out.println("打印一下http头信息:"+   protocal.toString());

//将请求的命令行和请求头信息发出

outputStream.write(   protocal.toString().getBytes());

// 再将文件中的所有的文本类型的普通参数数据都发送出去

outputStream.write(sb2.toString().getBytes());

 

// 将所有文件类型的实体数据发送出去

for (FileProperty fp : files) {

StringBuilder fsb = new StringBuilder();

fsb.append("--");

fsb.append(BOUNDARY);

fsb.append("\r\n");

fsb.append(

"Content-Disposition: form-data; name=\""

+ fp.getParameterName() + "\"; filename=\""

+ fp.getFileName() + "\"").append("\r\n");

fsb.append("Content-Type: " + fp.getContenttype() + "\r\n\r\n");

outputStream.write(fsb.toString().getBytes());

// 发送文件真正的数据

if (fp.getInputStream() != null) { // 是大文件的话，用流输出

byte[] buffer = new byte[2048];

int length = 0;

while ((length = fp.getInputStream().read(buffer, 0, 2048)) != -1) {

outputStream.write(buffer, 0, length);

}

fp.getInputStream().close(); // 关闭输入流

} else { // 是小文件的话，用byte[] data输出

outputStream.write(fp.getData(), 0, fp.getData().length);

}

outputStream.write("\r\n".getBytes());

}

// 最后是发送数据的结束标志，表示数据发送完毕

outputStream.write(ENDLINE.getBytes());

outputStream.flush();

 

// 读取服务器端的回应

BufferedReader read = new BufferedReader(new InputStreamReader(

socket.getInputStream()));

//System.out.println(read.readLine());

if (read.readLine().indexOf("200") == -1) {

return false;

}

outputStream.close();

read.close();

socket.close();

return true;

}

}

 

 

结果验证

 

 

 

 

 

 

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.InputStream;

 

/**

 * 要上传的文件的属性的封装类

 */

public class FileProperty {

private byte[] data;   //要上传的数据，小数据量上传

private InputStream inputStream;  //要上传的数据的输入流,用于大文件上传真

private File file;    //要上传的文件对象

 

private String fileName;  //要上传的文件名

private String parameterName;   //要上传的文件的请求参数名称

private String contenttype="application/octet-stream";

/**

* 此构造方法用于上传一些较小的数据.

* @param filename

* @param data : 只适合存储较少的数据

* @param paramterName

* @param contenttype

*/

public FileProperty(String filename,byte[] data,String paramterName,String contenttype){

this.data=data;

this.fileName=filename;

this.parameterName=paramterName;

if(contenttype!=null){

this.contenttype=contenttype;

}

}

/**

* 可以传较大的文件

* @param filename  文件名

* @param file    要上传的文件

* @param parameterName   文件的参数名字

* @param contenttype     文件类型

*/

public FileProperty(String filename,File file,String parameterName,String contenttype){

this.fileName=filename;

this.parameterName=parameterName;

this.file=file;

try {

this.inputStream=new FileInputStream(file);

} catch (FileNotFoundException e) {

e.printStackTrace();

}

if(contenttype!=null){

this.contenttype=contenttype;

}

}

public byte[] getData() {

return data;

}

public void setData(byte[] data) {

this.data = data;

}

public InputStream getInputStream() {

return inputStream;

}

public void setInputStream(InputStream inputStream) {

this.inputStream = inputStream;

}

public File getFile() {

return file;

}

public void setFile(File file) {

this.file = file;

}

public String getFileName() {

return fileName;

}

public void setFileName(String fileName) {

this.fileName = fileName;

}

public String getParameterName() {

return parameterName;

}

public void setParameterName(String parameterName) {

this.parameterName = parameterName;

}

public String getContenttype() {

return contenttype;

}

public void setContenttype(String contenttype) {

this.contenttype = contenttype;

}

 

 

 

}