| public static java.lang.String | uploadToServlet(java.lang.String host, java.lang.String port, java.lang.String user, java.lang.String password, com.sun.enterprise.deployment.deploy.shared.Archive module)
/*
* Alternate upload method. It will use UploadServlet instead of using JMX MBean.
* Reason is to increase upload speed.
* @param host admin hostname
* @param port admin port
* @param user admin username
* @param password admin password
* @param file upload file path
* @param name moduleId
* @return remote file path
*/
Socket socket = null;
BufferedInputStream bis = null;
try {
String fileName = null;
if (module instanceof MemoryMappedArchive) {
// jsr88: module.getArchiveUri() == null
byte[] bytes = ((MemoryMappedArchive) module).getByteArray();
bis = new BufferedInputStream(new ByteArrayInputStream(bytes));
File tmpFile = File.createTempFile(JSR88, null);
tmpFile.deleteOnExit();
fileName = tmpFile.getName();
} else {
// other deployment mechanisms
File f = new File(module.getURI().getPath());
bis = new BufferedInputStream(new FileInputStream(f));
fileName = f.getName();
}
// upload servlet url
String path = "/web1/uploadServlet?file=" + URLEncoder.encode(fileName, "UTF-8");
socket = new Socket(host, Integer.parseInt(port));
OutputStream out = socket.getOutputStream();
InputStream in = socket.getInputStream();
// write HTTP headers
BufferedWriter wr = new BufferedWriter(new OutputStreamWriter(out, "UTF-8"));
wr.write("POST " + path + " HTTP/1.0\r\n");
wr.write("Content-Length: " + bis.available() + "\r\n");
wr.write("Content-Type: application/octet-stream\r\n");
// add basic authentication header
byte[] encodedPassword = (user + ":" + password).getBytes();
BASE64Encoder encoder = new BASE64Encoder();
wr.write("Authorization: Basic " + encoder.encode(encodedPassword) + "\r\n");
wr.write("\r\n");
wr.flush();
// write upload file data
byte[] buffer = new byte[1024*64];
for (int i = bis.read(buffer); i > 0; i = bis.read(buffer)) {
out.write(buffer, 0, i);
}
out.flush();
// read HTTP response
BufferedReader reader = new BufferedReader(new InputStreamReader(in, "UTF-8"));
Vector v = new Vector();
for (int timeoutCounter = 0; timeoutCounter < 120; timeoutCounter++) {
boolean finished = false;
while (reader.ready()) {
String curLine = reader.readLine();
v.add(curLine);
if (curLine.startsWith("SUCCESS:")) {
finished = true;
}
}
if (finished) {
break;
} else {
Thread.sleep(500);
}
}
if (v.size() == 0) {
throw new Exception("Upload file failed: no server response received");
}
// parse HTTP response strings
boolean isData = false;
int i = 0;
String responseString = null;
for (Enumeration e = v.elements(); e.hasMoreElements(); i++) {
String curElement = (String) e.nextElement();
// check response code
if (i == 0) {
String responseCode = curElement.substring(curElement.indexOf(" ") + 1);
if (!responseCode.startsWith("200")) {
throw new Exception("HTTP connection failed: " + responseCode);
}
}
// check start of data
if (curElement.equals("")) {
isData = true;
continue;
}
// get first line of data
if (isData) {
responseString = curElement;
break;
}
}
if (responseString == null) {
throw new Exception("Upload file failed: no server response received");
}
if (!responseString.startsWith("SUCCESS:")) {
throw new Exception("Upload file failed: " + responseString);
}
// parse response string to get remote file path
String remotePath = responseString.substring(8);
return remotePath;
} catch (Exception e) {
throw e;
} finally {
if (socket != null) {
socket.close();
}
if (bis != null) {
bis.close();
}
}
|
