| Methods Summary |
|---|
| private static void | appendHTTPMetadata(javax.servlet.http.HttpServletRequest request, java.lang.StringBuffer metaData)
metaData.append("\tURI was " + request.getRequestURI() + "\n");
metaData.append("\tMethod was " + request.getMethod() + "\n");
metaData.append("\tQuery string was " + request.getQueryString() + "\n");
metaData.append("\tRemote user was " + request.getRemoteUser() + "\n");
metaData.append("\tProtocol was " + request.getProtocol() + "\n");
metaData.append("\tScheme was " + request.getScheme() + "\n");
metaData.append("\tRemote address was " + request.getRemoteAddr() + "\n");
metaData.append("\tRemote host was " + request.getRemoteHost() + "\n");
Enumeration headers = request.getHeaderNames();
while (headers.hasMoreElements()) {
String headerName = (String) headers.nextElement();
String headerValue = request.getHeader(headerName);
metaData.append("\tHeader " + headerName + " had value " + headerValue + "\n");
}
return;
|
| private static java.net.Socket | connectToLocalServer(int port)
Socket returnValue;
try {
returnValue = new Socket(InetAddress.getLocalHost(), port);
} catch (IOException e) {
throw new ServletServerException("could not connect to " + "local port");
}
return returnValue;
|
| private static int | convertStringToPort(java.lang.String stringfiedPort)
int returnValue;
try {
returnValue = Integer.parseInt(stringfiedPort);
} catch (NumberFormatException e) {
throw new ServletClientException("invalid port number: " + stringfiedPort);
}
if (returnValue <= 0 || returnValue > 0xFFFF) {
throw new ServletClientException("invalid port: " + returnValue);
}
if (returnValue < 1024) {
throw new ServletClientException("permission denied for port: " + returnValue);
}
return returnValue;
|
| public static void | execute(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, java.lang.String stringifiedPort)
int port = convertStringToPort(stringifiedPort);
Socket connectionToLocalServer = null;
try {
connectionToLocalServer = connectToLocalServer(port);
forwardRequest(request, connectionToLocalServer);
forwardResponse(response, connectionToLocalServer);
} finally {
if (null != connectionToLocalServer) {
connectionToLocalServer.close();
}
}
|
| private static void | forwardRequest(javax.servlet.http.HttpServletRequest request, java.net.Socket connectionToLocalServer)
byte buffer[];
DataInputStream clientIn = new DataInputStream(request.getInputStream());
buffer = new byte[request.getContentLength()];
try {
clientIn.readFully(buffer);
} catch (EOFException e) {
throw new ServletClientException("unexpected EOF " + "reading request body");
} catch (IOException e) {
throw new ServletClientException("error reading request" + " body");
}
printOutRequestMetadata(request, buffer);
DataOutputStream socketOut = null;
// send to local server in HTTP
try {
socketOut = new DataOutputStream(connectionToLocalServer.getOutputStream());
socketOut.writeBytes("POST / HTTP/1.0\r\n");
socketOut.writeBytes("Content-length: " + request.getContentLength() + "\r\n\r\n");
socketOut.write(buffer);
socketOut.flush();
} catch (IOException e) {
throw new ServletServerException("error writing to server");
}
|
| private static void | forwardResponse(javax.servlet.http.HttpServletResponse response, java.net.Socket connectionToLocalServer)
byte[] buffer;
DataInputStream socketIn;
try {
socketIn = new DataInputStream(connectionToLocalServer.getInputStream());
} catch (IOException e) {
throw new ServletServerException("error reading from " + "server");
}
String key = "Content-length:".toLowerCase();
boolean contentLengthFound = false;
String line;
int responseContentLength = -1;
do {
try {
line = socketIn.readLine();
} catch (IOException e) {
throw new ServletServerException("error reading from server");
}
if (line == null) {
throw new ServletServerException("unexpected EOF reading server response");
}
if (line.toLowerCase().startsWith(key)) {
responseContentLength = Integer.parseInt(line.substring(key.length()).trim());
contentLengthFound = true;
}
}
while ((line.length() != 0) &&
(line.charAt(0) != '\r") && (line.charAt(0) != '\n"));
if (!contentLengthFound || responseContentLength < 0)
throw new ServletServerException("missing or invalid content length in server response");
buffer = new byte[responseContentLength];
try {
socketIn.readFully(buffer);
} catch (EOFException e) {
throw new ServletServerException("unexpected EOF reading server response");
} catch (IOException e) {
throw new ServletServerException("error reading from server");
}
response.setStatus(HttpServletResponse.SC_OK);
response.setContentType("application/octet-stream");
response.setContentLength(buffer.length);
try {
OutputStream out = response.getOutputStream();
out.write(buffer);
out.flush();
} catch (IOException e) {
throw new ServletServerException("error writing response");
}
|
| private static void | printOutRequestMetadata(javax.servlet.http.HttpServletRequest request, byte[] content)
StringBuffer metaData = new StringBuffer("Request:\n");
appendHTTPMetadata(request, metaData);
System.out.println(metaData.toString());
|
