我正在为一个站点编写一个上传器类,在上传文件后,我正在读取该站点的上传响应。如果我没有阅读响应,则文件没有上传。我的代码如下,
String charset = "UTF-8";
File binaryFile = new File("C:\\TestVideoFile.flv");
String boundary = Long.toHexString(System.currentTimeMillis());
System.out.println(boundary);// Just generate some unique random value.
String CRLF = "\r\n"; // Line separator required by multipart/form-data.
URLConnection connection = new URL(UPLOAD_URL).openConnection();
connection.setDoInput(true);
connection.setDoOutput(true);
connection.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + boundary);
PrintWriter writer = null;
try {
OutputStream output = connection.getOutputStream();
writer = new PrintWriter(new OutputStreamWriter(output, charset), true); // true = autoFlush, important!
writer.append("--" + boundary).append(CRLF);
writer.append("Content-Disposition: form-data; name=\"file\"; filename=\"" + binaryFile.getName() + "\"").append(CRLF);
writer.append("Content-Type: " + URLConnection.guessContentTypeFromName(binaryFile.getName())).append(CRLF);
writer.append("Content-Transfer-Encoding: binary").append(CRLF);
writer.append(CRLF).flush();
InputStream input = null;
try {
input = new FileInputStream(binaryFile);
long filelen = binaryFile.length();
System.out.println("Length : " + filelen);
int dataRead = 0;
byte[] buffer = new byte[1024];
for (int length = 0; (length = input.read(buffer)) > 0;) {
output.write(buffer, 0, length);
}
System.out.println("Now only terminating the file write loop");
output.flush(); // Important! Output cannot be closed. Close of writer will close output as well.
} catch (Exception e) {
System.out.println(e);
} finally {
if (input != null) {
try {
input.close();
} catch (IOException logOrIgnore) {
System.out.println(logOrIgnore);
}
}
}
writer.append(CRLF).flush(); // CRLF is important! It indicates end of binary boundary.
// End of multipart/form-data.
writer.append("--" + boundary + "--").append(CRLF);
System.out.println("Sending username");
// Send normal param.
writer.append("--" + boundary).append(CRLF);
writer.append("Content-Disposition: form-data; name=\"user\"").append(CRLF);
writer.append("Content-Type: text/plain; charset=" + charset).append(CRLF);
writer.append(CRLF);
writer.append(username).append(CRLF).flush();
System.out.println("Sending password");
writer.append("--" + boundary).append(CRLF);
writer.append("Content-Disposition: form-data; name=\"password\"").append(CRLF);
writer.append("Content-Type: text/plain; charset=" + charset).append(CRLF);
writer.append(CRLF);
writer.append(password).append(CRLF).flush();
System.out.println("Reading response from server");
BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream()));
String k = "", tmp = "";
while ((tmp = br.readLine()) != null) {
System.out.println(tmp);
k += tmp;
}
if (k.contains("Successfully")) {
System.out.println("File Uploaded successfully into PutLocker :)");
String downloadLink = parseResponse(k, "<link>", "</link>");
System.out.println("Download Link : " + downloadLink);
} else {
System.out.println("Upload failed :(");
}
} catch (Exception e) {
System.out.println(e);
} finally {
if (writer != null) {
writer.close();
}
}
如您所见,我正在以下行中将数据写入服务器,
for (int length = 0; (length = input.read(buffer)) > 0;) {
output.write(buffer, 0, length);
}
但在此之后,我必须执行以下操作,
BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream()));
String k = "", tmp = "";
while ((tmp = br.readLine()) != null) {
System.out.println(tmp);
k += tmp;
}
为什么我必须读取服务器的响应才能使上传成功?
有人可以解释一下吗?
提前致谢。