关于http上传大文件的问题

0 0

关于http上传大文件的问题3

这两天在用http上传大的文件，访问路径为http://172.18.7.108:8898/images/upload?name=bbbbb&type=qcow2&arch=i386&bucket=suzhou_bucket

接口上传文件时，总是返回OK!或者200，但是文件没有传过去，
http://hostIP:8898/images/upload
这个是我的连接路径，而且还需要参数name=bbbbb&type=qcow2&arch=i386&bucket=suzhou_bucket。

我用python代码访问的时候确实没有问题，但是用如下java代码则出现问题，有人知道怎么回事吗？

以下是我的代码。

public class vstarEnvImageStub {
public void uploadImageVStarv(String host, String port, String imagesrc,
String name, String imagetype, String arch, String bucketname,
String username, String password) {
String userPass = username + ":" + password;
String userPassEncoded = new BASE64Encoder()
.encode(userPass.getBytes());

String path = "http://" + host + ":" + port + "/images/upload?name="
+ name + "&type=" + imagetype + "&arch=" + arch + "&bucket="
+ bucketname;
String pathURL = "http://" + host + ":" + port + "/images/upload";
System.out.println(path);

try {
HttpURLConnection urlConnection;

URL url = new URL(pathURL);

urlConnection = (HttpURLConnection) url.openConnection();
urlConnection.setRequestMethod("PUT");
urlConnection.setRequestProperty("User-Agent", "put.py/1.0");
urlConnection.setRequestProperty("Connection", "keep-alive");
urlConnection.setRequestProperty("Transfer-Encoding", "chunked");
urlConnection.setRequestProperty("Expect", "100-continue");
urlConnection.setRequestProperty("Accept", "*/*");
urlConnection.setDoOutput(true);
urlConnection.setDoInput(true);
urlConnection.setUseCaches(false);
urlConnection.setRequestProperty("Authorization", "Basic "
+ userPassEncoded);

OutputStream outUrlConnection = urlConnection.getOutputStream();
OutputStreamWriter out = new OutputStreamWriter(outUrlConnection);

urlConnection.connect();
String params = "name=" + name + "&type=" + imagetype + "&arch="
+ arch + "&bucket=" + bucketname;
out.write(params);
out.flush();

File file = new File("/home/zju/" + name);
FileInputStream in = new FileInputStream(file);
long length;
byte[] buffer = new byte[2048 * 2048];
long total = 0;
while (true) {
length = in.read(buffer);
if (length <= 0)
break;
out.write(length + "\r\n");
out.write(buffer + "\r\n");
out.flush();
total += length;
System.out.println(total);
}

out.write("0\r\n\r\n");
out.flush();
outUrlConnection.close();
out.close();
urlConnection.disconnect();
String s = urlConnection.getResponseMessage();
int t = urlConnection.getResponseCode();

System.out.println("Finish!!!!");
System.out.println(s + t);
} catch (IOException e) {
e.printStackTrace();

} catch (Exception e) {
e.printStackTrace();

}
}
public static void main(String[] args) throws Exception {
vstarEnvImageStub stub = new vstarEnvImageStub();
stub.uploadImageVStarv("172.18.7.108", "8898", "/home/zju", "bbbbb",
"qcow2", "i386", "suzhou_bucket", "fire3", "123456");
}
}